Task和ThreadPool的功能類似，可以用來(lái)創(chuàng)建一些輕量級(jí)的并行任務(wù)。對(duì)于將一個(gè)任務(wù)放進(jìn)線程池

ThreadPool.QueueUserWorkItem(A);

這段代碼用Task來(lái)實(shí)現(xiàn)的話，方式如下：

Task.Factory.StartNew(A);

這兩端代碼的使用和實(shí)現(xiàn)的功能都十分相似。但和TheadPool相比，Task有著更多的功能，更加方便我們使用。

假如我們要?jiǎng)?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)起來(lái)就相對(duì)簡(jiǎ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);

下面我們來(lái)簡(jiǎn)單的介紹一下Task的基本用法：

創(chuàng)建Task

創(chuàng)建Task有兩種方式

• 通過(guò)構(gòu)造函數(shù)創(chuàng)建

Task?t1 =?new?Task(A);

• 通過(guò)TaskFactory創(chuàng)建

Task?t1 =?Task.Factory.StartNew(A);

這兩種方式其實(shí)是一樣的，第一種方式里面也傳入了默認(rèn)的TaskFactory——Task.Factory。TaskFactory起著對(duì)Task進(jìn)行創(chuàng)建和調(diào)度管理的作用，類似于以前CTP版中的TaskManager，關(guān)于這個(gè)對(duì)象，后續(xù)會(huì)單獨(dú)寫一篇文章介紹。

開(kāi)始運(yùn)行Task

在上述兩種創(chuàng)建Task方式中，方式1創(chuàng)建的Task并沒(méi)有立即執(zhí)行，需要手動(dòng)調(diào)用t1.Start()來(lái)執(zhí)行（類似于線程，需要手動(dòng)執(zhí)行）。而方式2創(chuàng)建的Task是立即執(zhí)行的（類似于線程池，是自動(dòng)執(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í)行過(guò)程中發(fā)生異常時(shí)，該異常會(huì)在Wait或WaitAll等函數(shù)中重新throw?？梢酝ㄟ^(guò)Task的Exception屬性來(lái)獲取發(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版本中，是通過(guò)Fucture<>類來(lái)獲取帶返回值的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)大和簡(jiǎn)單。

到此這篇關(guān)于C#并行編程Task類的文章就介紹到這了。希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論