簡(jiǎn)單介紹
多個(gè)線(xiàn)程可以通過(guò)調用ManualResetEvent對象的WaitOne方法進(jìn)入等待或阻塞狀態(tài)。當控制線(xiàn)程調用Set()方法，所有等待線(xiàn)程將恢復并繼續執行。
ManualResetEvent是如何工作的
在內存中保持著(zhù)一個(gè)bool值，如果bool值為False，則使所有線(xiàn)程阻塞，反之，如果bool值為T(mén)rue,則使所有線(xiàn)程退出阻塞。當我們創(chuàng )建ManualResetEvent對象的實(shí)例時(shí)，我們在函數構造中傳遞默認的bool值，以下是實(shí)例化ManualResetEvent的例子。
1
ManualResetEvent manualResetEvent = new ManualResetEvent(false);
在上面代碼中，我們初始化了一個(gè)值為False的ManualResetEvent對象，這意味著(zhù)所有調用WaitOne放的線(xiàn)程將被阻塞，直到有線(xiàn)程調用了 Set() 方法。而如果我們用值True來(lái)對ManualResetEvent對象進(jìn)行初始化，所有調用WaitOne方法的線(xiàn)程并不會(huì )被阻塞，可以進(jìn)行后續的執行。
WaitOne方法
該方法阻塞當前線(xiàn)程并等待其他線(xiàn)程發(fā)送信號。如果收到信號，它將返回True，反之返回False。以下演示了如何調用該方法。
1
manualResetEvent.WaitOne();
在WaitOne方法的第二個(gè)重載版本中，我們可以指定當前線(xiàn)程等待信號的時(shí)間間隔。如果在時(shí)間間隔內，沒(méi)有收到信號，方法將返回False并繼續執行。以下代碼演示了帶時(shí)間間隔參數的WaitOne調用。
1
bool isSignalled = manualResetEvent.WaitOne(TimeSpan.FromSeconds(5));
我們指定了5秒作為WaitOne方法的參數，如果manualResetEvent對象在5秒內收到信號，它將isSignalled賦值為False。
Set方法
該方法用于給所有等待線(xiàn)程發(fā)送信號。Set() 方法的調用使得ManualResetEvent對象的bool變量值為T(mén)rue，所有線(xiàn)程被釋放并繼續執行。下面是調用的例子：
1
manualResetEvent.Set();
Reset方法
一旦我們調用了ManualResetEvent對象的Set()方法，它的bool值就變?yōu)閠rue,我們可以調用Reset()方法來(lái)重置該值，Reset()方法重置該值為False。以下是調用Reset方法的例子：
1
manualResetEvent.Reset();
如果我們想多次發(fā)送信號，那么我們必須在調用Set()方法后立即調用Reset()方法。
ManualResetEvent 例子
下面的例子展示了如何使用ManualResetEvent來(lái)釋放多個(gè)線(xiàn)程。我們用false值實(shí)例化了ManualResetEvent對象，它將阻塞所有調用WaitOne方法的線(xiàn)程。我們創(chuàng )建了兩個(gè)線(xiàn)程，它們調用方法GetDataFromServer，并以server數量作為參數。
在調用WaitOne方法獲取第一批數量后，兩個(gè)線(xiàn)程均等待來(lái)自調用WaitOne線(xiàn)程的信號。當控制線(xiàn)程調用manualrestEvent對象的Set方法，兩個(gè)線(xiàn)程均被釋放并繼續運行。在調用Set方法后，我們立即調用了Reset方法，這將改變manualrestEvent對象的bool值為false。所以，如果線(xiàn)程再次調用WaitOne方法，他們仍然會(huì )被阻塞。
在從服務(wù)器獲取第二批數據后，兩個(gè)線(xiàn)程均調用了WaitOne方法。在2秒后，控制線(xiàn)程再次調用Set方法釋放兩個(gè)線(xiàn)程。
class Program{ static ManualResetEvent manualResetEvent = new ManualResetEvent(false); static void Main(string[] args) { Task task = Task.Factory.StartNew(() => { GetDataFromServer(1); }); Task.Factory.StartNew(() => { GetDataFromServer(2); }); //Send first signal to get first set of data from server 1 and server 2 manualResetEvent.Set(); manualResetEvent.Reset(); Thread.Sleep(TimeSpan.FromSeconds(2)); //Send second signal to get second set of data from server 1 and server 2 manualResetEvent.Set(); Console.ReadLine(); /* Result * I get first data from server1 * I get first data from server2 * I get second data from server1 * I get second data from server2 * All the data collected from server2 * All the data collected from server1 */ } static void GetDataFromServer(int serverNumber) { //Calling any webservice to get data Console.WriteLine("I get first data from server" + serverNumber); manualResetEvent.WaitOne(); Thread.Sleep(TimeSpan.FromSeconds(2)); Console.WriteLine("I get second data from server" + serverNumber); manualResetEvent.WaitOne(); Console.WriteLine("All the data collected from server" + serverNumber); }}
