C# ManualResetEvent

原文連接 http://dotnetpattern.com/threading-manualresetevent

ManualResetEvent 和AutoResetEvent同樣，是另一種.NET線程同步技術。

ManualResetEvent被用於在兩個或多個線程間進行線程信號發送。

      多個線程能夠經過調用ManualResetEvent對象的WaitOne方法進入等待或阻塞狀態。當控制線程調用Set()方法，全部等待線程將恢復並繼續執行。

ManualResetEvent是如何工做的

    在內存中保持着一個bool值，若是bool值爲False，則使全部線程阻塞，反之，若是bool值爲True,則使全部線程退出阻塞。當咱們建立ManualResetEvent對象的實例時，咱們在函數構造中傳遞默認的bool值，如下是實例化ManualResetEvent的例子。

ManualResetEvent manualResetEvent = new ManualResetEvent(false);

在上面代碼中，咱們初始化了一個值爲False的ManualResetEvent對象，這意味着全部調用WaitOne放的線程將被阻塞，直到有線程調用了 Set() 方法。而若是咱們用值True來對ManualResetEvent對象進行初始化，全部調用WaitOne方法的線程並不會被阻塞，能夠進行後續的執行。

WaitOne方法

   該方法阻塞當前線程並等待其餘線程發送信號。若是收到信號，它將返回True，反之返回False。如下演示瞭如何調用該方法。

manualResetEvent.WaitOne();

在WaitOne方法的第二個重載版本中，咱們能夠指定當前線程等待信號的時間間隔。若是在時間間隔內，沒有收到信號，方法將返回False並繼續執行。如下代碼演示了帶時間間隔參數的WaitOne調用。

bool isSignalled = manualResetEvent.WaitOne(TimeSpan.FromSeconds(5));

咱們指定了5秒做爲WaitOne方法的參數，若是manualResetEvent對象在5秒內收到信號，它將isSignalled賦值爲False。

Set方法

   該方法用於給全部等待線程發送信號。 Set() 方法的調用使得ManualResetEvent對象的bool變量值爲True，全部線程被釋放並繼續執行。下面是調用的例子：

manualResetEvent.Set();

Reset方法
   一旦咱們調用了ManualResetEvent對象的Set()方法，它的bool值就變爲true,咱們能夠調用Reset()方法來重置該值，Reset()方法重置該值爲False。如下是調用Reset方法的例子：

manualResetEvent.Reset();

若是咱們想屢次發送信號，那麼咱們必須在調用Set()方法後當即調用Reset()方法。

ManualResetEvent 例子
    下面的例子展現瞭如何使用ManualResetEvent來釋放多個線程。咱們用false值實例化了ManualResetEvent對象，它將阻塞全部調用WaitOne方法的線程。咱們建立了兩個線程，它們調用方法GetDataFromServer，並以server數量做爲參數。
      在調用WaitOne方法獲取第一批數量後，兩個線程均等待來自調用WaitOne線程的信號。當控制線程調用manualrestEvent對象的Set方法，兩個線程均被釋放並繼續運行。在調用Set方法後，咱們當即調用了Reset方法，這將改變manualrestEvent對象的bool值爲false。因此，若是線程再次調用WaitOne方法，他們仍然會被阻塞。
    在從服務器獲取第二批數據後，兩個線程均調用了WaitOne方法。在2秒後，控制線程再次調用Set方法釋放兩個線程。

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);
    }
}