多執行緒，一個多么熟悉的詞匯，作為一名程式員，我相信無論是從事什么開發語言，都能夠輕輕松松說出幾種實作多執行緒的方式，并且在實際作業種也一定用到過多執行緒，比如：定時器、異步作業等等，如果你說你沒有用過多執行緒，我懷疑你是不是一名程式員，哈哈，
哈哈，言歸正傳，今天我們要說說c#中的多線執行緒哪一些事，當然c#在實作多執行緒上有多種方式，比如：Threads、Action、ThreadPool、Task、Parallel等，當然每一種方式都用其優點和缺點，也有其應用場景，在此不一一說明，今天我們主要以task為例，來一起聊聊task的使用，也就當著一次自我總結提煉罷了，
為什么要用多執行緒
其實我們在實際使用程序中，使用多執行緒的目的其實即使為了實作異步+并行，異步：是相對同步的，同步就是一個流程安裝一個流程執行完畢，異步就是在不影響主流程的執行同時，可以執行其他流程，這也就是達到了幾個邏輯并行執行的效果，當然了，不是說異步就完全是獨立執行，相互間就沒有關聯關系，其實在異步的同時，也可以在特定節點等待阻塞等待異步結果啦，說了半天廢話，不要走開，主題才剛剛開始，下面以實際例子來演繹task的實際使用吧！
如何創建和運行一個task
微軟就是那么6逼，在創建和執行一個task時，都給大家提供了多種方式來實作，大家可以根據其具體的使用場景和習慣來選擇最適合的方式，下面通過代碼來簡單說明如下的三種實作方式：
/// <summary> /// 簡單的task創建方式演示 /// </summary> private static void TaskCreatFun() { // 其一、通過傳統的 new 方式來實體化一個task物件，這種方式需要手動通過start來啟動 Task newTask = new Task(() => { Thread.Sleep(1000); Console.WriteLine($"Hello Engineer, 我是 new 的一個task,執行緒ID：Thread.CurrentThread.ManagedThreadId}"); }); // 啟動 tsak newTask.Start(); // 其二、通過工廠 factory 來生成一個task物件，并自啟動 Task factoryTask = Task.Factory.StartNew(() => { Thread.Sleep(1000); Console.WriteLine($"Hello Engineer, 我是 factory 生產 的一個task,執行緒ID：Thread.CurrentThread.ManagedThreadId}"); }); // 其三、通過 Task.Run(Action action) 來創建一個自啟動task Task runTask = Task.Run(() => { Thread.Sleep(1000); Console.WriteLine($"Hello Engineer, 我是 Task.Run 創建一個自啟動task,執行緒ID：Thread.CurrentThread.ManagedThreadId}"); }); runTask.RunSynchronously(); Console.WriteLine($"Hello Engineer, 我是主執行緒啦！執行緒ID{Thread.CurrentThread.ManagedThreadId}"); }
代碼的執行結果：很容易看出，task執行阻塞主執行緒，并且幾個task并行執行，
如何創建一個帶有回傳值的task
在上面的代碼實體種，我們以不同的方式創建并運行了一個多執行緒，但是這幾個task都是沒有回傳值的，這樣的task適用于：獨立執行的一個子業務，完全不關心其執行結果，但是我們在實際使中，往往會需要關系其執行結果的，
以一個實際的業務場景來說明：比如，我們在一個酒店預訂系統中，需要實時到不同的第三介面實時查詢某一個酒店的某一客房在最新狀態，比如有3個介面渠道：攜程、藝龍、去哪兒，該如何實作呢？
首先，如果我們采用串行的方式一個一個的去取資料，那樣估計你的系統慢到不會有人用的，所以我們第一個想到的是，采用task來并行獲取，并回傳獲取到的結果值，下面簡單模擬一下代碼實作：
/// <summary> /// 獲取最新的客房資訊 /// </summary> /// <returns>客房資訊集合</returns> private static List<string> GetHotelRoomInfro() { // 模擬存盤獲取到的酒店客房資料集合 List<string> listHotelRoomInfro = new List<string>(); Console.WriteLine("下面通過3個task，并行的到不同介面方獲取實時的客房資訊："); Console.WriteLine(""); // 在此我也分別對3種不同渠道，采用3種不同的方式來實作 // 其一、通過傳統的 new 方式來實體化一個task物件，獲取 攜程 的客房資料 Task<string> newCtripTask = new Task<string>(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); Console.WriteLine("攜程 內部處理完畢！"); return "我是來自 攜程 的最新客房資訊"; }); // 啟動 tsak newCtripTask.Start(); // 其二、通過工廠 factory 來生成一個task物件，并自啟動：獲取 藝龍 的客房資料 Task<string> factoryElongTask = Task<string>.Factory.StartNew(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); Console.WriteLine("藝龍 內部處理完畢！"); return "我是來自 藝龍 的最新客房資訊"; }); // 其三、通過 Task.Run(Action action) 來創建一個自啟動task：獲取 去哪兒網 的客房資料 Task<string> runQunarTask = Task<string>.Run(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); Console.WriteLine("去哪兒網 內部處理完畢！"); return "我是來自 去哪兒網 的最新客房資訊"; }); // 分別列印不同渠道的客房資料 Console.WriteLine(newCtripTask.Result); Console.WriteLine(factoryElongTask.Result); Console.WriteLine(runQunarTask.Result); Console.WriteLine(""); Console.WriteLine("所有介面方的最新客房資料獲取完畢！"); return listHotelRoomInfro; }
執行結果：
其實通過上面的執行結果，我們不難看出以下幾點
1、task雖然是異步執行緒，但是可以有回傳值的
2、task的回傳值獲取方式為：task.Result
3、在通過task.Result獲取回傳值時，會阻塞主執行緒，其實也不難理解，你要等待處理結果，肯定會阻塞等待啦！
task可以同步執行嗎？
通過上面的實際代碼測驗，我們知道task都是異步執行，那么有人會問，task可以實作同步執行嗎？不急，強大的微軟也想到了這個問題，于是乎，提供了 task.RunSynchronously() 來同步執行，但是這種方式執行，只有通過new 實體化的task才有效，原因也很簡單，其他兩種方式創建task都已經自啟動執行了，不可能在來一個同步啟動執行吧，嘿嘿，下面我們用代碼來演示：
/// <summary> /// 通過RunSynchronously 實作task的同步執行 /// </summary> private static void TaskRunSynchronously() { Console.WriteLine("主執行緒開始執行！"); Task<string> task = new Task<string>(() => { Thread.Sleep(100); Console.WriteLine("Task執行結束!"); return ""; }); /// task.Start(); /// task.Wait(); // 獲取執行結果，會阻塞主流程 // string result = task.Result; //同步執行，task會阻塞主執行緒 task.RunSynchronously(); Console.WriteLine("執行主執行緒結束！"); Console.ReadKey(); }
執行結果：很明顯主執行緒阻塞等待task同步執行，
task同步執行，出了上面的實作方式，其實我們也可以通過task.wait()來變相的實作同步執行效果，當然也可以用task.Result來變現的實作，原理很簡單，因為wait()和Result都是要阻塞主流程，直到task執行完畢，是不是有異曲同工之妙呢！以代碼為例：
通過task.wait()實作，只需要對上面的代碼做一個簡單的調整，如下：其最終的效果一樣：
/// <summary> /// 通過RunSynchronously 實作task的同步執行 /// </summary> private static void TaskRunSynchronously() { Console.WriteLine("主執行緒開始執行！"); Task<string> task = new Task<string>(() => { Thread.Sleep(100); Console.WriteLine("Task執行結束!"); return ""; }); task.Start(); task.Wait(); // 獲取執行結果，會阻塞主流程 // string result = task.Result; // 同步執行，task會阻塞主執行緒 // task.RunSynchronously(); Console.WriteLine("執行主執行緒結束！"); Console.ReadKey(); }
執行結果：
通過task.Result 實作，前提是task一定要有回傳值，如下：其最終的效果一樣：
/// <summary> /// 通過RunSynchronously 實作task的同步執行 /// </summary> private static void TaskRunSynchronously() { Console.WriteLine("主執行緒開始執行！"); Task<string> task = new Task<string>(() => { Thread.Sleep(100); Console.WriteLine("Task執行結束!"); return ""; }); task.Start(); /// task.Wait(); // 獲取執行結果，會阻塞主流程 string result = task.Result; // 同步執行，task會阻塞主執行緒 // task.RunSynchronously(); Console.WriteLine("執行主執行緒結束！"); Console.ReadKey(); }
執行效果也和上面的兩種方式一樣，
當然我還可以通過task.IsCompleted來變現實作，在此就不在細說，簡單一個代碼示意即可:while (!task.IsCompleted){}
當然我上面說的幾種實作同步的方式，只是為了拓展一下思路，不一定都是最優方案，
Task的Wait、WaitAny、WaitAll方法介紹
task的基本創建和用法，上面都做了簡單的介紹，但是在我們實際業務場景中，往往不是那么簡單的單純實作，比如：還是剛剛上面的那個酒店資訊獲取為例，現在新的需求是：3個渠道的介面實時資料，我們只需要獲取到其中的一個就立即回傳會用戶，避免用戶等待太久，那么這個時候task.WaitAny就派上用場了，WaitAny就是等待一組tsak集合中，只要有一個執行完畢就不在等待，與之對應的是WaitAll需要等待一組tsak集合中所有tsak都執行完畢，當然了Wait是針對一個task的，等待本身執行完成，上面的模擬同步執行已經說了，就不在啰嗦，
/// <summary> /// 獲取最新的客房資訊(只需要獲取到一個即可) /// </summary> /// <returns>客房資訊集合</returns> private static List<string> GetOneHotelRoomInfro() { // 模擬存盤獲取到的酒店客房資料集合 List<string> listHotelRoomInfro = new List<string>(); Console.WriteLine("下面通過3個task，并行的到不同介面方獲取實時的客房資訊："); Console.WriteLine(""); // 在此我也分別對3種不同渠道，采用3種不同的方式來實作 // 其一、通過傳統的 new 方式來實體化一個task對象，獲取 攜程 的客房資料 Task newCtripTask = new Task(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); listHotelRoomInfro.Add("我是來自 攜程 的最新客房資訊"); }); // 啟動 tsak newCtripTask.Start(); // 其二、通過工廠 factory 來生成一個task物件，并自啟動：獲取 藝龍 的客房資料 Task factoryElongTask = Task.Factory.StartNew(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); listHotelRoomInfro.Add("我是來自 藝龍 的最新客房資訊"); }); // 其三、通過 Task.Run(Action action) 來創建一個自啟動task：獲取 去哪兒網 的客房資料 Task runQunarTask = Task.Run(() => { // 具體獲取業務邏輯處理... Thread.Sleep(new Random().Next(100, 1000)); listHotelRoomInfro.Add("我是來自 去哪兒網 的最新客房資訊"); }); // 只需要等待一個有回傳即可 Task.WaitAny(new Task[] { newCtripTask, factoryElongTask, runQunarTask }); // 等待所有介面資料回傳 // Task.WaitAll(new Task[] { newCtripTask, factoryElongTask, runQunarTask }); Console.WriteLine("已經有介面資料回傳！"); foreach (var item in listHotelRoomInfro) { Console.WriteLine($"回傳的介面資料為：{item}"); } Console.WriteLine("主執行緒執行完畢！"); Console.ReadKey(); Console.WriteLine(""); return listHotelRoomInfro; }
上面是演示了WaitAny的執行結果，至于WaitAll就不在演示了，一看便知
好了，今天時間差不多了，就介紹到兒了，明天我們在來研究:
1、task的延續操作(WhenAny/WhenAll/ContinueWith)
2、任務取消(CancellationTokenSource)
3、實際案例分析
猜您喜歡：
第一篇：聊聊多執行緒哪一些事兒（task）之 一創建運行與阻塞
第二篇：聊聊多執行緒哪一些事兒（task）之 二 延續操作
第三篇：聊聊多執行緒那一些事兒（task）之 三 異步取消和異步方法
第四篇：聊聊多執行緒那一些事兒 之 四 經典應用（取與舍、動態創建）
END
為了更高的交流，歡迎大家關注我的公眾號，掃描下面二維碼即可關注，謝謝：
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/79167.html
標籤：.NET Core