博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
C#多线程--线程池(ThreadPool)
阅读量:5302 次
发布时间:2019-06-14

本文共 2703 字,大约阅读时间需要 9 分钟。

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

百度百科:线程池是一种多线程处理形式,处理过程中将任务添加到队列,然后在创建线程后自动启动这些任务。线程池线程都是后台线程。每个线程都使用默认的大小,以默认的优先级运行,并处于多线程单元中。如果某个线程在中空闲(如正在等待某个事件),则线程池将插入另一个来使所有处理器保持繁忙。如果所有线程池线程都始终保持繁忙,但队列中包含挂起的工作,则线程池将在一段时间后创建另一个辅助线程但线程的数目永远不会超过最大值。超过最大值的线程可以排队,但他们要等到其他线程完成后才启动。

线程池主要方法:

// 参数:        // 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来解决问题,对此还不了解的朋友可以参见。

上面代码稍加改动,如下:

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(); } } }

这里,当线程池中所有线程执行完成后,可以捕获到该事件,我们就可以利用此方法来获取线程池终止事件了,执行结果如下:

转载于:https://www.cnblogs.com/zxtceq/p/10980416.html

你可能感兴趣的文章
ios -WKWebView 高度 准确,留有空白的解决方案
查看>>
TCP连接的三次握手
查看>>
git 查看远程分支、本地分支、创建分支、把分支推到远程repository、删除本地分支...
查看>>
ArcEngine环境下合并断开的线要素(根据属性)
查看>>
锋利的js前端分页之jQuery
查看>>
C#中的四舍五入有多坑
查看>>
C# 中的值类型和引用类型
查看>>
shell编程while
查看>>
java 连接mysql
查看>>
spring 收藏博文
查看>>
Redis 编译报错 "make[3]: gcc:命令未找到" 解决实例
查看>>
容斥原理——hdu2841
查看>>
C#设计模式(19)——状态者模式(State Pattern)
查看>>
JAVA 线程池之Callable返回结果
查看>>
Navisworks 2014 Api 简单的使用
查看>>
Java Spring IOC用法
查看>>
解决ie6下不支持fix属性,模拟固定定位
查看>>
面向对象之类的其他方法
查看>>
Java NIO简介 2011-09-20 12:43 94人阅读 评论(0) 收藏...
查看>>
ubuntu虚拟内存一直保留
查看>>