C#并行編程Task類用法介紹
Task和ThreadPool的功能類似,可以用來創(chuàng)建一些輕量級的并行任務(wù)。對于將一個(gè)任務(wù)放進(jìn)線程池
ThreadPool.QueueUserWorkItem(A);
這段代碼用Task來實(shí)現(xiàn)的話,方式如下:
Task.Factory.StartNew(A);
這兩端代碼的使用和實(shí)現(xiàn)的功能都十分相似。但和TheadPool相比,Task有著更多的功能,更加方便我們使用。
假如我們要創(chuàng)建三個(gè)任務(wù),并等待它們完成。這個(gè)功能用TheadPool實(shí)現(xiàn)如下:
using (ManualResetEvent mre1 = new ManualResetEvent(false)) using (ManualResetEvent mre2 = new ManualResetEvent(false)) using (ManualResetEvent mre3 = new ManualResetEvent(false)) { ThreadPool.QueueUserWorkItem(delegate { A(); mre1.Set(); }); ThreadPool.QueueUserWorkItem(delegate { B(); mre2.Set(); }); ThreadPool.QueueUserWorkItem(delegate { C(); mre3.Set(); }); WaitHandle.WaitAll(new WaitHandle[] { mre1, mre2, mre3 }); }
用Task類實(shí)現(xiàn)起來就相對簡單多了:
Task t1 = Task.Factory.StartNew(delegate { A(); }); Task t2 = Task.Factory.StartNew(delegate { B(); }); Task t3 = Task.Factory.StartNew(delegate { C(); }); t1.Wait(); t2.Wait(); t3.Wait();
或者我們還可以這么寫:
Task t1 = Task.Factory.StartNew(delegate { A(); }); Task t2 = Task.Factory.StartNew(delegate { B(); }); Task t3 = Task.Factory.StartNew(delegate { C(); }); Task.WaitAll(t1, t2, t3);
下面我們來簡單的介紹一下Task的基本用法:
創(chuàng)建Task
創(chuàng)建Task有兩種方式
- 通過構(gòu)造函數(shù)創(chuàng)建
Task?t1 =?new?Task(A);
- 通過TaskFactory創(chuàng)建
Task?t1 =?Task.Factory.StartNew(A);
這兩種方式其實(shí)是一樣的,第一種方式里面也傳入了默認(rèn)的TaskFactory——Task.Factory。TaskFactory起著對Task進(jìn)行創(chuàng)建和調(diào)度管理的作用,類似于以前CTP版中的TaskManager,關(guān)于這個(gè)對象,后續(xù)會單獨(dú)寫一篇文章介紹。
開始運(yùn)行Task
在上述兩種創(chuàng)建Task方式中,方式1創(chuàng)建的Task并沒有立即執(zhí)行,需要手動調(diào)用t1.Start()來執(zhí)行(類似于線程,需要手動執(zhí)行)。而方式2創(chuàng)建的Task是立即執(zhí)行的(類似于線程池,是自動執(zhí)行的),從這兩種方式的函數(shù)名稱也可以看出這一點(diǎn)。
等待Task完成
等待Task完成的也有兩種:
- 調(diào)用Task的成員函數(shù)t.Wait()。
- 調(diào)用Task的靜態(tài)函數(shù)Task.WaitAll()或Task.WaitAny()。
這兩種方式和.net中常用的WaitHandle差不多,這里就不多介紹了。
取消Task
取消Task的方式較CTP的時(shí)候復(fù)雜和強(qiáng)大了不少,后續(xù)加一個(gè)單獨(dú)的篇章單獨(dú)介紹。
異常處理
當(dāng)Task在執(zhí)行過程中發(fā)生異常時(shí),該異常會在Wait或WaitAll等函數(shù)中重新throw。可以通過Task的Exception屬性來獲取發(fā)生的異常。
var t1 = Task.Factory.StartNew(() => { throw new Exception("t1 error occor"); }); var t2 = Task.Factory.StartNew(() => { throw new Exception("t2 error occor"); }); try { Task.WaitAll(t1, t2); } catch (Exception) { Console.WriteLine(t1.Exception.InnerException.Message); Console.WriteLine(t2.Exception.InnerException.Message); }
獲取Task的返回值
在CTP版本中,是通過Fucture<>類來獲取帶返回值的Task的,現(xiàn)在已經(jīng)將類改名為Task<>了,從而實(shí)現(xiàn)命名方式的統(tǒng)一。使用方式幾乎一致,就是多了一個(gè)Result屬性,可以在Task執(zhí)行完成后獲取返回值。示例如下:
var t1 = Task.Factory.StartNew(() => 3); t1.Wait(); Console.WriteLine(t1.Result);
其它
在Task中還有不少非常有用的任務(wù)調(diào)度和錯(cuò)誤處理等的方法和屬性,它們使得并發(fā)操作變得更為強(qiáng)大和簡單。
到此這篇關(guān)于C#并行編程Task類的文章就介紹到這了。希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
C# 調(diào)用API函數(shù)彈出映射網(wǎng)絡(luò)驅(qū)動器對話框問題
C#中的.net的常用對話框中沒有映射網(wǎng)絡(luò)驅(qū)動映射對話框,所以需要用windows的API函數(shù)去實(shí)現(xiàn)彈出映射網(wǎng)絡(luò)驅(qū)動器對話框2014-01-01C#?wpf?Bitmap轉(zhuǎn)換成WriteableBitmap的方法
本文主要介紹了C#?wpf?Bitmap轉(zhuǎn)換成WriteableBitmap的方法,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08C#預(yù)處理指令之#line,#pragma warning 詳細(xì)解析
#line 指令可能由生成過程中的自動中間步驟使用。例如,如果行從原始的源代碼文件中移除,但是您仍希望編譯器基于文件中的原始行號生成輸出,則可以移除行,然后用 #line 模擬原始行號2014-01-01Unity UGUI的Toggle復(fù)選框組件使用詳解
這篇文章主要為大家介紹了Unity UGUI的Toggle復(fù)選框組件使用詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-07-07