今天就跟大家聊聊有關(guān)C# 中ThreadPool類的作用是什么,可能很多人都不太了解,為了讓大家更加了解,小編給大家總結(jié)了以下內(nèi)容,希望大家根據(jù)這篇文章可以有所收獲。
創(chuàng)新互聯(lián)主營(yíng)新疆網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,APP應(yīng)用開發(fā),新疆h5微信小程序開發(fā)搭建,新疆網(wǎng)站營(yíng)銷推廣歡迎新疆等地區(qū)企業(yè)咨詢
在多線程的程序中,經(jīng)常會(huì)出現(xiàn)兩種情況:
一種情況: 應(yīng)用程序中,線程把大部分的時(shí)間花費(fèi)在等待狀態(tài),等待某個(gè)事件發(fā)生,然后才能給予響應(yīng),這一般使用ThreadPool(線程池)來解決;
另一種情況:線程平時(shí)都處于休眠狀態(tài),只是周期性地被喚醒,這一般使用Timer(定時(shí)器)來解決;
C# ThreadPool類提供一個(gè)由系統(tǒng)維護(hù)的線程池(可以看作一個(gè)線程的容器),該容器需要 Windows 2000 以上系統(tǒng)支持,因?yàn)槠渲心承┓椒ㄕ{(diào)用了只有高版本的Windows才有的API函數(shù)。
將線程安放在線程池里,需使用ThreadPool.QueueUserWorkItem()方法,該方法的原型如下:
//將一個(gè)線程放進(jìn)線程池,該線程的Start()方法將調(diào)用WaitCallback代理對(duì)象代表的函數(shù) public static bool QueueUserWorkItem(WaitCallback); //重載的方法如下,參數(shù)object將傳遞給WaitCallback所代表的方法 public static bool QueueUserWorkItem(WaitCallback, object);
C# ThreadPool類是一個(gè)靜態(tài)類,你不能也不必要生成它的對(duì)象。而且一旦使用該方法在線程池中添加了一個(gè)項(xiàng)目,那么該項(xiàng)目將是無法取消的。
在這里你無需自己建立線程,只需把你要做的工作寫成函數(shù),然后作為參數(shù)傳遞給ThreadPool.QueueUserWorkItem()方法就行了,傳遞的方法就是依靠WaitCallback代理對(duì)象,而線程的建立、管理、運(yùn)行等工作都是由系統(tǒng)自動(dòng)完成的,你無須考慮那些復(fù)雜的細(xì)節(jié)問題。
ThreadPool 的用法:首先程序創(chuàng)建了一個(gè)ManualResetEvent對(duì)象,該對(duì)象就像一個(gè)信號(hào)燈,可以利用它的信號(hào)來通知其它線程。
本例中,當(dāng)線程池中所有線程工作都完成以后,ManualResetEvent對(duì)象將被設(shè)置為有信號(hào),從而通知主線程繼續(xù)運(yùn)行。ManualResetEvent對(duì)象有幾個(gè)重要的方法:初始化該對(duì)象時(shí),用戶可以指定其默認(rèn)的狀態(tài)(有信號(hào)/無信號(hào));
在初始化以后,該對(duì)象將保持原來的狀態(tài)不變,直到它的Reset()或者Set()方法被調(diào)用:
◆Reset()方法:將其設(shè)置為無信號(hào)狀態(tài);
◆Set()方法:將其設(shè)置為有信號(hào)狀態(tài)。
WaitOne()方法:使當(dāng)前線程掛起,直到ManualResetEvent對(duì)象處于有信號(hào)狀態(tài),此時(shí)該線程將被激活。然后,程序?qū)⑾蚓€程池中添加工作項(xiàng),這些以函數(shù)形式提供的工作項(xiàng)被系統(tǒng)用來初始化自動(dòng)建立的線程。當(dāng)所有的線程都運(yùn)行完了以后,ManualResetEvent.Set()方法被調(diào)用,因?yàn)檎{(diào)用了ManualResetEvent.WaitOne()方法而處在等待狀態(tài)的主線程將接收到這個(gè)信號(hào),于是它接著往下執(zhí)行,完成后邊的工作。
C# ThreadPool類的用法示例:
using System;
using System.Collections;
using System.Threading;
namespace ThreadExample
{
//這是用來保存信息的數(shù)據(jù)結(jié)構(gòu),將作為參數(shù)被傳遞
public class SomeState
{
public int Cookie;
public SomeState(int iCookie)
{
Cookie = iCookie;
}
}
public class Alpha
{
public Hashtable HashCount;
public ManualResetEvent eventX;
public static int iCount = 0;
public static int iMaxCount = 0;
public Alpha(int MaxCount)
{
HashCount = new Hashtable(MaxCount);
iMaxCount = MaxCount;
}
//線程池里的線程將調(diào)用Beta()方法
public void Beta(Object state)
{
//輸出當(dāng)前線程的hash編碼值和Cookie的值
Console.WriteLine(" {0} {1} :", Thread.CurrentThread.GetHashCode(),
((SomeState)state).Cookie);Console.WriteLine("HashCount.Count=={0}, Thread.CurrentThread.GetHashCode()=={1}",
HashCount.Count, Thread.CurrentThread.GetHashCode());lock (HashCount)
{
//如果當(dāng)前的Hash表中沒有當(dāng)前線程的Hash值,則添加之
if (!HashCount.ContainsKey(Thread.CurrentThread.GetHashCode()))
HashCount.Add (Thread.CurrentThread.GetHashCode(), 0);
HashCount[Thread.CurrentThread.GetHashCode()] =
((int)HashCount[Thread.CurrentThread.GetHashCode()])+1;
}
int iX = 2000;
Thread.Sleep(iX);
//Interlocked.Increment()操作是一個(gè)原子操作,具體請(qǐng)看下面說明
Interlocked.Increment(ref iCount);
if (iCount == iMaxCount)
{
Console.WriteLine();
Console.WriteLine("Setting eventX ");
eventX.Set();
}
}
}
public class SimplePool
{
public static int Main(string[] args)
{
Console.WriteLine("Thread Pool Sample:");
bool W2K = false;
int MaxCount = 10;//允許線程池中運(yùn)行最多10個(gè)線程
//新建ManualResetEvent對(duì)象并且初始化為無信號(hào)狀態(tài)
ManualResetEvent eventX = new ManualResetEvent(false);
Console.WriteLine("Queuing {0} items to Thread Pool", MaxCount);
Alpha oAlpha = new Alpha(MaxCount);
//創(chuàng)建工作項(xiàng)
//注意初始化oAlpha對(duì)象的eventX屬性
oAlpha.eventX = eventX;
Console.WriteLine("Queue to Thread Pool 0");
try
{
//將工作項(xiàng)裝入線程池
//這里要用到Windows 2000以上版本才有的API,所以可能出現(xiàn)NotSupportException異常
ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta), new SomeState(0));
W2K = true;
}
catch (NotSupportedException)
{
Console.WriteLine("These API's may fail when called on a non-Windows 2000 system.");
W2K = false;
}
if (W2K)//如果當(dāng)前系統(tǒng)支持ThreadPool的方法.
{
for (int iItem=1;iItem < MaxCount;iItem++)
{
//插入隊(duì)列元素
Console.WriteLine("Queue to Thread Pool {0}", iItem);
ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta), new SomeState(iItem));
}
Console.WriteLine("Waiting for Thread Pool to drain");
//等待事件的完成,即線程調(diào)用ManualResetEvent.Set()方法
eventX.WaitOne(Timeout.Infinite,true);
//WaitOne()方法使調(diào)用它的線程等待直到eventX.Set()方法被調(diào)用
Console.WriteLine("Thread Pool has been drained (Event fired)");
Console.WriteLine();
Console.WriteLine("Load across threads");
foreach(object o in oAlpha.HashCount.Keys)
Console.WriteLine("{0} {1}", o, oAlpha.HashCount[o]);
}
Console.ReadLine();
return 0;
}
}
}
}
看完上述內(nèi)容,你們對(duì)C# 中ThreadPool類的作用是什么有進(jìn)一步的了解嗎?如果還想了解更多知識(shí)或者相關(guān)內(nèi)容,請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝大家的支持。
文章標(biāo)題:C#中ThreadPool類的作用是什么
分享URL:http://sd-ha.com/article14/gjghge.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站內(nèi)鏈、網(wǎng)站建設(shè)、品牌網(wǎng)站設(shè)計(jì)、網(wǎng)頁(yè)設(shè)計(jì)公司、企業(yè)建站、網(wǎng)站導(dǎo)航
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)