上一節(jié)主要介紹了使用鎖進(jìn)行同步，本節(jié)主要介紹使用信號量進(jìn)行同步
EventWaitHandle主要用于實(shí)現(xiàn)信號燈機(jī)制。信號燈主要用于通知等待的線程。主要有兩種實(shí)現(xiàn)：AutoResetEvent和ManualResetEvent。
AutoResetEvent從字面上理解是一個(gè)自動(dòng)重置的時(shí)間。舉個(gè)例子，假設(shè)有很多人等在門外，AutoResetEvent更像一個(gè)十字旋轉(zhuǎn)門，每一次只允許一個(gè)人進(jìn)入，進(jìn)入之后門仍然是關(guān)閉狀態(tài)。
下面的例子演示了使用方式：
using System;using System.Threading;class BasicWaitHandle{ static EventWaitHandle _waitHandle = new AutoResetEvent(false); static void Main() { for (int i = 0; i < 3; i++) new Thread(Waiter).Start(); for (int i = 0; i < 3; i++) { Thread.Sleep(1000); // Pause for a second... Console.WriteLine("通知下一個(gè)線程進(jìn)入"); _waitHandle.Set(); // Wake up the Waiter. } Console.ReadLine(); } static void Waiter() { var threadId = Thread.CurrentThread.ManagedThreadId; Console.WriteLine("線程 {0} 正在等待", threadId); _waitHandle.WaitOne(); // 等待通知 Console.WriteLine("線程 {0} 得到通知，可以進(jìn)入", threadId); }}
某些情況下，如果你連續(xù)的多次使用Set方法通知工作線程，這個(gè)時(shí)候工作線程可能還沒有準(zhǔn)備好接收信號，這樣的話后面的幾次Set通知可能會(huì)沒有效果。這種情況下，你需要讓主線程得到工作線程接收信息的通知再開始發(fā)送信息。你可能需要通過兩個(gè)信號燈實(shí)現(xiàn)這個(gè)功能。
示例代碼：
using System;using System.Threading;class TwoWaySignaling{ static EventWaitHandle _ready = new AutoResetEvent(false); static EventWaitHandle _go = new AutoResetEvent(false); static readonly object _locker = new object(); static string _message; static void Main() { new Thread(Work).Start(); _ready.WaitOne(); // 在工作線程準(zhǔn)備接收信息之前需要一直等待 lock (_locker) _message = "床前明月光"; _go.Set(); // 通知工作線程開始工作 _ready.WaitOne(); lock (_locker) _message = "疑是地上霜"; _go.Set(); _ready.WaitOne(); lock (_locker) _message = "結(jié)束"; // 告訴工作線程退出 _go.Set(); Console.ReadLine(); } static void Work() { while (true) { _ready.Set(); // 表示當(dāng)前線程已經(jīng)準(zhǔn)備接收信號 _go.WaitOne(); // 工作線程等待通知 lock (_locker) { if (_message == "結(jié)束") return; // 優(yōu)雅的退出~-~ Console.WriteLine(_message); } } }}生產(chǎn)消費(fèi)隊(duì)列是多線程編程里常見的的需求，他的主要思路是：
示例代碼：
using System;using System.Threading;using System.Collections.Generic; class PRoducerConsumerQueue : IDisposable{ EventWaitHandle _wh = new AutoResetEvent (false); Thread _worker; readonly object _locker = new object(); Queue<string> _tasks = new Queue<string>(); public ProducerConsumerQueue() { _worker = new Thread (Work); _worker.Start(); } public void EnqueueTask (string task) { lock (_locker) _tasks.Enqueue (task); _wh.Set(); } public void Dispose() { EnqueueTask (null); // Signal the consumer to exit. _worker.Join(); // Wait for the consumer's thread to finish. _wh.Close(); // Release any OS resources. } void Work() { while (true) { string task = null; lock (_locker) if (_tasks.Count > 0) { task = _tasks.Dequeue(); if (task == null) return; } if (task != null) { Console.WriteLine ("Performing task: " + task); Thread.Sleep (1000); // simulate work... } else _wh.WaitOne(); // No more tasks - wait for a signal } }}
為了保證線程安全，我們使用lock來保護(hù)Queue<string>集合。我們也顯示的關(guān)閉了WaitHandle。
在.NET 4.0中，一個(gè)新的類BlockingCollection實(shí)現(xiàn)了類似生產(chǎn)者消費(fèi)者隊(duì)列的功能。
ManualResetEvent從字面上看是一個(gè)需要手動(dòng)關(guān)閉的事件。舉個(gè)例子：假設(shè)有很多人等在門外，它像是一個(gè)普通的門，門開啟之后，所有等在門外的人都可以進(jìn)來，當(dāng)你關(guān)閉門之后，不再允許外面的人進(jìn)來。
示例代碼：
using System;using System.Threading;class BasicWaitHandle{ static EventWaitHandle _waitHandle = new ManualResetEvent(false); static void Main() { for (int i = 0; i < 3; i++) new Thread(Waiter).Start(); Thread.Sleep(1000); // Pause for a second... Console.WriteLine("門已打開，線程進(jìn)入"); _waitHandle.Set(); // Wake up the Waiter. new Thread(Waiter).Start(); Thread.Sleep(2000); _waitHandle.Reset(); Console.WriteLine("門已關(guān)閉，線程阻塞"); new Thread(Waiter).Start(); Console.ReadLine(); } static void Waiter() { var threadId = Thread.CurrentThread.ManagedThreadId; Console.WriteLine("線程 {0} 正在等待", threadId); _waitHandle.WaitOne(); // 等待通知 Console.WriteLine("線程 {0} 得到通知，可以進(jìn)入", threadId); }}ManualResetEvent可以在當(dāng)前線程喚醒所有等待的線程，這一應(yīng)用非常重要。
CountdownEvent的使用和ManualEvent正好相反，是多個(gè)線程共同喚醒一個(gè)線程。
示例代碼：
using System;using System.Threading;class CountDownTest{ static CountdownEvent _countdown = new CountdownEvent(3); static void Main() { new Thread(SaySomething).Start("I am thread 1"); new Thread(SaySomething).Start("I am thread 2"); new Thread(SaySomething).Start("I am thread 3"); _countdown.Wait(); // 當(dāng)前線程被阻塞，直到收到 _countdown發(fā)送的三次信號 Console.WriteLine("All threads have finished speaking!"); Console.ReadLine(); } static void SaySomething(object thing) { Thread.Sleep(1000); Console.WriteLine(thing); _countdown.Signal(); }}EventWaitHandle的構(gòu)造方法允許創(chuàng)建一個(gè)命名的EventWaitHandle，來實(shí)現(xiàn)跨進(jìn)程的信號量操作。名字只是一個(gè)簡單的字符串，只要保證不會(huì)跟其它進(jìn)程的鎖沖突即可。
示例代碼：
EventWaitHandle wh = new EventWaitHandle(false, EventResetMode.AutoReset, "MyCompany.MyApp.SomeName");
如果兩個(gè)進(jìn)程運(yùn)行這段代碼，信號量會(huì)作用于兩個(gè)進(jìn)程內(nèi)所有的線程。
新聞熱點(diǎn)
疑難解答
圖片精選
