日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > C# >内容正文

C#

5天玩转C#并行和多线程编程 —— 第四天 Task进阶

發布時間:2025/4/5 C# 36 豆豆
生活随笔 收集整理的這篇文章主要介紹了 5天玩转C#并行和多线程编程 —— 第四天 Task进阶 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

?

?一、Task的嵌套

?  Task中還可以再嵌套Task,Thread中能不能這樣做,我只能說我是沒這樣寫過。Task中的嵌套,我感覺其實也可以分開來寫,不過嵌套起來會方便管理一點。Task中的嵌套分為兩種,關聯嵌套和非關聯嵌套,就是說內層的Task和外層的Task是否有聯系,下面我們編寫代碼先來看一下非關聯嵌套,及內層Task和外層Task沒有任何關系,還是在控制臺程序下面,代碼如下:

static void Main(string[] args){var pTask = Task.Factory.StartNew(() => {var cTask = Task.Factory.StartNew(() =>{System.Threading.Thread.Sleep(2000);Console.WriteLine("Childen task finished!");});Console.WriteLine("Parent task finished!");});pTask.Wait();Console.WriteLine("Flag");Console.Read();}

運行后,輸出以下信息:

從圖中我們可以看到,外層的pTask運行完后,并不會等待內層的cTask,直接向下走先輸出了Flag。這種嵌套有時候相當于我們創建兩個Task,但是嵌套在一起的話,在Task比較多時會方便查找和管理,并且還可以在一個Task中途加入多個Task,讓進度并行前進。

下面我們來看一下如何創建關聯嵌套,就是創建有父子關系的Task,修改上面代碼如下:

static void Main(string[] args){var pTask = Task.Factory.StartNew(() => {var cTask = Task.Factory.StartNew(() =>{System.Threading.Thread.Sleep(2000);Console.WriteLine("Childen task finished!");},TaskCreationOptions.AttachedToParent);Console.WriteLine("Parent task finished!");});pTask.Wait();Console.WriteLine("Flag");Console.Read();}

可以看到,我們在創建cTask時,加入了以參數,TaskCreationOptions.AttachedToParent,這個時候,cTask和pTask就會建立關聯,cTask就會成為pTask的一部分,運行代碼,看下結果:

可以看到,tTask會等待cTask執行完成。省得我們寫Task.WaitAll了,外層的Task會自動等待所有的子Task完成才向下走。

?

下面我們來寫一個Task綜合使用的例子,來看一下多任務是如何協作的。假設有如下任務,如圖:

任務2和任務3要等待任務1完成后,取得任務1的結果,然后開始執行。任務4要等待任務2完成,取得其結果才能執行,最終任務3和任務4都完成了,合并結果,任務完成。圖中已經說的很明白了。下面來看一下代碼:

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks;namespace TaskDemo {class Program{static void Main(string[] args){Task.Factory.StartNew(() =>{var t1 = Task.Factory.StartNew<int>(() => {Console.WriteLine("Task 1 running...");return 1;});t1.Wait(); //等待任務一完成var t3 = Task.Factory.StartNew<int>(() =>{Console.WriteLine("Task 3 running...");return t1.Result + 3;});var t4 = Task.Factory.StartNew<int>(() =>{Console.WriteLine("Task 2 running...");return t1.Result + 2;}).ContinueWith<int>(task =>{Console.WriteLine("Task 4 running...");return task.Result + 4;});Task.WaitAll(t3, t4); //等待任務三和任務四完成var result = Task.Factory.StartNew(() =>{Console.WriteLine("Task Finished! The result is {0}",t3.Result + t4.Result);});});Console.Read();}} }

任務2和任務4可以用ContinueWith連接執行,最終運行結果如圖:

可以看到所有的任務都執行了,我們也得到了正確的結果11.這下體會到Task的強大了吧~

?

?二、Task的異常處理

?  任何應用程序都需要有異常處理機制,誰也不能保證自己寫到代碼在任何時候都是可以正常運行的,那么在Task中到底該怎么處理異常呢?先來按照平時的寫法,加個Try...Catch...試試,看看會出現什么現象:

static void Main(string[] args){try{var pTask = Task.Factory.StartNew(() =>{var cTask = Task.Factory.StartNew(() =>{System.Threading.Thread.Sleep(2000);throw new Exception("cTask Error!");Console.WriteLine("Childen task finished!");});throw new Exception("pTask Error!");Console.WriteLine("Parent task finished!");});pTask.Wait();}catch (Exception ex){Console.WriteLine(ex.Message);}Console.WriteLine("Flag");Console.Read();}

?

大家都看得懂,就不解釋了,直接F5運行,結果如圖:

唉,不對啊~~怎么顯示這異常信息呢?先不說異常信息對不對,反正異常是捕獲到了。從這張圖中你們還發現了什么嗎?

沒錯,cTask被中斷了,這里cTask和pTask并沒有建立關聯,但是pTask出現異常,其內部的Task也都會中斷,不再執行,即使異常是在子Task啟動以后發生的。

下面我們繼續來說異常吧,來看看正確的異常處理辦法,怎么捕獲到真正的異常信息,代碼如下:

static void Main(string[] args){try{var pTask = Task.Factory.StartNew(() =>{var cTask = Task.Factory.StartNew(() =>{System.Threading.Thread.Sleep(2000);throw new Exception("cTask Error!");Console.WriteLine("Childen task finished!");});throw new Exception("pTask Error!");Console.WriteLine("Parent task finished!");});pTask.Wait();}catch (AggregateException ex){foreach (Exception inner in ex.InnerExceptions){Console.WriteLine(inner.Message);}}Console.WriteLine("Flag");Console.Read();}

這里用了AggregateException,就是異常集合,當然開發中不會只有一個線程,肯定會有多個線程,多個線程就可能有多個異常。我們變量異常集合,輸出異常信息,如下圖:

對了吧,看到正確的異常信息了,但是還是看不到cTask的,因為他被中斷了。

當然,除了在task中使用異常,我們還可以通過Task的幾個屬性來判斷Task的狀態,如:IsCompleted, IsFaulted, IsCancelled,Exception等等來判斷task是否成功的執行了。

?

轉載于:https://www.cnblogs.com/fire909090/p/8023702.html

總結

以上是生活随笔為你收集整理的5天玩转C#并行和多线程编程 —— 第四天 Task进阶的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。