聊聊多執行緒哪一些事兒(task)之 二 延續操作
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的非同步取消、非同步方法這兩個知識點了,明天我會在單獨一篇文章專門來介紹這兩個知識點,想繼續看明天的後續文章的小夥伴們,點關注哦,明天一定補上,謝謝!
END
為了更高的交流,歡迎大家關注我的公眾號,掃描下面二維碼即可關注,謝謝: