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

