一,、直接使用線程的問題每次都要創(chuàng)建Thread對象,,并向操作系統(tǒng)申請創(chuàng)建一個線程,這是需要耗費CPU時間和內(nèi)存資源的,。 無法直接獲取線程函數(shù)返回值 無法直接捕捉線程函數(shù)內(nèi)發(fā)生的異常
使用線程池可以解決第一個問題
二,、.NET中的線程池 在這里只簡單的介紹一下ThreadPool,由于TPL的存在,,我工作中大部分使用的是TPL中的類,,這是后面介紹的重點,。 1. ThreadPool.QueueUserWorkItem 這個方法有三個重載
public static bool QueueUserWorkItem(WaitCallback callBack) public static bool QueueUserWorkItem(WaitCallback callBack, object? state) public static bool QueueUserWorkItem<TState>(Action<TState> callBack, TState state, bool preferLocal)
第一個函數(shù)需要傳入一個WaitCallback 委托,,該委托的定義如下
第二個函數(shù)多了一個state參數(shù),表示需要傳給委托的參數(shù),,若無需傳參調(diào)用第一個函數(shù)即可,。
第三個函數(shù)是一個泛型版本,,還多了一個布爾類型的參數(shù)preferLocal,這個參數(shù)表示傳入的委托將會在放入線程池工作線程的本地隊列還是線程池的全局隊列,。
線程池內(nèi)部有本地隊列和全局隊列的概念,,線程池遵循生產(chǎn)者-消費者模式,線程池還可以為線程數(shù)量提供良好的伸縮性,,有關(guān).NET線程池的詳細信息,,請參見https://docs.microsoft.com/zh-cn/dotnet/api/system.threading.threadpool?view=netcore-3.1
需要注意的是,線程池中的線程默認為后臺線程,,這意味著如下代碼一般不能按預(yù)期工作,。
1 static void Main(string[] args)2 {3 ThreadPool.QueueUserWorkItem(state =>4 {5 Thread.Sleep(100);6 Console.WriteLine("執(zhí)行完畢");7 });8 }
并且由于線程會被復(fù)用,所以不能作依賴于某個特定線程的操作,。
2. 何時不使用線程池(摘錄微軟文檔)需要一個前臺線程,。 需要具有特定優(yōu)先級的線程。 擁有會導(dǎo)致線程長時間阻塞的任務(wù),。 線程池具有最大線程數(shù),,因此大量被阻塞的線程池線程可能會阻止任務(wù)啟動。 需將線程放入單線程單元,。 所有 ThreadPool 線程均位于多線程單元中,。 需具有與線程關(guān)聯(lián)的穩(wěn)定標識,或需將一個線程專用于一項任務(wù)。
三,、更方便的解決方案(使用TPL)1.處理線程池未解決的問題 線程池雖然解決了線程資源浪費的問題,,但是以下兩點還未解決
無法直接獲取線程函數(shù)返回值 無法直接捕捉線程函數(shù)內(nèi)發(fā)生的異常
在上一篇中MyTask類可以解決這兩個問題,但由于內(nèi)部是每個Task直接開一個線程,,資源浪費的問題還是沒有解決,,所以我們是不是能夠把兩者結(jié)合呢?
2.Task初體驗無返回值無異常 1 static void Main(string[] args) 2 { 3 Task task = new Task(() =>
4 { 5 Thread.Sleep(100); 6 Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}"); 7 }); 8 task.Start(); 9 try10 {11 task.Wait();12 }13 catch(Exception e)14 {15 Console.WriteLine(e.Message);16 }17 }
輸出如下:
無返回值有異常 1 static void Main(string[] args) 2 { 3 var task = new Task(() =>
4 { 5 Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}"); 6 var task1 = new Task(() =>
7 { 8 Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}"); 9 throw new Exception("延續(xù)任務(wù)發(fā)生異常");10 },TaskCreationOptions.AttachedToParent);11 task1.Start();12 throw new Exception("主任務(wù)發(fā)生異常");13 });14 15 task.Start();16 try17 {18 task.Wait();19 }20 catch(AggregateException ae)//Task內(nèi)部包裝了異常,,有異常發(fā)生Wait()內(nèi)部會拋出一個聚合異常21 {22 foreach(var e in ae.Flatten().InnerExceptions)//把階梯式的聚合異常變?yōu)楸馄降漠惓?3 {24 Console.WriteLine(e.Message);25 }26 }27 }
有返回值的就不演示了,。可以看到,,使用Task解決了開始的三種問題,,但事物總是具有兩面性,有優(yōu)點也有缺點,,Task會帶來額外的內(nèi)存分配,,Task抽象層次過高,深入理解并使用好并非易事,,在與async/await關(guān)鍵字配合編寫異步代碼時更加突出,。
網(wǎng)上關(guān)于Task的使用例子很多,微軟文檔也很全,,我在此這里補充一下需要注意的地方,。
任務(wù)是托管線程上更高層次的抽象 任務(wù)的執(zhí)行由任務(wù)調(diào)度器(TaskScheduler)決定 默認的任務(wù)調(diào)度器是線程池調(diào)度器,它使用線程池執(zhí)行任務(wù) Task.Run()靜態(tài)方法和Task.Start()實例方法以及默認的任務(wù)工廠Task.Factory都是使用默認的線程池任務(wù)調(diào)度器 因此說Task是對線程池的封裝是不準確的 通過指定TaskCreationOptions.LongRunning枚舉便可讓任務(wù)在非線程池中的線程上執(zhí)行,,這樣可以避免長期占用線程池中的線程,,因為線程池是有大小的,一般線程池用來處理簡單但量多的工作,。
|