hello,又見面啦，昨天我們簡單的介紹了如何去創建和運行一個task、如何實作task的同步執行、如何阻塞等待task集合的執行完畢等待，昨天講的是task的最基本的知識點，如果你沒有看昨天的博客，也不要急，你可以點擊下面的地址， 聊聊多執行緒哪一些事兒（task）之 一），先看看后，在回到這兒來繼續交流學習今天的文章，謝謝！
今天主要和大家交流分享的是：task的延續操作、task的異步取消、異步方法等知識點，希望通過本篇文章，能夠給你帶來一點點幫助我就高興的不要不要的啦，當然啦，既然是交流，如果我有什么說的不對，或者說的不好的地方，大家多多指點，多多包涵，如果能夠得到大牛的指點，我也會高興的合不攏嘴，謝謝，好了，不廢話了，言歸正傳，繼續今天的分享加交流，
Task延續操作之WhenAny、WhenAll、ContinueWith
上一篇文章我們已經知道可以通過task.wait/task.WaitAny/task.WaitAll,等方法來實作等待一個tsak或者一組task的執行完畢，這一個方法都會阻塞主執行緒（如果沒有看一篇文章的請單擊查看：聊聊多執行緒哪一些事兒（task）之 一），也就是這一些操作都是主流程的一個必然環節，但是我們在實際專案中，也還會遇到這樣的場景，那就是主流程根本不關心task的執行結果，但是task執行完畢后，需要執行一個其他的子業務，那么這個時候WhenAny、WhenAll、ContinueWith就派上用場了，這幾個方法也就專門是為這樣的場景而存在的，哈哈，說了這么多，是不是覺得有點抽象，有點云里霧里的感覺，說實話，我自己都覺得說的太空洞，還不如來一個實際的場景+代碼實體，這樣整的更明白，
實際業務場景：我想了半天，到得用什么樣的業務場景比較合適呢，最終決定還是以昨天酒店客房資料查詢為例進行為例，用戶在線預訂酒店時，由于真正的客房預訂是需要實時的到第三介面平臺預訂，所以用戶在自己系統下單后，并不代表真正的酒店預訂成功，真正的酒店預訂成功，是需要通過介面到第三方系統下單成功才算真正的預訂成功，并且一個平臺對接的介面都會有多個，平臺最侄訓比價后，選擇一個平臺利用最大化的介面下單，這樣以來，系統不可能讓用戶等待到第三方介面下單成功后，在回傳的用戶吧，這樣用戶是沒有那么好的心情的來等待的，并且這樣也很容易超時的，所以在實際專案處理上，是需要將本系統下單和第三介面預訂兩個步驟解耦，實作異步預訂，其大致的業務邏輯是這樣的，
第一步：用戶在系統發起酒店預訂請求
第二步：本系統下單成功，并回傳給用戶
第三步：開啟一個異步執行緒，到介面方下單
異步執行緒的處理邏輯大概是：
其一：具有該客房的介面方各開啟一個異步執行緒
其二：每一個執行緒的具體邏輯是，根據客房資訊查詢具體的客房資訊（客房狀態、價格、服務等）
其三：當每一個異步執行緒都執行完畢后，對獲取到介面資料進行對比分析，選擇一個最優的介面方進行預訂
其四：預訂成功后，并發送一個訊息給客戶
好了，下面用一個簡單的實體代碼來模擬上面的處理邏輯和流程
/// <summary>/// 酒店在線預訂操作/// </summary>/// <param name="hotelBookInfo">用戶預訂的酒店資訊</param>/// <returns>預訂結果</returns>private static object HotelBook(object hotelBookInfo){ Console.WriteLine("用戶發起了酒店預訂請求！"); Console.WriteLine(""); // 第一步：首先本系統落地酒店預訂相關操作（資料校驗、資料落地、日志記錄等等） // ---此處省略具體的業務邏輯代碼，根據業務需要自由發揮 // 第二步：根據具有該客房的酒店介面商，開啟異步執行緒預訂酒店 //（假設第一步操作都成功的，并且 攜程和藝龍都有該客房） // 模擬存盤獲取到的酒店客房資料集合 List<string> listHotelRoomInfro = new List<string>(); // 其一、通過傳統的 new 方式來實體化一個task物件，獲取 攜程 的客房時時資料 Task newCtripTask = new Task(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); Console.WriteLine("攜程 介面資料獲取完畢！"); Console.WriteLine(""); listHotelRoomInfro.Add("我是來自 攜程 的最新客房資訊，該客房可預訂,預訂價格為：100元"); }); // 啟動 tsak newCtripTask.Start(); // 其二、通過工廠 factory 來生成一個task物件，并自啟動：獲取 藝龍 的客房資料 Task factoryElongTask = Task.Factory.StartNew(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); Console.WriteLine("藝龍 介面資料獲取完畢！"); Console.WriteLine(""); listHotelRoomInfro.Add("我是來自 藝龍 的最新客房資訊，該客房可預訂,預訂價格為：99元"); }); // 其三：通過 Task.WhenAll() 來執行 攜程和藝龍的客房資料獲取結果的后續處理 // Task.WhenAll() 可以用 Task.Factory.ContinueWhenAll()來代替，兩種的效果是一樣的 Task.Factory.ContinueWhenAll(new Task[] { newCtripTask, factoryElongTask }, (t) => { }); Task.WhenAll(newCtripTask, factoryElongTask).ContinueWith((t) => { Console.WriteLine("所有介面資料獲取完畢，現在進行最優選擇！"); Console.WriteLine(""); // 對比 所有介面獲取的實時資料，找到一個平臺利益最大化的介面預訂 // 具體的規則，每個平臺都有自己的規則，在此我們簡單的以價格最低為準，具體的對比邏輯就不在寫了 // 根據資料分析，最終藝龍的價格最低，所以直接預訂藝龍的資料 Console.WriteLine("藝龍介面最優，現在呼叫藝龍在線預訂介面！"); Console.WriteLine(""); // 模擬呼叫藝龍的酒店預訂介面，進行酒店預訂 Thread.Sleep(new Random().Next(100, 1000)); // 預訂成功后，系統資料落地的相關業務操作..... Console.WriteLine("藝龍在線預訂成功，開始后續業務流程處理！"); }); // 第三步步：回傳用戶，下單成功 Console.WriteLine("您好，你的酒店下單成功，具體的預訂結果等待第三方酒店提高商的回傳結果為準！謝謝"); Console.WriteLine(""); return "構建下單成功相關資訊";}
執行結果：
通過上面的執行結果，我們可以得出以下幾點：
其一、WhenAll里面的邏輯是在所有tsak都執行完畢后，在執行
其二、whenAll的執行，不會影響主執行緒的執行
其三、其實簡單的理解，WhenAll可以理解為一個task組的異步回呼
好了，詳細的舉例說了whenAll的使用，至于 WhenAny 使用就不在詳細說明了，其實從字面意思都能夠看明白啦，就是只要所有的task集合中，只有有一個task執行完成，就在執行whenAny里面的邏輯，也就是說，wenAll和whenAny的唯一區別就是：前者是要所有task都執行完畢才執行，后者只需要有一個執行完畢就執行里面的邏輯，
其實WhenAny 的有實際應用場景也是很多的，比如，一個具有競爭的業務邏輯中，最終只選擇一個效率對快的一個，那么WhenAny就能夠發揮其作用了，
Task.WhenAll與Task.Factory.ContinueWhenAll
Task.WhenAny 與Task.Factory.ContinueWhenAny
這兩者是一個成對的等效操作，其實你閱讀兩個的底層原始碼實作，你會發現，其實最終第底層實作都是呼叫的TaskFactory中的同一方法實作，所以就不在啰嗦的寫一次Task.Factory.ContinueWhenAll的場景應用，需要閱讀的底層原始碼的，可以查看下面地址進行閱讀：https://blog.csdn.net/weixin_33701294/article/details/85958795
好了，今天就寫到這兒了，我仔細看了一下，文章篇幅已經夠多了，本篇文章就不在介紹 task的異步取消、異步方法這兩個知識點了，明天我會在單獨一篇文章專門來介紹這兩個知識點，想繼續看明天的后續文章的小伙伴們，點關注哦，明天一定補上，謝謝！
猜您喜歡：
第一篇：聊聊多執行緒哪一些事兒（task）之 一創建運行與阻塞
第二篇：聊聊多執行緒哪一些事兒（task）之 二 延續操作
第三篇：聊聊多執行緒那一些事兒（task）之 三 異步取消和異步方法
第四篇：聊聊多執行緒那一些事兒 之 四 經典應用（取與舍、動態創建）
END
為了更高的交流，歡迎大家關注我的公眾號，掃描下面二維碼即可關注，謝謝：
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/77427.html
標籤：.NET Core