抓虫系列(四) 不要轻视web程序中常用的三个"池" 之线程池

前篇回顾：上篇讲了数据库连接池的问题，其实关于是否是活动连接还是有很大问题可以挖掘的。这个有空虫子再和大家交流了

本篇谈下线程池的相关问题，希望各位看官留个爪印，应用程序池和数据库连接池可能大部分程序员不需要关心那个，不过线程池可所谓是重头戏了。

先把虫子的观点放上： 个人表示排斥在项目中使用ThreadPool这个类，至于.net中关联到ThreadPool的资源我们暂且不做讨论。如果需要操作线程池可以使用第三方例如SmartThreadPool或者自己按照自己的项目需求开发一个。

线程池的相关概念我就不多说了，同样这里我只介绍下。线程池中容易被忽视的问题。

一. 相对池外线程，池内线程操作的性能极差！

<a href="http://blog.51cto.com/dubing/712451#">?</a>

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

<code>ManualResetEvent[] MR = </code><code>new</code> <code>ManualResetEvent[10];</code>

<code>           </code><code>for</code> <code>(</code><code>int</code> <code>i = 0; i &lt; 10; i++)</code>

<code>           </code><code>{</code>

<code>               </code><code>MR[i] = </code><code>new</code> <code>ManualResetEvent(</code><code>false</code><code>);</code>

<code>           </code><code>}</code>

<code>           </code><code>int</code> <code>a, b;</code>

<code>           </code><code>ThreadPool.GetMaxThreads(</code><code>out</code> <code>a, </code><code>out</code> <code>b);</code>

<code>           </code><code>Console.WriteLine(</code><code>string</code><code>.Format(</code><code>"(辅助线程的最大数目{0}  I/O线程的最大数目{1})    初始状态"</code><code>, a, b));</code>

<code>           </code><code>ThreadPool.GetAvailableThreads(</code><code>out</code> <code>a, </code><code>out</code> <code>b);</code>

<code>           </code><code>Console.WriteLine(</code><code>string</code><code>.Format(</code><code>"(可用辅助线程的最大数目{0}  可用I/O线程的最大数目{1})    初始状态"</code><code>, a, b));</code>

<code>       </code> 

<code>           </code><code>Stopwatch sw = Stopwatch.StartNew();</code>

<code>             </code> 

<code>               </code><code>new</code> <code>Thread((qq) =&gt;</code>

<code>               </code><code>{</code>

<code>                   </code><code>Console.WriteLine(</code><code>"这是个线程池外的线程"</code><code>+qq.ToString());</code>

<code>                   </code><code>MR[(</code><code>int</code><code>)qq].Set();</code>

<code>                   </code><code>Thread.Sleep(5000);</code>

<code>               </code><code>}) { }.Start(i);</code>

<code>           </code><code>WaitHandle.WaitAll(MR);</code>

<code>           </code><code>Console.WriteLine(</code><code>"生成池外10个线程 共耗时"</code> <code>+ sw.ElapsedMilliseconds);</code>

<code>           </code><code>foreach</code> <code>(ManualResetEvent me </code><code>in</code> <code>MR)</code>

<code>               </code><code>me.Reset();</code>

<code>           </code><code>Thread.Sleep(500);</code>

<code>           </code><code>Console.WriteLine(</code><code>string</code><code>.Format(</code><code>"(可用辅助线程的最大数目{0}  可用I/O线程的最大数目{1})    线程池外启动线程后"</code><code>, a, b));</code>

<code>           </code><code>sw = Stopwatch.StartNew();</code>

<code>           </code><code>ThreadPool.QueueUserWorkItem(qq =&gt;</code>

<code>               </code><code>{                 </code>

<code>                   </code><code>Console.WriteLine(</code><code>"这是个线程池内的线程"</code> <code>+ qq.ToString());</code>

<code>                   </code><code>Thread.Sleep(20000);</code>

<code>                   </code> 

<code>               </code><code>},i);</code>

