首页 > 程序开发 > 软件开发 > 其他 >

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

2011-10-24

前篇回顾:上篇讲了数据库连接池的问题,其实关于是否是活动连接还是有很大问题可以挖掘的。这个有空虫子再和大家交流了本篇谈下线程池的相关问题,希望各位看官留个爪印,应用程序池和数据库连接池可能大部分程...

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

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

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

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

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

01 ManualResetEvent[] MR = new ManualResetEvent[10];

02 for (int i = 0; i < 10; i++)

03 {

04 MR[i] = new ManualResetEvent(false);

05 }

06 int a, b;

07 ThreadPool.GetMaxThreads(out a, out b);

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

09 ThreadPool.GetAvailableThreads(out a, out b);

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

11

12 Stopwatch sw = Stopwatch.StartNew();

13 for (int i = 0; i < 10; i++)

14 {

15

16 new Thread((qq) =>

17 {

18 Console.WriteLine("这是个线程池外的线程"+qq.ToString());

19 MR[(int)qq].Set();

20 Thread.Sleep(5000);

21

22 }) { }.Start(i);

23 }

24 WaitHandle.WaitAll(MR);

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

26

27 foreach (ManualResetEvent me in MR)

28 {

29 me.Reset();

30 }

31 Thread.Sleep(500);

32 ThreadPool.GetAvailableThreads(out a, out b);

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

34

35 sw = Stopwatch.StartNew();

36 for (int i = 0; i < 10; i++)

37 {

38 ThreadPool.QueueUserWorkItem(qq =>

39 {

40 Console.WriteLine("这是个线程池内的线程" + qq.ToString());

41 MR[(int)qq].Set();

42 Thread.Sleep(20000);

43

44 },i);

45 }

46 WaitHandle.WaitAll(MR);

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

48

49 Thread.Sleep(6000);

50 ThreadPool.GetAvailableThreads(out a, out b);

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

\

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

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

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

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

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

01 static void Main(string[] args)

02 {

03 //哪些函数会影响线程池

04 int a, b;

05 Timer timer = new Timer((qq) =>

06 {

07 Console.WriteLine("这是一个timer");

08 Thread.Sleep(2000);

09

10 }, null, 2000, 1000);

11

12 ThreadPool.GetAvailableThreads(out a, out b);

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

14 timer.Dispose();

15

16 timer = new Timer((qq) =>

17 {

18 ThreadPool.GetAvailableThreads(out a, out b);

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

20 }, null, 2000, 1000);

21

22 var act = new Action(testmethod);

23 var qqt = act.BeginInvoke(CallbackMethod, act);

24

25

26 Console.ReadLine();

27 }

28

29 static void CallbackMethod(IAsyncResult ar)

30 {

31 var caller = (Action)ar.AsyncState;

32 caller.EndInvoke(ar);

33 Console.WriteLine("Action回调结束");

34

35 }

36

37 static void testmethod()

38 {

39 Console.WriteLine("Action开始");

40 int a, b;

41 ThreadPool.GetAvailableThreads(out a, out b);

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

43 Thread.Sleep(2000);

44

45 }

\

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

作者:熬夜的虫子

QQ:1326194996 Msn:dubing_sh@hotmail.com

相关文章
最新文章
热点推荐