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)之 三 異步取消和異步方法
第四篇:聊聊多線程那一些事兒 之 四 經典應用(取與舍、動態創建)
END
為了更高的交流,歡迎大家關注我的公眾號,掃描下面二維碼即可關注,謝謝: