首页 > 代码库 > 信号量 <第六篇>
信号量 <第六篇>
一、ManualResetEvent
该对象有两种信号量状态True和False。构造函数设置初始状态。
- WaitOne：该方法用于阻塞线程，默认是无限期的阻塞，支持超时阻塞，如果超时就放弃阻塞，这样也就避免了无限期等待的尴尬；
- Set:手动修改信号量为True，也就是恢复线程执行；
- ReSet:重置状态；
class Program { public static void Main() { Thread t = new Thread(Run); t.Name = "辅助线程"; t.Start(); Console.WriteLine("当前时间:{0} {1}准备执行！", DateTime.Now.TimeOfDay, t.Name); //手动修改信号量为True，也就是恢复一个等待线程执行。 mr.Set(); Console.ReadKey(); } //一开始设置为false才会等待收到信号才执行 static ManualResetEvent mr = new ManualResetEvent(true); static void Run() { //线程开始执行时待命，收到信号才动身 mr.WaitOne(); Console.WriteLine("\n当前时间:{0} {1}正式执行！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); //我想让辅助线程暂停3秒 mr.WaitOne(3000); Console.WriteLine("\n当前时间:{0} {1}暂停3秒，但是无效！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); //我想让辅助线程暂停 mr.Reset(); Console.WriteLine("\n当前时间:{0} {1}还是无效！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); } }输出如下：
Reset()的意思其实是重置，重置后才又能再WaitOne()；
class Program { public static void Main() { Thread t = new Thread(Run); t.Name = "辅助线程"; t.Start(); Console.WriteLine("当前时间:{0} {1}准备执行！", DateTime.Now.TimeOfDay, t.Name); //手动修改信号量为True，也就是恢复一个等待线程执行。 mr.Set(); Thread.Sleep(10000); mr.Set(); Console.ReadKey(); } //一开始设置为false才会等待收到信号才执行 static ManualResetEvent mr = new ManualResetEvent(false); static void Run() { //线程开始执行时待命，收到信号才动身 mr.WaitOne(); Console.WriteLine("\n当前时间:{0} {1}正式执行！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); //重置后停止才有效 mr.Reset(); //我想让辅助线程暂停3秒 mr.WaitOne(3000); Console.WriteLine("\n当前时间:{0} {1}暂停3秒，这回有效了！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); //重置后停止才有效 mr.Reset(); //我想让辅助线程暂停,10后由主线程再次唤醒 mr.WaitOne(); Console.WriteLine("\n当前时间:{0} {1}暂停，但会被主线程再次唤醒，这回有效了！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name ); } }输出如下：
二、AutoResetEvent
AutoResetEvent与ManualResetEvent的区别在于AutoResetEvent 的WaitOne会改变信号量的值。
比如说初始信号量为True，如果WaitOne超时信号量将自动变为False，而ManualResetEvent则不会。
class Program { public static void Main() { Thread t = new Thread(Run); t.Name = "辅助线程"; t.Start(); Console.WriteLine("当前时间:{0} {1}准备执行！", DateTime.Now.TimeOfDay, t.Name); Console.ReadKey(); } static AutoResetEvent ar = new AutoResetEvent(true); static void Run() { var state = ar.WaitOne(1000); Console.WriteLine("当前的信号量状态:{0}", state); state = ar.WaitOne(1000); Console.WriteLine("再次WaitOne后现在的状态是:{0}", state); } }输出如下：
假如要实现上面ManualResetEvent同样的效果，Run方法就不用手动Reset()了：
static void Run() { //线程开始执行时待命，收到信号才动身 mr.WaitOne(); Console.WriteLine("\n当前时间:{0} {1}正式执行！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); //我想让辅助线程暂停3秒 mr.WaitOne(3000); Console.WriteLine("\n当前时间:{0} {1}暂停3秒，这回有效了！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); //我想让辅助线程暂停,10后由主线程再次唤醒 mr.WaitOne(); Console.WriteLine("\n当前时间:{0} {1}暂停，但会被主线程再次唤醒，这回有效了！", DateTime.Now.TimeOfDay, Thread.CurrentThread.Name); }少了手动Reset()代码。
三、Semaphore
用于控制线程的访问数量，默认的构造函数为initialCount和maximumCount，表示默认设置的信号量个数和最大信号量个数。当你WaitOne的时候，信号量自减，当Release的时候，信号量自增，然而当信号量为0的时候，后续的线程就不能拿到WaitOne了，所以必须等待先前的线程通过Release来释放。
class Program { static void Main(string[] args) { Thread t1 = new Thread(Run1); t1.Start(); Thread t2 = new Thread(Run2); t2.Start(); Thread t3 = new Thread(Run3); t3.Start(); Console.Read(); } //初始可以授予2个线程信号，因为第3个要等待前面的Release才能得到信号 static Semaphore sem = new Semaphore(2, 10); static void Run1() { sem.WaitOne(); Console.WriteLine("大家好，我是Run1" + DateTime.Now.TimeOfDay); } static void Run2() { sem.WaitOne(); Console.WriteLine("大家好，我是Run2" + DateTime.Now.TimeOfDay); //两秒后 Thread.Sleep(2000); sem.Release(); } static void Run3() { sem.WaitOne(); Console.WriteLine("大家好，我是Run3" + DateTime.Now.TimeOfDay); } }输出：
在以上的方法中Release()方法相当于自增一个信号量，Release(5)自增5个信号量。但是，Release()到构造函数的第二个参数maximumCount的值就不能再自增了。
命名Semaphore可用于进程级交互。
class Program { static void Main(string[] args) { Thread t1 = new Thread(Run1); t1.Start(); Thread t2 = new Thread(Run2); t2.Start(); Console.Read(); } //初始可以授予2个线程信号，因为第3个要等待前面的Release才能得到信号 static Semaphore sem = new Semaphore(3, 10, "命名Semaphore"); static void Run1() { sem.WaitOne(); Console.WriteLine("进程：" +Process.GetCurrentProcess().Id + " 我是Run1" + DateTime.Now.TimeOfDay); } static void Run2() { sem.WaitOne(); Console.WriteLine("进程：" + Process.GetCurrentProcess().Id + " 我是Run2" + DateTime.Now.TimeOfDay); } }输出如下：
- ManualResetEvent：每次可以唤醒一个或多个线程；
- AutoResetEvent：每次只能唤醒一个线程；
信号量 <第六篇>
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。