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