日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
C#ThreadPool類簡介

C#語言有很多值得學(xué)習(xí)的地方，這里我們主要介紹C# ThreadPool類，包括介紹ThreadPool.QueueUserWorkItem()方法等方面。

讓客戶滿意是我們工作的目標(biāo)，不斷超越客戶的期望值來自于我們對(duì)這個(gè)行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶，將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價(jià)值的長期合作伙伴，公司提供的服務(wù)項(xiàng)目有：域名注冊(cè)、網(wǎng)站空間、營銷軟件、網(wǎng)站建設(shè)、晉州網(wǎng)站維護(hù)、網(wǎng)站推廣。

在多線程的程序中，經(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()方法，該方法的原型如下：

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

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類的用法示例：

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

新聞名稱：C#ThreadPool類簡介
文章轉(zhuǎn)載：http://www.5511xx.com/article/dhsscio.html