前篇回顾:上篇讲了数据库连接池的问题,其实关于是否是活动连接还是有很大问题可以挖掘的。这个有空虫子再和大家交流了
本篇谈下线程池的相关问题,希望各位看官留个爪印,应用程序池和数据库连接池可能大部分程序员不需要关心那个,不过线程池可所谓是重头戏了。
先把虫子的观点放上: 个人表示排斥在项目中使用ThreadPool这个类,至于.net中关联到ThreadPool的资源我们暂且不做讨论。如果需要操作线程池可以使用第三方例如SmartThreadPool或者自己按照自己的项目需求开发一个。
线程池的相关概念我就不多说了,同样这里我只介绍下。线程池中容易被忽视的问题。
一. 相对池外线程,池内线程操作的性能极差!
ManualResetEvent[] MR = new ManualResetEvent[10]; for (int i = 0; i < 10; i++) { MR[i] = new ManualResetEvent(false); } int a, b; ThreadPool.GetMaxThreads(out a, out b); Console.WriteLine(string.Format("(辅助线程的最大数目{0} I/O线程的最大数目{1}) 初始状态", a, b)); ThreadPool.GetAvailableThreads(out a, out b); Console.WriteLine(string.Format("(可用辅助线程的最大数目{0} 可用I/O线程的最大数目{1}) 初始状态", a, b)); Stopwatch sw = Stopwatch.StartNew(); for (int i = 0; i < 10; i++) { new Thread((qq) => { Console.WriteLine("这是个线程池外的线程"+qq.ToString()); MR[(int)qq].Set(); Thread.Sleep(5000); }) { }.Start(i); } WaitHandle.WaitAll(MR); Console.WriteLine("生成池外10个线程 共耗时" + sw.ElapsedMilliseconds); foreach (ManualResetEvent me in MR) { me.Reset(); } Thread.Sleep(500); ThreadPool.GetAvailableThreads(out a, out b); Console.WriteLine(string.Format("(可用辅助线程的最大数目{0} 可用I/O线程的最大数目{1}) 线程池外启动线程后", a, b)); sw = Stopwatch.StartNew(); for (int i = 0; i < 10; i++) { ThreadPool.QueueUserWorkItem(qq => { Console.WriteLine("这是个线程池内的线程" + qq.ToString()); MR[(int)qq].Set(); Thread.Sleep(20000); },i); } WaitHandle.WaitAll(MR); Console.WriteLine("生成池内10个线程 共耗时" + sw.ElapsedMilliseconds); Thread.Sleep(6000); ThreadPool.GetAvailableThreads(out a, out b); Console.WriteLine(string.Format("(可用辅助线程的最大数目{0} 可用I/O线程的最大数目{1}) 线程池内启动线程后", a, b));
在初始状态后 生成线程的效率存在百倍的差距!!!不过线程池既然是池的作用那么在程序运行中应该会好很多。
二。线程池内的线程只能是后台线程。
三。不能为线程设置优先级。在高精度的项目中线程池不适用。
四。所支持的Callback不能有返回值。WaitCallback只能带一个object类型的参数,没有任何返回值。
五。容易被干扰,同时容易破坏项目的应用环境。举些例子
static void Main(string[] args) { //哪些函数会影响线程池 int a, b; Timer timer = new Timer((qq) => { Console.WriteLine("这是一个timer"); Thread.Sleep(2000); }, null, 2000, 1000); ThreadPool.GetAvailableThreads(out a, out b); Console.WriteLine(string.Format("(可用辅助线程的最大数目{0} 可用I/O线程的最大数目{1}) Timer启动后", a, b)); timer.Dispose(); timer = new Timer((qq) => { ThreadPool.GetAvailableThreads(out a, out b); Console.WriteLine(string.Format("(可用辅助线程的最大数目{0}/可用I/O线程的最大数目{1}) Timer资源占用ing", a, b)); }, null, 2000, 1000); var act = new Action(testmethod); var qqt = act.BeginInvoke(CallbackMethod, act); Console.ReadLine(); } static void CallbackMethod(IAsyncResult ar) { var caller = (Action)ar.AsyncState; caller.EndInvoke(ar); Console.WriteLine("Action回调结束"); } static void testmethod() { Console.WriteLine("Action开始"); int a, b; ThreadPool.GetAvailableThreads(out a, out b); Console.WriteLine(string.Format("(可用辅助线程的最大数目{0} 可用I/O线程的最大数目{1}) Action启动ing", a, b)); Thread.Sleep(2000); }
至于还有哪些,大家可以各自讨论,或者提出反对的意见。