C#多線程之線程池ThreadPool詳解

第C#多線程之線程池ThreadPool詳解一、ThreadPool概述

提供一個線程池，該線程池可用于執(zhí)行任務(wù)、發(fā)送工作項、處理異步I/O、代表其他線程等待以及處理計時器。

創(chuàng)建線程需要時間。如果有不同的小任務(wù)要完成，就可以事先創(chuàng)建許多線程/在應(yīng)完成這些任務(wù)時發(fā)出請求。不需要自己創(chuàng)建這樣一個列表。該列表由ThreadPool類托管。

這個類會在需要時增減池中線程的線程數(shù)，直到最大的線程數(shù)。池中的最大線程數(shù)是可配置的。在雙核CPU中，默認(rèn)設(shè)置為1023個工作線程和1000個I/O線程。也可以指定在創(chuàng)建線程池時應(yīng)立即啟動的最小線程數(shù)，以及線程池中可用的最大線程數(shù)。

如果有更多的作業(yè)要處理，線程池中線程的個數(shù)也達到了極限，最新的作業(yè)就要排隊，且必須等待線程完成其任務(wù)。

線程池使用起來很簡單，但它有一些限制：

線程池中的所有線程都是后臺線程。如果進程的所有前臺線程都結(jié)束了，所有的后臺線程就會停止。不能把入池的線程改為前臺線程。不能給入池的線程設(shè)置優(yōu)先級或名稱。對于COM對象，入池的所有線程都是多線程單元(multithreadedapartment,MTA)線程。許多COM對象都需要單線程單元(single-threadedapartment,MTA)線程。入池的線程只能用于時間較短的任務(wù)。如果線程要一直運行(如Word的拼寫檢杳器線程)，就應(yīng)使用Thread類創(chuàng)建一個線程.

使用線程池線程的操作的情況包括：

當(dāng)您創(chuàng)建Task或TaskTResult對象以異步方式執(zhí)行某項任務(wù)，默認(rèn)情況下任務(wù)調(diào)度在線程池線程上運行的。異步計時器使用線程池。線程池線程從System.Threading.Timer類執(zhí)行回調(diào)，和從System.Timers.Timer類引發(fā)事件。當(dāng)使用已注冊的等待句柄時，系統(tǒng)線程監(jiān)視等待句柄的狀態(tài)。等待操作完成后，從線程池的工作線程將執(zhí)行相應(yīng)的回調(diào)函數(shù)。當(dāng)您調(diào)用QueueUserWorkItem方法進行排隊，以在線程池線程上執(zhí)行的方法。為此，可將該方法傳遞WaitCallback委托。

GetAvailableThreads(Int32,Int32)

檢索由GetMaxThreads(Int32,Int32)方法返回的最大線程池線程數(shù)和當(dāng)前活動線程數(shù)之間的差值。GetMaxThreads(Int32,Int32)

檢索可以同時處于活動狀態(tài)的線程池請求的數(shù)目。所有大于此數(shù)目的請求將保持排隊狀態(tài)，直到線程池線程變?yōu)榭捎谩etMaxThreads(Int32,Int32)

設(shè)置可以同時處于活動狀態(tài)的線程池的請求數(shù)目。所有大于此數(shù)目的請求將保持排隊狀態(tài)，直到線程池線程變?yōu)榭捎?。GetMinThreads(Int32,Int32)

發(fā)出新的請求時，在切換到管理線程創(chuàng)建和銷毀的算法之前檢索線程池按需創(chuàng)建的線程的最小數(shù)量。SetMinThreads(Int32,Int32)

發(fā)出新的請求時，在切換到管理線程創(chuàng)建和銷毀的算法之前設(shè)置線程池按需創(chuàng)建的線程的最小數(shù)量。QueueUserWorkItem(WaitCallback,Object)

將方法排入隊列以便執(zhí)行，并指定包含該方法所用數(shù)據(jù)的對象。此方法在有線程池線程變得可用時執(zhí)行。RegisterWaitForSingleObject(WaitHandle,WaitOrTimerCallback,Object,Int32,Boolean)

注冊一個等待WaitHandle的委托，并指定一個32位有符號整數(shù)來表示超時值（以毫秒為單位）。

三、獲取線程數(shù)方法

inti=0;

intj=0;

//前面是輔助(也就是所謂的工作者)線程，后面是I/O線程

ThreadPool.GetMaxThreads(outi,outj);

Console.WriteLine(i.ToString()+""+j.ToString());//默認(rèn)都是1000

//獲取空閑線程，由于現(xiàn)在沒有使用異步線程，所以為空

ThreadPool.GetAvailableThreads(outi,outj);

Console.WriteLine(i.ToString()+""+j.ToString());//默認(rèn)都是1000

四、QueueUserWorkItem(WaitCallback,Object)

將方法排入隊列以便執(zhí)行，并指定包含該方法所用數(shù)據(jù)的對象。此方法在有線程池線程變得可用時執(zhí)行。

publicstaticboolQueueUserWorkItem(System.Threading.WaitCallbackcallBack,objectstate);

實例：

staticvoidMain(string[]args)

Personp=newPerson(1,"劉備");

//啟動工作者線程

ThreadPool.QueueUserWorkItem(newWaitCallback(RunWorkerThread),p);

staticvoidRunWorkerThread(object