C#中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);
  }
}

以上就是C#中ManualResetEvent用法總結的詳細內容,更多關於C#中ManualResetEvent用法的資料請關註WalkonNet其它相關文章!