聊聊多線程哪一些事兒（task）之二延續操作

上一篇文章我們已經知道可以通過task.wait/task.WaitAny/task.WaitAll,等方法來實現等待一個tsak或者一組task的執行完畢，這一個方法都會阻塞主線程也就是這一些操作都是主流程的一個必然環節，但是我們在實際項目中，也還會遇到這樣的場景，那就是主流程根本不關心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
為了更高的交流，歡迎大家關註我的公眾號，掃描下麵二維碼即可關註，謝謝：