C# ThreadPool

蔚落 2022-06-14 11:14 147阅读 0赞

首先，看看线程池的样子：

![10cd5c17de64be13c93d6da5.jpg][]

从上图看出，线程池维护1个至n个线程，操作系统从请求队列中提取请求分配个线程池中的适合线程处理。  
  
先写下如下的代码：

![None.gif][] using  System;  
![None.gif][] using  System.Threading;  
![None.gif][]  
![None.gif][] public  class  ThreadBase  
![ExpandedBlockStart.gif][]![ContractedBlock.gif][] ![dot.gif][] \{  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]     public  static  void  Main ( )  ![dot.gif][] \{  
![InBlock.gif][]  
![InBlock.gif][]         System.Threading.WaitCallback waitCallback =new WaitCallback ( MyThreadWork );  
![InBlock.gif][]  
![InBlock.gif][]         ThreadPool.QueueUserWorkItem ( waitCallback, "第一个线程" );  
![InBlock.gif][]         ThreadPool.QueueUserWorkItem ( waitCallback, "第二个线程" );  
![InBlock.gif][]         ThreadPool.QueueUserWorkItem ( waitCallback, "第三个线程" );  
![InBlock.gif][]         ThreadPool.QueueUserWorkItem ( waitCallback, "第四个线程" );  
![InBlock.gif][]         Console.ReadLine ( );  
![ExpandedSubBlockEnd.gif][]     \}   
![InBlock.gif][]  
![ExpandedSubBlockStart.gif][]![ContractedSubBlock.gif][]     public  static  void  MyThreadWork (  object  state )  ![dot.gif][] \{  
![InBlock.gif][]         Console.WriteLine (  " 线程现在开始启动…… \{0\} " ,( string )state );  
![InBlock.gif][]         Thread.Sleep (  10000  );  
![InBlock.gif][]         Console.WriteLine (  " 运行结束…… \{0\} " ,(  string  ) state );  
![ExpandedSubBlockEnd.gif][]     \}   
![ExpandedBlockEnd.gif][]\}

分析上面的代码：  
一、首先定义了一个 System.Threading.WaitCallback 对象 waitCallback。  
WaitCallback 是一个委托，表示线程池线程要执行的回调方法,它的原型如下：

![None.gif][] \[ComVisibleAttribute( true )\]  
![None.gif][] public  delegate  void  WaitCallback (  
![None.gif][]     Object state  
![None.gif][])  
![None.gif][]

1、这里有一个 Callback 机制的问题，所谓的Callback 简单的理解就是由操作系统调用的函数，我们自己写的程序不需要调用。就像有个修理工到家里搞修理，你只需要告诉他钳子、螺丝刀、胶布等修理工具在什么地方就行，而不要管他在什么时候、在什么地方怎样使用这些修理工具。  
2、WaitCallback 的参数" Object state"，这个参数包含回调方法要使用的信息的对象。在接下来的情况中我再说。  
既然 WaitCallback 委托的原型如此，那么我们就申明一个跟它的样子差不多的函数，这个函数就是要线程做的事情。

![None.gif][] public  static    void  MyThreadWork (  object  state )

这里函数中多了一个 "static"，这是因为Main的关系（更大一点就是因为C\#语言机制的问题），如果WaitCallback 的对象不是在静态(static)方法中，这个static 是不需要的。  
  
二、接着就是要执行的方法放入线程池中，以便操作系统执行。  
我这里放置了四个方法要操作系统执行：

![None.gif][]          ThreadPool.QueueUserWorkItem ( waitCallback,  " 第一个线程 "  );  
![None.gif][]         ThreadPool.QueueUserWorkItem ( waitCallback,  " 第二个线程 "  );  
![None.gif][]         ThreadPool.QueueUserWorkItem ( waitCallback,  " 第三个线程 "  );  
![None.gif][]         ThreadPool.QueueUserWorkItem ( waitCallback,  " 第四个线程 "  );

这里，我放置到线程池中的操作是一样的，当然也可以不一样，接下来说。  
  
三、最后阻塞主线程，等待线程池中的线程执行

![None.gif][]  Console.ReadLine ( );

如果忽略掉这个代码，则有可能看不到任何输出  
  
好了，这是主线程做的事情了，接下来看看线程池中的线程做的事情。  
这个很简单，就是将线程的参数输出，然后线程睡眠(sleep)一段时间，最后输出线程结束的信息。

[10cd5c17de64be13c93d6da5.jpg]: /images/20220614/a46e512eb58d44248dbda6fbcaf45431.png
[None.gif]: /images/20220614/736642152013472c838dd282ffa43945.png
[ExpandedBlockStart.gif]: http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif
[ContractedBlock.gif]: http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif
[dot.gif]: /images/20220614/0595602349bd409f8e0a944f51821845.png
[ExpandedSubBlockStart.gif]: http://www.cnblogs.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif
[ContractedSubBlock.gif]: http://www.cnblogs.com/Images/OutliningIndicators/ContractedSubBlock.gif
[InBlock.gif]: /images/20220614/cda6fbc84ac0420c86b892b6894a1bac.png
[ExpandedSubBlockEnd.gif]: /images/20220614/be2cfe71cd7a49cab218158ef84e97cf.png
[ExpandedBlockEnd.gif]: /images/20220614/1eefab3f5826482ab74ebebafd7590b0.png