zoukankan      html  css  js  c++  java
  • 抓虫系列(四) 不要轻视web程序中常用的三个"池" 之线程池

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

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

    先把虫子的观点放上: 个人表示排斥在项目中使用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);
            
            }
    

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



  • 相关阅读:
    Codeforces 468 B Two Sets
    POJ 3080 Blue Jeans
    Scan法求凸包
    线段树 区间更新 区间求和 板子
    拼图设计 课程作业三
    通讯录c#实现 课程作业二
    贷款计算器C#实现 课程作业一
    标准计算器C#实现 课程作业一
    ccf 行车路线
    hdu 4902 Nice boat
  • 原文地址:https://www.cnblogs.com/dubing/p/2221143.html
Copyright © 2011-2022 走看看