C#多線程編程(二)線程池與TPL

来源:https://www.cnblogs.com/hkfyf/archive/2020/07/07/13173305.html
-Advertisement-
Play Games

一、直接使用線程的問題每次都要創建Thread對象,並向操作系統申請創建一個線程,這是需要耗費CPU時間和記憶體資源的。無法直接獲取線程函數返回值無法直接捕捉線程函數內發生的異常 使用線程池可以解決第一個問題二、.NET中的線程池 在這裡只簡單的介紹一下ThreadPool,由於TPL的存在,我工作中... ...


一、直接使用線程的問題

  1. 每次都要創建Thread對象,並向操作系統申請創建一個線程,這是需要耗費CPU時間和記憶體資源的。
  2. 無法直接獲取線程函數返回值
  3. 無法直接捕捉線程函數內發生的異常

      使用線程池可以解決第一個問題

二、.NET中的線程池

      在這裡只簡單的介紹一下ThreadPool,由於TPL的存在,我工作中大部分使用的是TPL中的類,這是後面介紹的重點。

1. ThreadPool.QueueUserWorkItem

      這個方法有三個重載

  • public static bool QueueUserWorkItem(WaitCallback callBack)
  • public static bool QueueUserWorkItem(WaitCallback callBack, object? state)
  • public static bool QueueUserWorkItem<TState>(Action<TState> callBack, TState state, bool preferLocal)

      第一個函數需要傳入一個WaitCallback 委托,該委托的定義如下

  • public delegate void WaitCallback(object? state);

      第二個函數多了一個state參數,表示需要傳給委托的參數,若無需傳參調用第一個函數即可。

      第三個函數是一個泛型版本,還多了一個布爾類型的參數preferLocal,這個參數表示傳入的委托將會在放入線程池工作線程的本地隊列還是線程池的全局隊列。

      線程池內部有本地隊列全局隊列的概念,線程池遵循生產者-消費者模式,線程池還可以為線程數量提供良好的伸縮性,有關.NET線程池的詳細信息,請參見https://docs.microsoft.com/zh-cn/dotnet/api/system.threading.threadpool?view=netcore-3.1

      需要註意的是,線程池中的線程預設為後臺線程,這意味著如下代碼一般不能按預期工作。

1 static void Main(string[] args)
2 {
3      ThreadPool.QueueUserWorkItem(state =>
4      {
5          Thread.Sleep(100);
6          Console.WriteLine("執行完畢");
7      });
8 }


      並且由於線程會被覆用,所以不能作依賴於某個特定線程的操作。

2. 何時不使用線程池(摘錄微軟文檔)

  1. 需要一個前臺線程。
  2. 需要具有特定優先順序的線程。
  3. 擁有會導致線程長時間阻塞的任務。 線程池具有最大線程數,因此大量被阻塞的線程池線程可能會阻止任務啟動。
  4. 需將線程放入單線程單元。 所有 ThreadPool 線程均位於多線程單元中。
  5. 需具有與線程關聯的穩定標識,或需將一個線程專用於一項任務。

三、更方便的解決方案(使用TPL)

1.處理線程池未解決的問題

      線程池雖然解決了線程資源浪費的問題,但是以下兩點還未解決

  1. 無法直接獲取線程函數返回值
  2. 無法直接捕捉線程函數內發生的異常

      在上一篇中MyTask類可以解決這兩個問題,但由於內部是每個Task直接開一個線程,資源浪費的問題還是沒有解決,所以我們是不是能夠把兩者結合呢?

2.Task初體驗

無返回值無異常

 1 static void Main(string[] args)
 2 {
 3      Task task = new Task(() => 
 4      {
 5          Thread.Sleep(100);
 6          Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
 7      });
 8      task.Start();
 9      try
10      {
11          task.Wait();
12      }
13      catch(Exception e)
14      {
15          Console.WriteLine(e.Message);
16      }
17 }



輸出如下:

image

無返回值有異常

 1 static void Main(string[] args)
 2 {
 3      var task = new Task(() => 
 4      {
 5          Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
 6          var task1 = new Task(() => 
 7          {
 8              Console.WriteLine($"是否是線程池線程:{Thread.CurrentThread.IsThreadPoolThread}");
 9              throw new Exception("延續任務發生異常");
10          },TaskCreationOptions.AttachedToParent);
11          task1.Start();
12          throw new Exception("主任務發生異常");
13      });
14 
15     task.Start();
16      try
17      {
18          task.Wait();
19      }
20      catch(AggregateException ae)//Task內部包裝了異常,有異常發生Wait()內部會拋出一個聚合異常
21      {
22          foreach(var e in ae.Flatten().InnerExceptions)//把階梯式的聚合異常變為扁平的異常
23          {
24              Console.WriteLine(e.Message);
25          }
26      }
27 }


image

      有返回值的就不演示了。可以看到,使用Task解決了開始的三種問題,但事物總是具有兩面性,有優點也有缺點,Task會帶來額外的記憶體分配,Task抽象層次過高,深入理解並使用好並非易事,在與async/await關鍵字配合編寫非同步代碼時更加突出。

      網上關於Task的使用例子很多,微軟文檔也很全,我在此這裡補充一下需要註意的地方。

  • 任務是托管線程上更高層次的抽象
  • 任務的執行由任務調度器(TaskScheduler)決定
  • 預設的任務調度器是線程池調度器,它使用線程池執行任務
  • Task.Run()靜態方法和Task.Start()實例方法以及預設的任務工廠Task.Factory都是使用預設的線程池任務調度器
  • 因此說Task是對線程池的封裝是不准確的
  • 通過指定TaskCreationOptions.LongRunning枚舉便可讓任務在非線程池中的線程上執行,這樣可以避免長期占用線程池中的線程,因為線程池是有大小的,一般線程池用來處理簡單但量多的工作。

