C#中ThreadPool類的作用是什么

今天就跟大家聊聊有關(guān)C# 中ThreadPool類的作用是什么，可能很多人都不太了解，為了讓大家更加了解，小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

創(chuàng)新互聯(lián)主營新疆網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,APP應(yīng)用開發(fā),新疆h5微信小程序開發(fā)搭建,新疆網(wǎng)站營銷推廣歡迎新疆等地區(qū)企業(yè)咨詢

在多線程的程序中，經(jīng)常會出現(xiàn)兩種情況：

一種情況： 應(yīng)用程序中，線程把大部分的時間花費在等待狀態(tài)，等待某個事件發(fā)生，然后才能給予響應(yīng)，這一般使用ThreadPool（線程池）來解決；

另一種情況：線程平時都處于休眠狀態(tài)，只是周期性地被喚醒，這一般使用Timer（定時器）來解決；

C# ThreadPool類提供一個由系統(tǒng)維護的線程池（可以看作一個線程的容器），該容器需要 Windows 2000 以上系統(tǒng)支持，因為其中某些方法調(diào)用了只有高版本的Windows才有的API函數(shù)。

將線程安放在線程池里，需使用ThreadPool.QueueUserWorkItem()方法，該方法的原型如下：

//將一個線程放進線程池，該線程的Start()方法將調(diào)用WaitCallback代理對象代表的函數(shù)  public static bool QueueUserWorkItem(WaitCallback);  //重載的方法如下，參數(shù)object將傳遞給WaitCallback所代表的方法  public static bool QueueUserWorkItem(WaitCallback, object);

C# ThreadPool類是一個靜態(tài)類，你不能也不必要生成它的對象。而且一旦使用該方法在線程池中添加了一個項目，那么該項目將是無法取消的。

在這里你無需自己建立線程，只需把你要做的工作寫成函數(shù)，然后作為參數(shù)傳遞給ThreadPool.QueueUserWorkItem()方法就行了，傳遞的方法就是依靠WaitCallback代理對象，而線程的建立、管理、運行等工作都是由系統(tǒng)自動完成的，你無須考慮那些復(fù)雜的細(xì)節(jié)問題。
ThreadPool 的用法：首先程序創(chuàng)建了一個ManualResetEvent對象，該對象就像一個信號燈，可以利用它的信號來通知其它線程。

本例中，當(dāng)線程池中所有線程工作都完成以后，ManualResetEvent對象將被設(shè)置為有信號，從而通知主線程繼續(xù)運行。ManualResetEvent對象有幾個重要的方法：初始化該對象時，用戶可以指定其默認(rèn)的狀態(tài)（有信號/無信號）；

在初始化以后，該對象將保持原來的狀態(tài)不變，直到它的Reset()或者Set()方法被調(diào)用：
◆Reset()方法：將其設(shè)置為無信號狀態(tài)；
◆Set()方法：將其設(shè)置為有信號狀態(tài)。

WaitOne()方法：使當(dāng)前線程掛起，直到ManualResetEvent對象處于有信號狀態(tài)，此時該線程將被激活。然后，程序?qū)⑾蚓€程池中添加工作項，這些以函數(shù)形式提供的工作項被系統(tǒng)用來初始化自動建立的線程。當(dāng)所有的線程都運行完了以后，ManualResetEvent.Set()方法被調(diào)用，因為調(diào)用了ManualResetEvent.WaitOne()方法而處在等待狀態(tài)的主線程將接收到這個信號，于是它接著往下執(zhí)行，完成后邊的工作。

C# ThreadPool類的用法示例：

  1. using System;  
  2. using System.Collections;  
  3. using System.Threading;  
  4.  
  5. namespace ThreadExample  
  6. {  
  7. //這是用來保存信息的數(shù)據(jù)結(jié)構(gòu)，將作為參數(shù)被傳遞  
  8. public class SomeState  
  9. {  
  10. public int Cookie;  
  11. public SomeState(int iCookie)  
  12. {  
  13. Cookie = iCookie;  
  14. }  
  15. }  
  16.  
  17. public class Alpha  
  18. {  
  19. public Hashtable HashCount;  
  20. public ManualResetEvent eventX;  
  21. public static int iCount = 0;  
  22. public static int iMaxCount = 0;  
  23.  
  24. public Alpha(int MaxCount)   
  25. {  
  26. HashCount = new Hashtable(MaxCount);  
  27. iMaxCount = MaxCount;  
  28. }  
  29.  
  30. //線程池里的線程將調(diào)用Beta()方法  
  31. public void Beta(Object state)  
  32. {  
  33. //輸出當(dāng)前線程的hash編碼值和Cookie的值  
  34. Console.WriteLine(" {0} {1} :", Thread.CurrentThread.GetHashCode(),
    ((SomeState)state).Cookie);  
  35. Console.WriteLine("HashCount.Count=={0}, Thread.CurrentThread.GetHashCode()=={1}", 
    HashCount.Count, Thread.CurrentThread.GetHashCode());  
  36. lock (HashCount)   
  37. {  
  38. //如果當(dāng)前的Hash表中沒有當(dāng)前線程的Hash值，則添加之  
  39. if (!HashCount.ContainsKey(Thread.CurrentThread.GetHashCode()))  
  40. HashCount.Add (Thread.CurrentThread.GetHashCode(), 0);  
  41. HashCount[Thread.CurrentThread.GetHashCode()] =   
  42. ((int)HashCount[Thread.CurrentThread.GetHashCode()])+1;  
  43. }  
  44. int iX = 2000;  
  45. Thread.Sleep(iX);  
  46. //Interlocked.Increment()操作是一個原子操作，具體請看下面說明  
  47. Interlocked.Increment(ref iCount);  
  48.  
  49. if (iCount == iMaxCount)  
  50. {  
  51. Console.WriteLine();  
  52. Console.WriteLine("Setting eventX ");  
  53. eventX.Set();  
  54.  }  
  55. }  
  56. }  
  57.  
  58. public class SimplePool  
  59. {  
  60. public static int Main(string[] args)  
  61. {  
  62. Console.WriteLine("Thread Pool Sample:");  
  63. bool W2K = false;  
  64. int MaxCount = 10;//允許線程池中運行最多10個線程  
  65. //新建ManualResetEvent對象并且初始化為無信號狀態(tài)  
  66. ManualResetEvent eventX = new ManualResetEvent(false);  
  67. Console.WriteLine("Queuing {0} items to Thread Pool", MaxCount);  
  68. Alpha oAlpha = new Alpha(MaxCount);   
  69. //創(chuàng)建工作項  
  70. //注意初始化oAlpha對象的eventX屬性  
  71. oAlpha.eventX = eventX;  
  72. Console.WriteLine("Queue to Thread Pool 0");  
  73. try  
  74. {  
  75. //將工作項裝入線程池   
  76. //這里要用到Windows 2000以上版本才有的API，所以可能出現(xiàn)NotSupportException異常  
  77. ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta), new SomeState(0));  
  78. W2K = true;  
  79. }  
  80. catch (NotSupportedException)  
  81. {  
  82. Console.WriteLine("These API's may fail when called on a non-Windows 2000 system.");  
  83. W2K = false;  
  84. }  
  85. if (W2K)//如果當(dāng)前系統(tǒng)支持ThreadPool的方法.  
  86. {  
  87. for (int iItem=1;iItem < MaxCount;iItem++)  
  88. {  
  89. //插入隊列元素  
  90. Console.WriteLine("Queue to Thread Pool {0}", iItem);  
  91. ThreadPool.QueueUserWorkItem(new WaitCallback(oAlpha.Beta), new SomeState(iItem));  
  92. }  
  93. Console.WriteLine("Waiting for Thread Pool to drain");  
  94. //等待事件的完成，即線程調(diào)用ManualResetEvent.Set()方法  
  95. eventX.WaitOne(Timeout.Infinite,true);  
  96. //WaitOne()方法使調(diào)用它的線程等待直到eventX.Set()方法被調(diào)用  
  97. Console.WriteLine("Thread Pool has been drained (Event fired)");  
  98. Console.WriteLine();  
  99. Console.WriteLine("Load across threads");  
  100. foreach(object o in oAlpha.HashCount.Keys)  
  101. Console.WriteLine("{0} {1}", o, oAlpha.HashCount[o]);  
  102. }  
  103. Console.ReadLine();  
  104. return 0;  
  105. }  
  106. }  
  107. }  
  108. } 

看完上述內(nèi)容，你們對C# 中ThreadPool類的作用是什么有進一步的了解嗎？如果還想了解更多知識或者相關(guān)內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝大家的支持。

文章標(biāo)題：C#中ThreadPool類的作用是什么
分享URL：http://www.muchs.cn/article14/gjghge.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站內(nèi)鏈、網(wǎng)站建設(shè)、品牌網(wǎng)站設(shè)計、網(wǎng)頁設(shè)計公司、企業(yè)建站、網(wǎng)站導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

成都seo排名網(wǎng)站優(yōu)化