标签:
using System; using System.Threading; namespace ConsoleApplication1 { class Program { static void Main(string[] args) { ManualResetEvent rem = new ManualResetEvent(false); //设置信号灯为无状态 ThreadPool.SetMaxThreads(3, 3); thr t = new thr(15, rem); for (int i = 0; i < 15; i++) { ThreadPool.QueueUserWorkItem(new WaitCallback(t.met),i); } rem.WaitOne(Timeout.Infinite, true); Console.WriteLine("断点测试"); Thread.Sleep(10000); Console.WriteLine("运行结束"); Console.ReadKey(); } } public class thr { public thr(int count,ManualResetEvent res) { iMaxCount1 = count; evens = res; } public static int icount = 0; public static int iMaxCount1 = 0; public ManualResetEvent evens; public void met(object i) { Console.WriteLine("thgead[" + i.ToString() + "]"); Thread.Sleep(2000); //Interlocked.Increment()操作是一个原子操作,作用是:iCount++ 具体请看下面说明 //原子操作,就是不能被更高等级中断抢夺优先的操作。你既然提这个问题,我就说深一点。 //由于操作系统大部分时间处于开中断状态, //所以,一个程序在执行的时候可能被优先级更高的线程中断。 //而有些操作是不能被中断的,不然会出现无法还原的后果,这时候,这些操作就需要原子操作。 //就是不能被中断的操作。 Interlocked.Increment(ref icount); if (icount == iMaxCount1) { Console.WriteLine("发出结束信号!"); //将事件状态设置为终止状态,允许一个或多个等待线程继续。 evens.Set(); } } } }
标签:
原文地址:http://www.cnblogs.com/mengluo/p/5592918.html