日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

C#并行編程Task類用法介紹_C#教程

作者：天方 ? 更新時間： 2022-08-10 編程語言

Task和ThreadPool的功能類似，可以用來創建一些輕量級的并行任務。對于將一個任務放進線程池

ThreadPool.QueueUserWorkItem(A);

這段代碼用Task來實現的話，方式如下：

Task.Factory.StartNew(A);

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

假如我們要創建三個任務，并等待它們完成。這個功能用TheadPool實現如下：

    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類實現起來就相對簡單多了：

    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的基本用法：

創建Task

創建Task有兩種方式

  • 通過構造函數創建
Task?t1 =?new?Task(A);
  • 通過TaskFactory創建
Task?t1 =?Task.Factory.StartNew(A);

這兩種方式其實是一樣的，第一種方式里面也傳入了默認的TaskFactory——Task.Factory。TaskFactory起著對Task進行創建和調度管理的作用，類似于以前CTP版中的TaskManager，關于這個對象，后續會單獨寫一篇文章介紹。

開始運行Task

在上述兩種創建Task方式中，方式1創建的Task并沒有立即執行，需要手動調用t1.Start()來執行（類似于線程，需要手動執行）。而方式2創建的Task是立即執行的（類似于線程池，是自動執行的），從這兩種方式的函數名稱也可以看出這一點。

等待Task完成

等待Task完成的也有兩種：

  • 調用Task的成員函數t.Wait()。
  • 調用Task的靜態函數Task.WaitAll()或Task.WaitAny()。

這兩種方式和.net中常用的WaitHandle差不多，這里就不多介紹了。

取消Task

取消Task的方式較CTP的時候復雜和強大了不少，后續加一個單獨的篇章單獨介紹。

異常處理

當Task在執行過程中發生異常時，該異常會在Wait或WaitAll等函數中重新throw?？梢酝ㄟ^Task的Exception屬性來獲取發生的異常。

    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的，現在已經將類改名為Task<>了，從而實現命名方式的統一。使用方式幾乎一致，就是多了一個Result屬性，可以在Task執行完成后獲取返回值。示例如下：

    var t1 = Task.Factory.StartNew(() => 3);
    t1.Wait();
    Console.WriteLine(t1.Result);

其它

在Task中還有不少非常有用的任務調度和錯誤處理等的方法和屬性，它們使得并發操作變得更為強大和簡單。

原文鏈接：https://www.cnblogs.com/TianFang/archive/2009/11/02/1594783.html

欄目分類
最近更新