簡單介紹

     多個(gè)線程可以通過調(diào)用ManualResetEvent對(duì)象的WaitOne方法進(jìn)入等待或阻塞狀態(tài)。當(dāng)控制線程調(diào)用Set()方法，所有等待線程將恢復(fù)并繼續(xù)執(zhí)行。

ManualResetEvent是如何工作的

    在內(nèi)存中保持著一個(gè)bool值，如果bool值為False，則使所有線程阻塞，反之，如果bool值為True,則使所有線程退出阻塞。當(dāng)我們創(chuàng)建ManualResetEvent對(duì)象的實(shí)例時(shí)，我們在函數(shù)構(gòu)造中傳遞默認(rèn)的bool值，以下是實(shí)例化ManualResetEvent的例子。

ManualResetEvent manualResetEvent = new ManualResetEvent(false);

在上面代碼中，我們初始化了一個(gè)值為False的ManualResetEvent對(duì)象，這意味著所有調(diào)用WaitOne放的線程將被阻塞，直到有線程調(diào)用了 Set() 方法。而如果我們用值True來對(duì)ManualResetEvent對(duì)象進(jìn)行初始化，所有調(diào)用WaitOne方法的線程并不會(huì)被阻塞，可以進(jìn)行后續(xù)的執(zhí)行。

WaitOne方法

   該方法阻塞當(dāng)前線程并等待其他線程發(fā)送信號(hào)。如果收到信號(hào)，它將返回True，反之返回False。以下演示了如何調(diào)用該方法。

manualResetEvent.WaitOne();

在WaitOne方法的第二個(gè)重載版本中，我們可以指定當(dāng)前線程等待信號(hào)的時(shí)間間隔。如果在時(shí)間間隔內(nèi)，沒有收到信號(hào)，方法將返回False并繼續(xù)執(zhí)行。以下代碼演示了帶時(shí)間間隔參數(shù)的WaitOne調(diào)用。

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

我們指定了5秒作為WaitOne方法的參數(shù)，如果manualResetEvent對(duì)象在5秒內(nèi)收到信號(hào)，它將isSignalled賦值為False。

Set方法

   該方法用于給所有等待線程發(fā)送信號(hào)。 Set() 方法的調(diào)用使得ManualResetEvent對(duì)象的bool變量值為True，所有線程被釋放并繼續(xù)執(zhí)行。下面是調(diào)用的例子：

manualResetEvent.Set();

Reset方法

   一旦我們調(diào)用了ManualResetEvent對(duì)象的Set()方法，它的bool值就變?yōu)閠rue,我們可以調(diào)用Reset()方法來重置該值，Reset()方法重置該值為False。以下是調(diào)用Reset方法的例子：

manualResetEvent.Reset();

如果我們想多次發(fā)送信號(hào)，那么我們必須在調(diào)用Set()方法后立即調(diào)用Reset()方法。

ManualResetEvent 例子

    下面的例子展示了如何使用ManualResetEvent來釋放多個(gè)線程。我們用false值實(shí)例化了ManualResetEvent對(duì)象，它將阻塞所有調(diào)用WaitOne方法的線程。我們創(chuàng)建了兩個(gè)線程，它們調(diào)用方法GetDataFromServer，并以server數(shù)量作為參數(shù)。
      在調(diào)用WaitOne方法獲取第一批數(shù)量后，兩個(gè)線程均等待來自調(diào)用WaitOne線程的信號(hào)。當(dāng)控制線程調(diào)用manualrestEvent對(duì)象的Set方法，兩個(gè)線程均被釋放并繼續(xù)運(yùn)行。在調(diào)用Set方法后，我們立即調(diào)用了Reset方法，這將改變manualrestEvent對(duì)象的bool值為false。所以，如果線程再次調(diào)用WaitOne方法，他們?nèi)匀粫?huì)被阻塞。
    在從服務(wù)器獲取第二批數(shù)據(jù)后，兩個(gè)線程均調(diào)用了WaitOne方法。在2秒后，控制線程再次調(diào)用Set方法釋放兩個(gè)線程。

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用法總結(jié)的詳細(xì)內(nèi)容，更多關(guān)于C#中ManualResetEvent用法的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論