快捷導(dǎo)航

如何取消.net后臺(tái)線程的執(zhí)行

更新時(shí)間：2012年11月09日 16:34:47 作者：

在使用多線程模型進(jìn)行編程時(shí)，經(jīng)常遇到的問(wèn)題之一是，當(dāng)我們關(guān)閉前臺(tái)的UI線程時(shí)，后臺(tái)的輔助線程仍然處于活動(dòng)狀態(tài)，從而導(dǎo)致整個(gè)應(yīng)用程序無(wú)法正常退出

介紹
在使用多線程模型進(jìn)行編程時(shí)，經(jīng)常遇到的問(wèn)題之一是，當(dāng)我們關(guān)閉前臺(tái)的UI線程時(shí)，后臺(tái)的輔助線程仍然處于活動(dòng)狀態(tài)，從而導(dǎo)致整個(gè)應(yīng)用程序無(wú)法正常退出。這時(shí)我們需要一種較安全的方式來(lái)結(jié)束后臺(tái)線程的運(yùn)行，這樣我們可以隨時(shí)結(jié)束后臺(tái)線程的運(yùn)行，并且在線程結(jié)束時(shí)進(jìn)行相應(yīng)的資源清理工作（例如將內(nèi)存數(shù)據(jù)寫(xiě)入硬盤(pán)）。.net框架提供了一些工具來(lái)實(shí)現(xiàn)該功能。

目錄
IsBackground屬性
Abort方法
輪循方式
取消阻塞的線程
IsBackgound屬性
Thread類提供了IsBackground屬性，當(dāng)線程的IsBackground屬性被設(shè)置為true時(shí)，表示此線程為后臺(tái)工作線程。當(dāng)一個(gè)應(yīng)用程序結(jié)束時(shí)，它的所有后臺(tái)線程會(huì)自動(dòng)的被結(jié)束執(zhí)行。如果你有一個(gè)后臺(tái)線程偵聽(tīng)Socket連接，并且正在被阻塞，那么這時(shí)候通過(guò)設(shè)置線程的IsBackground屬性為T(mén)rue,使它自動(dòng)隨應(yīng)用程序的結(jié)束而結(jié)束是比較合適的。但在這種情況下，線程會(huì)靜悄悄的結(jié)束，它不會(huì)引發(fā)任何異常，你的線程沒(méi)有機(jī)會(huì)執(zhí)行一些需要的清理代碼。例如，內(nèi)存中的數(shù)據(jù)可能會(huì)來(lái)不及寫(xiě)入磁盤(pán)，從而造成丟失數(shù)據(jù)。

Abort方法
可以調(diào)用Thread類的Abort方法來(lái)強(qiáng)制終制線程。上調(diào)用此方法時(shí)，線程上引發(fā)ThreadAbortException，并導(dǎo)至線程終結(jié)，通過(guò)捕獲該異常，可以執(zhí)行一些資源清理代碼。但這種模式也有一些問(wèn)題，主要是難以知道線程上的代碼執(zhí)行到什么地方，所有相應(yīng)的資源清理代碼也難以編寫(xiě)。總的來(lái)說(shuō)這是一種比較粗暴的終止線程執(zhí)行的方法，通常來(lái)說(shuō)是不推薦使用的。

輪循方式
如果后臺(tái)線程將執(zhí)行一個(gè)很長(zhǎng)的計(jì)算，那么可以將計(jì)算隔成若干小段，并經(jīng)常檢查是否需要取消線程。.NET框架提供了CancellationTokenSource類來(lái)作為線程取消的統(tǒng)一模式。例如：

復(fù)制代碼代碼如下:

 
public class Example 
{ 
public static void Main() 
{ 
CancellationTokenSource cts = new CancellationTokenSource(); 
var thread = new Thread(ThreadWork); 
thread.Start(cts.Token); 
while (true) 
{ 
if(Console.ReadKey().KeyChar == 'c') 
{ 
Console.WriteLine("請(qǐng)求取消線程的執(zhí)行"); 
cts.Cancel(); 
break; 
} 
} 
Console.ReadLine(); 
} 

private static void ThreadWork(object state) 
{ 
CancellationToken cancellationToken = (CancellationToken)state; 

while (true) 
{ 
// 檢查是否取消 
if(cancellationToken.IsCancellationRequested) 
{ 
Console.WriteLine("線程已經(jīng)取消了"); 
Console.WriteLine("線程的資源已經(jīng)清理完成。"); 
break; 
} 
// 模擬工作 
Thread.SpinWait(500000); 
Console.WriteLine("我還在工作。"); 
} 
} 
} 

取消阻塞的線程
上面的示例中，后臺(tái)線程會(huì)長(zhǎng)時(shí)間進(jìn)行計(jì)算，但更多的時(shí)候，線程會(huì)由于等待某個(gè)事件，從而進(jìn)入阻塞狀態(tài)。這個(gè)時(shí)候，實(shí)際上線程已經(jīng)不再執(zhí)行狀態(tài)了，很明顯，它沒(méi)有機(jī)會(huì)去檢查取消標(biāo)志。那么，該如何解決這個(gè)問(wèn)題呢？CancellationToken的WaitHandle屬性提供了解答。WaitHandle類有一個(gè)靜態(tài)方法WaitAny,它可以同時(shí)等待多個(gè)事件，當(dāng)多個(gè)事件中的任意一個(gè)有效時(shí)，線程都會(huì)從阻塞狀態(tài)中返回?？梢愿鶕?jù)WaitAny方法的返回值來(lái)判斷發(fā)生了什么事件，從而相應(yīng)的執(zhí)行代碼。例子：

復(fù)制代碼代碼如下:

 
public class Example 
{ 
private static int Value; 

public static void Main() 
{ 
var autoResetEvent = new AutoResetEvent(false); 
var cts = new CancellationTokenSource(); 
var state = new { ValueAvailableEvent = autoResetEvent, CancellationToken = cts.Token }; 
var threadConsumer = new Thread(ConsumerThreadWork); 
var threadProducter = new Thread(ProducterThreadWork); 

threadConsumer.Start(state); 
threadProducter.Start(state); 

while (true) 
{ 
if (Console.ReadKey().KeyChar == 'c') 
{ 
Console.WriteLine("請(qǐng)求取消線程的執(zhí)行"); 
cts.Cancel(); 
break; 
} 
} 
Console.ReadLine(); 

} 
public static void ProducterThreadWork(dynamic state) 
{ 
var valueAvailableEvent = (AutoResetEvent)state.ValueAvailableEvent; 
var cancellationToken = (CancellationToken)state.CancellationToken; 
var rand = new Random(); 
while (!cancellationToken.IsCancellationRequested) 
{ 
Value = rand.Next(); 
Console.WriteLine("\r\n產(chǎn)生一個(gè)值{0}", Value); 
valueAvailableEvent.Set(); 
Thread.Sleep(500); 
} 

Console.WriteLine("生產(chǎn)者線程被取消。"); 
} 

public static void ConsumerThreadWork(dynamic state) 
{ 
var valueAvailableEvent = (AutoResetEvent)state.ValueAvailableEvent; 
var cancellationToken = (CancellationToken)state.CancellationToken; 
var events = new[] { valueAvailableEvent, cancellationToken.WaitHandle }; 

while (true) 
{ 
var eventIndex = WaitHandle.WaitAny(events); 
// 處理數(shù)據(jù) 
if (eventIndex == 0) 
{ 
Console.WriteLine("處理值{0}。", Value); 
} 
// 處理取消事件 
else if (eventIndex == 1) 
{ 
Console.WriteLine("消費(fèi)者線程被取消。"); 
break; 
} 
} 
} 
} 

在上面的例子中，有三個(gè)線程，分別是UI線程，生產(chǎn)者線程和消費(fèi)者線程。其中生產(chǎn)者線程每隔一秒產(chǎn)生一個(gè)有效數(shù)值，并將數(shù)據(jù)保存到Value字段中，而消費(fèi)者線程等待值的產(chǎn)生，這個(gè)等待的過(guò)程是阻塞的。消費(fèi)都線程通過(guò)WaitHandle.WaitAny方法來(lái)同時(shí)等待值有效事件或者取消事件，當(dāng)任意一個(gè)事件有效時(shí)，線程都將繼續(xù)，并且通過(guò)返回的值來(lái)判斷發(fā)生的事件，并作相應(yīng)的處理。

總結(jié)
多線程模型中的線程取消問(wèn)題還是比較復(fù)雜的。Thread.IsBackground屬性提供了在前臺(tái)線程結(jié)束后自動(dòng)結(jié)束線程的方法。Thread.Abort方法提供了一種“粗暴”的結(jié)束線程的方法。CancellationTokenSource類則是線程取消的標(biāo)準(zhǔn)模式，我們應(yīng)當(dāng)更多的使用這種模式。文章寫(xiě)的不多，基本是字?jǐn)?shù)不夠，代碼來(lái)湊，大家伙將就的看看吧。

您可能感興趣的文章: