C#多线程处理多个队列数据的方法

这篇文章主要介绍了C#多线程处理多个队列数据的方法,涉及C#线程与队列的相关操作技巧,需要的朋友可以参考下

本文实例讲述了C#多线程处理多个队列数据的方法。分享给大家供大家参考。具体实现方法如下：

1. using System; 
2. using System.Collections.Generic; 
3. using System.Linq; 
4. using System.Text; 
5. using System.Threading; 
6. using System.Collections; 
7. using System.Windows.Forms; 
8. namespace ThredProcessQueue 
9. { 
10. //用于顯示狀態的代理方法類型定義  
11. public delegate void DelegateShowStateInfo(string state); 
12. /// <summary>  
13. /// 測試器  
14. /// </summary>  
15. public class QueueTester 
16. { 
17. private static bool _Exit = false; //標記是否已中斷測試程序  
18. private static Form _OwnerForm; //測試的窗體  
19. private static DelegateShowStateInfo _StateMethod; 
20. private static IList _Queue1 = new ArrayList(); //Queue1的數據  
21. private static IList _Queue2 = new ArrayList(); //Queue2的數據  
22. private static IList _Queue3 = new ArrayList(); //Queue3的數據  
23.  
24. public static void StopThread() 
25. { 
26. _Exit = true; 
27. _OwnerForm = null; 
28. } 
29. public static void Testing(Form sender, DelegateShowStateInfo method) 
30. { 
31. _StateMethod = method; 
32. _OwnerForm = sender; 
33. _Exit = false; 
34. ThreadPool.QueueUserWorkItem(MainTestThread); 
35. ThreadPool.QueueUserWorkItem(Queue1Thread); //啟動Queue1線程  
36. ThreadPool.QueueUserWorkItem(Queue2Thread); //啟動Queue2線程  
37. } 
38. //測試用的主線程，循環向隊列1中壓入數據。  
39. public static void MainTestThread(object state) 
40. { 
41. Random R = new Random(1); 
42. double V = 0; 
43. while (_Exit == false) 
44. { 
45. //在while（true）里一直对数据进行读取，然后放到queue1中，  
46. //与此同时如果queue1中有数据，则线程1就开启  
47. //臨時數據,隨機數  
48. V = R.NextDouble(); 
49. _Queue1.Add(V); //把數據插入到隊列1  
50. Application.DoEvents(); 
51. ShowState(); 
52. Thread.Sleep(100);//生成隨機數太快,為了看清效果,暫停n毫秒  
53. } 
54. } 
55.  
56. //对queue1中的数据进行处理，处理后放到queue2中  
57. public static void Queue1Thread(object state) 
58. { 
59. while (_Exit == false) 
60. { 
61. while (_Queue1.Count > 0) 
62. { 
63. //对queue1中的数据进行处理，处理后放到queue2中  
64. _Queue2.Add(_Queue1[0]); 
65. _Queue1.RemoveAt(0); 
66. Application.DoEvents(); 
67. ShowState(); 
68. } 
69. } 
70. } 
71. //对queue2中的数据进行处理，处理后放到queue3中  
72. public static void Queue2Thread(object state) 
73. { 
74. while (_Exit == false) 
75. { 
76. while (_Queue2.Count > 0) 
77. { 
78. //对queue1中的数据进行处理，处理后放到queue2中  
79. _Queue3.Add(_Queue2[0]); 
80. _Queue2.RemoveAt(0); 
81. Application.DoEvents(); 
82. ShowState(); 
83. } 
84. } 
85. } 
86. //用于監視各隊列狀態的線程  
87. public static void ShowState() 
88. { 
89. string stateInfo = 
90. QueueTester._Queue1.Count.ToString() " -> " 
91. QueueTester._Queue2.Count.ToString() " -> " 
92. QueueTester._Queue3.Count.ToString(); 
93. try 
94. { 
95. if (_OwnerForm != null) 
96. { 
97. _OwnerForm.Invoke(_StateMethod, stateInfo); 
98. Application.DoEvents(); 
99. } 
100. } 
101. catch 
102. { 
103. } 
104. } 
105. } 
106. } 

希望本文所述对大家的C#程序设计有所帮助。