线程池设置最多M线程执行N个任务
Posted JeffQing
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了线程池设置最多M线程执行N个任务相关的知识,希望对你有一定的参考价值。
转载地址:http://www.ithao123.cn/content-4805192.html
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; namespace 多线程池试验 { class Program { public static void Main() { //新建ManualResetEvent对象并且初始化为无信号状态 ManualResetEvent eventX = new ManualResetEvent(false); ThreadPool.SetMaxThreads(3, 3); thr t = new thr(15, eventX); for (int i = 0; i < 15; i++) { ThreadPool.QueueUserWorkItem(new WaitCallback(t.ThreadProc), i); } //等待事件的完成,即线程调用ManualResetEvent.Set()方法 //eventX.WaitOne 阻止当前线程,直到当前 WaitHandle 收到信号为止。 eventX.WaitOne(Timeout.Infinite, true); Console.WriteLine("断点测试"); Thread.Sleep(10000); Console.WriteLine("运行结束"); } public class thr { public thr(int count,ManualResetEvent mre) { iMaxCount = count; eventX = mre; } public static int iCount = 0; public static int iMaxCount = 0; public ManualResetEvent eventX; public void ThreadProc(object i) { Console.WriteLine("Thread[" + i.ToString() + "]"); Thread.Sleep(2000); //Interlocked.Increment()操作是一个原子操作,作用是:iCount++ 具体请看下面说明 //原子操作,就是不能被更高等级中断抢夺优先的操作。你既然提这个问题,我就说深一点。 //由于操作系统大部分时间处于开中断状态, //所以,一个程序在执行的时候可能被优先级更高的线程中断。 //而有些操作是不能被中断的,不然会出现无法还原的后果,这时候,这些操作就需要原子操作。 //就是不能被中断的操作。 Interlocked.Increment(ref iCount); if (iCount == iMaxCount) { Console.WriteLine("发出结束信号!"); //将事件状态设置为终止状态,允许一个或多个等待线程继续。 eventX.Set(); } } } } }
转载地址:http://www.ithao123.cn/content-4805192.html
以上是关于线程池设置最多M线程执行N个任务的主要内容,如果未能解决你的问题,请参考以下文章