多线程的AutoResetEvent
作者:互联网
多线程的AutoResetEvent
一、简介
我们在线程编程的时候往往会涉及到线程的通信,通过信号的接受来进行线程是否阻塞的操作。
AutoResetEvent 允许线程通过发信号互相通信。通常,此通信涉及线程需要独占访问的资源。具体方法和扩展方法请详见AutoResetEvent类,最常用方法中就有Set()和WaitOne()。
线程通过调用 AutoResetEvent 上的 WaitOne 来等待信号。如果 AutoResetEvent 处于非终止状态,则该线程阻塞,并等待当前控制资源的线程通过调用 Set 发出资源可用的信号。AutoResetEvent 的非终止状态可以通过构造函数在设置。
通俗的来讲只有等myResetEven.Set()成功运行后,myResetEven.WaitOne()才能够获得运行机会;Set是发信号,WaitOne是等待信号,只有发了信号,
等待的才会执行。如果不发的话,WaitOne后面的程序就永远不会执行。
AutoResetEvent myEvent = new AutoResetEvent(false);
这里构造函数中的参数false就代表该状态为非终止状态,相反若为true则为终止状态。
二、代码
案例一:
public class Program { const int cycleNum = 10;static void Main(string[] args) { // 参数: // workerThreads: // 要由线程池根据需要创建的新的最小工作程序线程数。 // completionPortThreads: // 要由线程池根据需要创建的新的最小空闲异步 I/O 线程数。 // 返回结果:如果更改成功,则为 true;否则为 false。 //public static bool SetMinThreads(int workerThreads, int completionPortThreads); ThreadPool.SetMinThreads(1, 1); // 参数: // workerThreads: // 线程池中辅助线程的最大数目。 // completionPortThreads: // 线程池中异步 I/O 线程的最大数目。 // 返回结果:如果更改成功,则为 true;否则为 false。 //public static bool SetMaxThreads(int workerThreads, int completionPortThreads); ThreadPool.SetMaxThreads(5, 5); for (int i = 1; i <= cycleNum; i++) { ThreadPool.QueueUserWorkItem(new WaitCallback(testFun), i.ToString()); } Console.WriteLine("主線程執行!"); 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); } }
运行结果:
这里可以看出,线程池里线程的执行不影响主线程的运行,线程池虽然可以管理多线程的执行,但是却无法知道它什么时候终止。
案例二:
public class Program { const int cycleNum = 10; static int cnt = 10; static AutoResetEvent myEvent = new AutoResetEvent(false); static void Main(string[] args) { // 参数: // workerThreads: // 要由线程池根据需要创建的新的最小工作程序线程数。 // completionPortThreads: // 要由线程池根据需要创建的新的最小空闲异步 I/O 线程数。 // 返回结果:如果更改成功,则为 true;否则为 false。 //public static bool SetMinThreads(int workerThreads, int completionPortThreads); ThreadPool.SetMinThreads(1, 1); // 参数: // workerThreads: // 线程池中辅助线程的最大数目。 // completionPortThreads: // 线程池中异步 I/O 线程的最大数目。 // 返回结果:如果更改成功,则为 true;否则为 false。 //public static bool SetMaxThreads(int workerThreads, int completionPortThreads); 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(); } } }
运行结果:
上面例子中一开始非终止状态,当遇到WaitOne()方法时则会阻塞线程,在没有set()时将一直处于阻塞状态.
三、总结
既然说到了AutoResetEvent,就不得不说ManualResetEvent,这两个方法几乎相同,不同的地方就在于AutoResetEvent的WaitOne()方法执行后会自动又将信号置为不发送状态也就是阻塞状态,当再次遇到WaitOne()方法是又会被阻塞,而ManualResetEvent则不会,只要线程处于非阻塞状态则无论遇到多少次WaitOne()方法都不会被阻塞,除非调用ReSet()方法来手动阻塞线程。
标签:workerThreads,AutoResetEvent,int,线程,static,多线程,WaitOne 来源: https://www.cnblogs.com/wml-it/p/14823469.html