c# AutoResetEvent 信号灯 用于线程池状态控制
我们在线程编程的时候往往会涉及到线程的通信,通过信号的接受来进行线程是否阻塞的操作。
AutoResetEvent 允许线程通过发信号互相通信。通常,此通信涉及线程需要独占访问的资源。
AutoResetEvent 的方法有很多,具体方法和扩展方法请详见AutoResetEvent类,最常用方法中就有Set()和WaitOne()。
我们构造一个信号灯。
static AutoResetEvent myResetEvent = new AutoResetEvent(false);
想要监控线程的状态,通俗的来讲只有等myResetEven.Set()成功运行后,myResetEven.WaitOne()才能够获得运行机会;Set是发信号,WaitOne是等待信号,只有发了信号,才可以进行等待的查询。
public class Program { const int cycleNum = 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) { Console.WriteLine(string.Format("{0}:第{1}个线程", DateTime.Now.ToString(), obj.ToString())); Thread.Sleep(5000); if (obj.ToString() == cycleNum.ToString()) { myEvent.Set(); } } }