C#多线程--线程池（ThreadPool）

先引入一下线程池的概念：

百度百科：线程池是一种多线程处理形式，处理过程当中将任务添加到队列，而后在建立线程后自动启动这些任务。线程池线程都是后台线程。每一个线程都使用默认的堆栈大小，以默认的优先级运行，并处于多线程单元中。若是某个线程在托管代码中空闲（如正在等待某个事件）,则线程池将插入另外一个辅助线程来使全部处理器保持繁忙。若是全部线程池线程都始终保持繁忙，但队列中包含挂起的工做，则线程池将在一段时间后建立另外一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程能够排队，但他们要等到其余线程完成后才启动。

线程池主要方法:

        // 参数:
        // workerThreads:
        // 要由线程池根据须要建立的新的最小工做程序线程数。
        // completionPortThreads:
        // 要由线程池根据须要建立的新的最小空闲异步 I/O 线程数。

        // 返回结果:若是更改为功，则为 true；不然为 false。
        [SecuritySafeCritical]
        public static bool SetMinThreads(int workerThreads, int completionPortThreads);
        // 参数:
        // workerThreads:
        // 线程池中辅助线程的最大数目。
         // completionPortThreads:
        // 线程池中异步 I/O 线程的最大数目。
        // 返回结果:若是更改为功，则为 true；不然为 false。
        [SecuritySafeCritical]
        public static bool SetMaxThreads(int workerThreads, int completionPortThreads);

先来看一个简单的例子：

public class Program
    {
        const int cycleNum = 10;
        static void Main(string[] args) 
        {
            ThreadPool.SetMinThreads(1,1);
            ThreadPool.SetMaxThreads(5, 5);
            for(int i = 1; i <= cycleNum; i++)
            {
                ThreadPool.QueueUserWorkItem(new WaitCallback(testFun),i.ToString());
            }
            Console.WriteLine("主线程执行！");
            Console.WriteLine("主线程结束！");
            Console.ReadKey();
        }
        public static void testFun(object obj)
        {
            Console.WriteLine(string.Format("{0}:第{1}个线程",DateTime.Now.ToString(),obj.ToString()));
            Thread.Sleep(5000);
        }
    }

附上结果：

 

这里能够看出，线程池里线程的执行不影响主线程的运行，线程池虽然能够管理多线程的执行，可是却没法知道它何时终止。这时候咱们能够利用以前讲的信号灯AutoResetEvent和ManualResetEvent来解决问题，对此还不了解的朋友能够参见多线程之AutoResetEvent。

上面代码稍加改动，以下：

public class Program
    {
        const int cycleNum = 10;
        static int cnt = 10;
        static AutoResetEvent myEvent = new AutoResetEvent(false);
        static void Main(string[] args) 
        {
            ThreadPool.SetMinThreads(1,1);
            ThreadPool.SetMaxThreads(5, 5);
            for(int i = 1; i <= cycleNum; i++)
            {
                ThreadPool.QueueUserWorkItem(new WaitCallback(testFun),i.ToString());
            }
            Console.WriteLine("主线程执行！");
            Console.WriteLine("主线程结束！");
            myEvent.WaitOne();
            Console.WriteLine("线程池终止！");
            Console.ReadKey();
        }
        public static void testFun(object obj)
        {
            cnt -= 1;
            Console.WriteLine(string.Format("{0}:第{1}个线程",DateTime.Now.ToString(),obj.ToString()));
            Thread.Sleep(5000);
            if (cnt == 0)
            {
                myEvent.Set();
            }
        }
    }

这里，当线程池中全部线程执行完成后，能够捕获到该事件，咱们就能够利用此方法来获取线程池终止事件了，执行结果以下：

做者：依封剑白
出处：C#多线程--线程池（ThreadPool）
本文版权归做者和博客园共有，欢迎转载，但未经做者赞成必须保留此段声明，且在文章页面明显位置给出原文链接，不然保留追究法律责任的权利。若有问题或建议，请多多赐教，很是感谢。