上一篇:(一)進程與線程


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 一個微小的投入就會帶來巨大的突變 集群安全模式 為什麼出現集群安全模式呢? ​ Namenode啟動時,首先將鏡像文件載人記憶體,並執行編輯日誌中的各項操作。一旦在內存中成功建立文件系統元數據的映像,則創建一個新的Fsimage文件和一個空的編輯日誌。此時,** Namenode開始監聽Datanod ...
  • 從事這麼多年的.NET,這段時間來,學習另外一門技術Python。 購買相關的書籍,不停地看書。 然後在VS安裝Python,然後可以上機練習,編寫代碼...... ...
  • 場景 ASP.NET中新建Web網站並部署到IIS上(詳細圖文教程): https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/107199747 在上面博客中已經將網站部署到了IIS上。 但是如果網站很大,頁面比較多,甚至每個頁面都有不少 ...
  • 用C#代替Javascript來做Web應用,是有多爽? 今天聊聊 Blazor。 Blazor 是一個 Web UI 框架。這個框架允許開發者使用 C# 來創建可運行於瀏覽器的具有完全交互 UI 的 Web 應用。 可以理解為,這是一個 C# 語言的 Vue / Angular / React,可 ...
  • --先給GridView控制項註冊滑鼠按下事件gv.MouseDown += new System.Windows.Forms.MouseEventHandler(this.gv_MouseDown); --在滑鼠按下事件裡面增加滑鼠右鍵判斷,並增加滑鼠右鍵菜單複製單元格功能。 private voi ...
  • 場景 ASP.NET中新建MVC項目並連接SqlServer資料庫實現增刪改查: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/107024544 在上面實現了新建簡單的MVC項目以及連接資料庫實現簡單的增刪改查後怎樣將網站部署到 ...
  • 場景 在使用IIS部署ASP.NET的Web項目時提示: InvalidOperationException:未能映射路徑“/” 註: 博客: https://blog.csdn.net/badao_liumang_qizhi 關註公眾號 霸道的程式猿 獲取編程相關電子書、教程推送與免費下載。 實現 ...
  • 上次課程我們新建了管理員的模板頁。 本次我們就完善這個模板頁,順便加入樣式和一些基本的組件,配置好整個項目的UI風格。 一、引入 共用的css和js文件 後端庫用nuget, 前端庫用libman. 右鍵wwwroot文件夾,選擇菜單 Add / Client-Side Library 我們使用ad ...
一周排行
    -Advertisement-
    Play Games
  • Dapr Outbox 是1.12中的功能。 本文只介紹Dapr Outbox 執行流程,Dapr Outbox基本用法請閱讀官方文檔 。本文中appID=order-processor,topic=orders 本文前提知識:熟悉Dapr狀態管理、Dapr發佈訂閱和Outbox 模式。 Outbo ...
  • 引言 在前幾章我們深度講解了單元測試和集成測試的基礎知識,這一章我們來講解一下代碼覆蓋率,代碼覆蓋率是單元測試運行的度量值,覆蓋率通常以百分比表示,用於衡量代碼被測試覆蓋的程度,幫助開發人員評估測試用例的質量和代碼的健壯性。常見的覆蓋率包括語句覆蓋率(Line Coverage)、分支覆蓋率(Bra ...
  • 前言 本文介紹瞭如何使用S7.NET庫實現對西門子PLC DB塊數據的讀寫,記錄了使用電腦模擬,模擬PLC,自至完成測試的詳細流程,並重點介紹了在這個過程中的易錯點,供參考。 用到的軟體: 1.Windows環境下鏈路層網路訪問的行業標準工具(WinPcap_4_1_3.exe)下載鏈接:http ...
  • 從依賴倒置原則(Dependency Inversion Principle, DIP)到控制反轉(Inversion of Control, IoC)再到依賴註入(Dependency Injection, DI)的演進過程,我們可以理解為一種逐步抽象和解耦的設計思想。這種思想在C#等面向對象的編 ...
  • 關於Python中的私有屬性和私有方法 Python對於類的成員沒有嚴格的訪問控制限制,這與其他面相對對象語言有區別。關於私有屬性和私有方法,有如下要點: 1、通常我們約定,兩個下劃線開頭的屬性是私有的(private)。其他為公共的(public); 2、類內部可以訪問私有屬性(方法); 3、類外 ...
  • C++ 訪問說明符 訪問說明符是 C++ 中控制類成員(屬性和方法)可訪問性的關鍵字。它們用於封裝類數據並保護其免受意外修改或濫用。 三種訪問說明符: public:允許從類外部的任何地方訪問成員。 private:僅允許在類內部訪問成員。 protected:允許在類內部及其派生類中訪問成員。 示 ...
  • 寫這個隨筆說一下C++的static_cast和dynamic_cast用在子類與父類的指針轉換時的一些事宜。首先,【static_cast,dynamic_cast】【父類指針,子類指針】,兩兩一組,共有4種組合:用 static_cast 父類轉子類、用 static_cast 子類轉父類、使用 ...
  • /******************************************************************************************************** * * * 設計雙向鏈表的介面 * * * * Copyright (c) 2023-2 ...
  • 相信接觸過spring做開發的小伙伴們一定使用過@ComponentScan註解 @ComponentScan("com.wangm.lifecycle") public class AppConfig { } @ComponentScan指定basePackage,將包下的類按照一定規則註冊成Be ...
  • 操作系統 :CentOS 7.6_x64 opensips版本: 2.4.9 python版本:2.7.5 python作為腳本語言,使用起來很方便,查了下opensips的文檔,支持使用python腳本寫邏輯代碼。今天整理下CentOS7環境下opensips2.4.9的python模塊筆記及使用 ...