聊聊多線程那一些事兒(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的異步取消、異步方法這兩個知識點了,明天我會在單獨一篇文章專門來介紹這兩個知識點,想繼續看明天的后續文章的小伙伴們,點關注哦,明天一定補上,謝謝!

 

猜您喜歡:        

 第一篇:聊聊多線程哪一些事兒(task)之 一創建運行與阻塞

 第二篇:聊聊多線程哪一些事兒(task)之 二 延續操作

 第三篇:聊聊多線程那一些事兒(task)之 三 異步取消和異步方法

 第四篇:聊聊多線程那一些事兒 之 四 經典應用(取與舍、動態創建)

END
為了更高的交流,歡迎大家關注我的公眾號,掃描下面二維碼即可關注,謝謝:


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM