C#线程池（ThreadPool）

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Node.js›Node.js教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

先引入一下线程池的概念：

百度百科：线程池是一种多线程处理形式，处理过程中将任务添加到队列，然后在创建线程后自动启动这些任务。线程池线程都是后台线程。每个线程都使用默认的堆栈大小，以默认的优先级运行，并处于多线程单元中。如果某个线程在托管代码中空闲（如正在等待某个事件）,则线程池将插入另一个辅助线程来使所有处理器保持繁忙。如果所有线程池线程都始终保持繁忙，但队列中包含挂起的工作，则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队，但他们要等到其他线程完成后才启动。

线程池主要方法:

 1 　　　　  // 参数:
 2         // workerThreads:
 3         // 要由线程池根据需要创建的新的最小工作程序线程数。
 4         // completionPortThreads:
 5         // 要由线程池根据需要创建的新的最小空闲异步 I/O 线程数。        // 返回结果:如果更改成功，则为 true；否则为 false。
 6         [SecuritySafeCritical]
 7         public static bool SetMinThreads(int workerThreads, int completionPortThreads);
 8         // 参数:
 9         // workerThreads:
10         // 线程池中辅助线程的最大数目。
11          // completionPortThreads:
12         // 线程池中异步 I/O 线程的最大数目。
13         // 返回结果:如果更改成功，则为 true；否则为 false。
14         [SecuritySafeCritical]
15         public static bool SetMaxThreads(int workerThreads, int completionPortThreads);

先来看一个简单的例子：

 1 public class Program
 2     {
 3         const int cycleNum = 10;
 4         static void Main(string[] args) 
 5         {
 6             ThreadPool.SetMinThreads(1,1);
 7             ThreadPool.SetMaxThreads(5, 5);
 8             for(int i = 1; i <= cycleNum; i++)
 9             {
10                 ThreadPool.QueueUserWorkItem(new WaitCallback(testFun),i.ToString());
11             }
12             Console.WriteLine("主线程执行！");
13             Console.WriteLine("主线程结束！");
14             Console.ReadKey();
15         }
16         public static void testFun(object obj)
17         {
18             Console.WriteLine(string.Format("{0}:第{1}个线程",DateTime.Now.ToString(),obj.ToString()));
19             Thread.Sleep(5000);
20         }
21     }

附上结果：

这里可以看出，线程池里线程的执行不影响主线程的运行，线程池虽然可以管理多线程的执行，但是却无法知道它什么时候终止。这时候我们可以利用之前讲的信号灯AutoResetEvent和ManualResetEvent来解决问题，对此还不了解的朋友可以参见多线程之AutoResetEvent。

上面代码稍加改动，如下：

 1 public class Program
 2     {
 3         const int cycleNum = 10;        static int cnt = 10;
 4         static AutoResetEvent myEvent = new AutoResetEvent(false);
 5         static void Main(string[] args) 
 6         {
 7             ThreadPool.SetMinThreads(1,1);
 8             ThreadPool.SetMaxThreads(5, 5);
 9             for(int i = 1; i <= cycleNum; i++)
10             {
11                 ThreadPool.QueueUserWorkItem(new WaitCallback(testFun),i.ToString());
12             }
13             Console.WriteLine("主线程执行！");
14             Console.WriteLine("主线程结束！");
15             myEvent.WaitOne();
16             Console.WriteLine("线程池终止！");
17             Console.ReadKey();
18         }
19         public static void testFun(object obj)
20         {            cnt -= 1;
21             Console.WriteLine(string.Format("{0}:第{1}个线程",DateTime.Now.ToString(),obj.ToString()));
22             Thread.Sleep(5000);
23             if (cnt == 0)
24             {
25                 myEvent.Set();
26             }
27         }
28     }