C# ThreadPool類(線程池)


C# ThreadPool類(線程池)

CLR線程池並不會在CLR初始化時立即建立線程,而是在應用程序要創建線程來運行任務時,線程池才初始化一個線程。

線程池初始化時是沒有線程的,線程池里的線程的初始化與其他線程一樣,
但是在完成任務以后,該線程不會自行銷毀,而是以掛起的狀態返回到線程池。
直到應用程序再次向線程池發出請求時,線程池里掛起的線程就會再度激活執行任務。
這樣既節省了建立線程所造成的性能損耗
可以讓多個任務反復重用同一線程,從而在應用程序生存期內節約大量開銷。
通過CLR線程池所建立的線程總是默認為后台線程,優先級數為ThreadPriority.Normal。//Normal:正常的

 

CLR線程池分為工作者線程(workerThreads)與I/O線程(completionPortThreads)兩種: 

工作者線程(workerThreads)是主要用作管理CLR內部對象的運作,通常用於計算密集的任務I/O(Input/Output)線程主要用於與外部系統交互信息,
如輸入輸出,CPU僅需在任務開始的時候,將任務的參數傳遞給設備,然后啟動硬件設備即可。
等任務完成的時候,CPU收到一個通知,一般來說是一個硬件的中斷信號,此時CPU繼續后繼的處理工作。
在處理過程中,CPU是不必完全參與處理過程的,如果正在運行的線程不交出CPU的控制權, 那么線程也只能處於等待狀態,即使操作系統將當前的CPU調度給其他線程,此時線程所占用的空間還是被占用, 而並沒有CPU處理這個線程,可能出現線程資源浪費的問題

  

如果這是一個網絡服務程序,每一個網絡連接都使用一個線程管理,可能出現大量線程都在等待網絡通信,
隨着網絡連接的不斷增加,處於等待狀態的線程將會很消耗盡所有的內存資源。可以考慮使用線程池解決這個問題。  

線程池的最大值一般默認為1000、2000。當大於此數目的請求時,將保持排隊狀態,直到線程池里有線程可用。

 使用CLR線程池的工作者線程一般有兩種方式:

通過ThreadPool.QueueUserWorkItem()方法;
通過委托;

要注意,不論是通過ThreadPool.QueueUserWorkItem()還是委托,調用的都是線程池里的線程。

通過以下兩個方法可以讀取和設置CLR線程池中工作者線程與I/O線程的最大線程數。
ThreadPool.GetMax(out in workerThreads,out int completionPortThreads);
ThreadPool.SetMax(int workerThreads,int completionPortThreads);

 

查看線程池中有多少線程正在投入使用:
可以通過ThreadPool.GetAvailableThreads(out in workThreads,out int conoletionPortThreads)方法。

方法    說明
GetAvailableThreads    剩余空閑線程數
GetMaxThreads          最多可用線程數,所有大於此數目的請求將保持排隊狀態,直到線程池線程變為可用
GetMinThreads          檢索線程池在新請求預測中維護的空閑線程數
QueueUserWorkItem      啟動線程池里得一個線程(隊列的方式,如線程池暫時沒空閑線程,則進入隊列排隊)
SetMaxThreads          設置線程池中的最大線程數
SetMinThreads          設置線程池最少需要保留的線程數

 使用線程池有如下優點 

1、縮短應用程序的響應時間。因為在線程池中有線程的線程處於等待分配任務狀態(只要沒有超過線程池的最大上限),無需創建線程。
2、不必管理和維護生存周期短暫的線程,不用在創建時為其分配資源,在其執行完任務之后釋放資源。
3、線程池會根據當前系統特點對池內的線程進行優化處理。

總之使用線程池的作用就是減少創建和銷毀線程的系統開銷。在.NET中有一個線程的類ThreadPool,它提供了線程池的管理。

 ThreadPool是一個靜態類,它沒有構造函數,對外提供的函數也全部是靜態的 

//將方法排入隊列以便執行。此方法在有線程池線程變得可用時執行。
public static bool QueueUserWorkItem(WaitCallback callBack)

//將方法排入隊列以便執行,並指定包含該方法所用數據的對象。此方法在有線程池線程變得可用時執行。
public static bool QueueUserWorkItem(WaitCallback callBack,Object state)

QueueUserWorkItem方法中使用的的WaitCallback參數表示一個delegate,它的聲明如下:
public delegate void WaitCallback(Object state)

如果需要傳遞任務信息可以利用WaitCallback中的state參數,類似於ParameterizedThreadStart委托。

 


免責聲明!

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



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