<code>           </code><code>Console.WriteLine(</code><code>"生成池内10个线程 共耗时"</code> <code>+ sw.ElapsedMilliseconds);</code>

<code>           </code><code>Thread.Sleep(6000);</code>

<code>           </code><code>Console.WriteLine(</code><code>string</code><code>.Format(</code><code>"(可用辅助线程的最大数目{0}  可用I/O线程的最大数目{1})    线程池内启动线程后"</code><code>, a, b));</code>

在初始状态后 生成线程的效率存在百倍的差距！！！不过线程池既然是池的作用那么在程序运行中应该会好很多。

二。线程池内的线程只能是后台线程。

三。不能为线程设置优先级。在高精度的项目中线程池不适用。

四。所支持的Callback不能有返回值。WaitCallback只能带一个object类型的参数，没有任何返回值。

五。容易被干扰，同时容易破坏项目的应用环境。举些例子

<code>static</code> <code>void</code> <code>Main(</code><code>string</code><code>[] args)</code>

<code>        </code><code>{                   </code>

<code>            </code><code>//哪些函数会影响线程池</code>

<code>            </code><code>int</code> <code>a, b;</code>

<code>            </code><code>Timer timer = </code><code>new</code> <code>Timer((qq) =&gt;</code>

<code>            </code><code>{           </code>

<code>                </code><code>Console.WriteLine(</code><code>"这是一个timer"</code><code>);</code>

<code>                </code><code>Thread.Sleep(2000);</code>

<code>            </code><code>}, </code><code>null</code><code>, 2000, 1000);</code>

<code>           </code> 

<code>            </code><code>ThreadPool.GetAvailableThreads(</code><code>out</code> <code>a, </code><code>out</code> <code>b);</code>

<code>            </code><code>Console.WriteLine(</code><code>string</code><code>.Format(</code><code>"(可用辅助线程的最大数目{0}  可用I/O线程的最大数目{1})    Timer启动后"</code><code>, a, b));</code>

<code>            </code><code>timer.Dispose();</code>

<code>            </code><code>timer = </code><code>new</code> <code>Timer((qq) =&gt;</code>

<code>            </code><code>{         </code>

<code>                </code><code>ThreadPool.GetAvailableThreads(</code><code>out</code> <code>a, </code><code>out</code> <code>b);</code>

<code>                </code><code>Console.WriteLine(</code><code>string</code><code>.Format(</code><code>"(可用辅助线程的最大数目{0}/可用I/O线程的最大数目{1}) Timer资源占用ing"</code><code>, a, b));</code>

<code>            </code><code>var</code> <code>act = </code><code>new</code> <code>Action(testmethod);</code>

<code>            </code><code>var</code> <code>qqt = act.BeginInvoke(CallbackMethod, act);</code>

<code>            </code><code>Console.ReadLine();</code>

<code>        </code><code>}</code>

<code>        </code><code>static</code> <code>void</code> <code>CallbackMethod(IAsyncResult ar)</code>

<code>        </code><code>{</code>

<code>            </code><code>var</code> <code>caller = (Action)ar.AsyncState;</code>

<code>            </code><code>caller.EndInvoke(ar);</code>

<code>            </code><code>Console.WriteLine(</code><code>"Action回调结束"</code><code>);</code>

<code> </code> 

<code>        </code><code>static</code> <code>void</code> <code>testmethod()</code>

<code>            </code><code>Console.WriteLine(</code><code>"Action开始"</code><code>);</code>

<code>            </code><code>Console.WriteLine(</code><code>string</code><code>.Format(</code><code>"(可用辅助线程的最大数目{0}  可用I/O线程的最大数目{1})    Action启动ing"</code><code>, a, b));</code>

<code>            </code><code>Thread.Sleep(2000);</code>

<code>        </code> 

至于还有哪些，大家可以各自讨论，或者提出反对的意见。

本文转自 熬夜的虫子  51CTO博客，原文链接:http://blog.51cto.com/dubing/712451