C#限制并发线程数例程

ㄣ负二代

按自己的想法实现的C#版本的限制并发线程数的例程，给有需要的读者

1. using System;
   
2. using System.Collections.Generic;
   
3. using System.Text;
   
4. using System.Threading;
   
5. 
   
6. namespace WZDM.Test
   
7. {
   
8. /// <summary>
   
9. /// 限制并发线程数例程
   
10. /// </summary>
    
11. public class TestThread
    
12. {
    
13. int _currentThreads = 0;
    
14. int _maxThreads = 10;
    
15. 
    
16. public void Test()
    
17. {
    
18. while (true)
    
19. {
    
20. //_maxThreads = new Random().Next(1, 10);
    
21. for (int i=0; i<100; i++)
    
22. {
    
23. // 在此进行数量限制
    
24. if (_currentThreads >= _maxThreads)
    
25. break;
    
26. 
    
27. // 开启线程
    
28. lock (typeof(TestThread))
    
29. {
    
30. _currentThreads++;
    
31. if (_currentThreads > _maxThreads)
    
32. _currentThreads = _maxThreads;
    
33. 
    
34. string currentInfo = string.Format("thread {0}/{1}", _currentThreads, _maxThreads);
    
35. Console.WriteLine(currentInfo + " start");
    
36. Thread thread = new Thread(new ParameterizedThreadStart(Run));
    
37. thread.Start(currentInfo);
    
38. }
    
39. }
    
40. 
    
41. System.Threading.Thread.Sleep(2000);
    
42. }
    
43. }
    
44. 
    
45. // 线程任务
    
46. void Run(object obj)
    
47. {
    
48. for (int i = 0; i < 100; i++)
    
49. {
    
50. Console.WriteLine("{0}:{1}", obj, i);
    
51. Thread.Sleep(100);
    
52. }
    
53. Console.WriteLine("{0} finished", obj);
    
54. 
    
55. lock (typeof(TestThread))
    
56. {
    
57. _currentThreads--;
    
58. if (_currentThreads < 0)
    
59. _currentThreads = 0;
    
60. }
    
61. }
    
62. }
    
63. }
    

复制代码

fml224

楼主刷屏了哦，不过还差一主题

qiongye

跟着内存学?你能说的详细点么

qiongye

楼主,我不怎么想看教学视频,你有什么C#的学习资料么?