浅谈ThreadPool 线程池

admin

相关概念：
    线程池可以看做容纳线程的容器；
    一个应用程序最多只能有一个线程池；
    ThreadPool静态类通过QueueUserWorkItem()方法将工作函数排入线程池；
    每排入一个工作函数，就相当于请求创建一个线程；

线程池的作用：
线程池是为突然大量爆发的线程设计的，通过有限的几个固定线程为大量的操作服务，减少了创建和销毁线程所需的时间，从而提高效率。
如果一个线程的时间非常长，就没必要用线程池了(不是不能作长时间操作，而是不宜。)，况且我们还不能控制线程池中线程的开始、挂起、和中止。

什么时候使用ThreadPool？


ThreadPool 示例一 ：

1. 
   
2. ThreadPool_1.cs
   
3. 
   
4. using System;
   
5. using System.Text;
   
6. using System.Threading;
   
7. 
   
8. namespace 多线程
   
9. {
   
10.     public class Example
    
11.     {
    
12.         public static void Main()
    
13.         {
    
14.             // Queue the task.
    
15.             ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc));
    
16. 
    
17.             Console.WriteLine("Main thread does some work, then sleeps.");
    
18.          
    
19.             Thread.Sleep(1000);
    
20. 
    
21.             Console.WriteLine("Main thread exits.");
    
22.         }
    
23. 
    
24.         static void ThreadProc(Object stateInfo)
    
25.         {
    
26.             // No state object was passed to QueueUserWorkItem,
    
27.             // so stateInfo is null.
    
28.             Console.WriteLine("Hello from the thread pool.");
    
29.         }
    
30.     }
    
31. }

复制代码

ThreadPool 示例二 ：

1. 
   
2. ThreadPool_2.cs
   
3. 
   
4. using System;
   
5. using System.Collections.Generic;
   
6. using System.Text;
   
7. using System.Threading;
   
8. 
   
9. namespace CS_Test
   
10. {
    
11.     class ThreadPool_Demo
    
12.     {
    
13.         // 用于保存每个线程的计算结果
    
14.         static int[] result = new int[10];
    
15. 
    
16. 
    
17.         //注意：由于WaitCallback委托的声明带有参数，
    
18.         //      所以将被调用的Fun方法必须带有参数，即：Fun(object obj)。
    
19.         static void Fun(object obj)
    
20.         {
    
21.             int n = (int)obj;
    
22. 
    
23.             //计算阶乘
    
24.             int fac = 1;
    
25.             for (int i = 1; i <= n; i++)
    
26.             {
    
27.                 fac *= i;
    
28.             }
    
29.             //保存结果
    
30.             result[n] = fac;
    
31.         }
    
32. 
    
33.         static void Main(string[] args)
    
34.         {
    
35.             //向线程池中排入9个工作线程
    
36.             for (int i = 1; i <= 9 ; i++)
    
37.             {
    
38.                 //QueueUserWorkItem()方法：将工作任务排入线程池。
    
39.                 ThreadPool.QueueUserWorkItem(new WaitCallback(Fun),i);
    
40.                 // Fun 表示要执行的方法(与WaitCallback委托的声明必须一致)。
    
41.                 // i   为传递给Fun方法的参数(obj将接受)。
    
42.             }
    
43. 
    
44.             //输出计算结果
    
45.             for (int i = 1; i <= 9; i++)
    
46.             {
    
47.                 Console.WriteLine("线程{0}: {0}! = {1}",i,result[i]);
    
48.             }
    
49.         }
    
50. 
    
51.     }
    
52. }

复制代码

ThreadPool的作用：