c# ManualResetEvent WaitHandle 实现同步

//本文演示了ManualResetEvent 类的非静态set()、Reset()、WaitOne()和

//WaitHandle类的静态方法WaitAllWaitAll()

//它们用于线程间的同步控制。

//实现了如下功能：线程1（定时控制）通知线程2和线程3采集数据

//线程2和3数据采集完了，各自通知线程1情况。

//那么线程1收到了两个线程的通知，则进行下一轮采集

//控制台.netframework4.0

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading;

using System.Threading.Tasks;

//用以下Main函数替换掉你自己的

static void Main(string[] args)
        {
            const int numberOfFiles=2;
            Console.WriteLine("Press any key to start");
            Console.ReadKey();
            var cancelToken = new CancellationTokenSource();//用于取消多线程
            var random = new Random();
            Console.WriteLine("Task started, press any key to stop...");
    
            var manualResetEvent1 = new ManualResetEvent(false);
            var manualResetEvent2 = new ManualResetEvent(false);
            ManualResetEvent [] manualEvents = new ManualResetEvent[numberOfFiles];
            for (int i = 0; i < numberOfFiles; i++)
            {
                manualEvents[i] = new ManualResetEvent(false);
            }
            bool reached = true;

            //线程1
            Task.Factory.StartNew(() =>
            {

                while (!cancelToken.IsCancellationRequested)
                {

                    if (reached)
                    {
                        manualResetEvent1.Set();//发给线程2
                        manualResetEvent2.Set();//发给线程3
                        Console.WriteLine("Start new turn-----------------------");
                    }
                   
                    Thread.Sleep(300);//定时控制，等待300ms
                    reached = WaitHandle.WaitAll(manualEvents,400,false);//等待线程2和线程3的情况
                    manualEvents[0].Reset();//将线程2发来的情况复位
                    manualEvents[1].Reset();//将线程3发来的情况复位
                }
            });

            //线程2
            Task.Factory.StartNew(() =>
            {
                var num = random.Next(10, 15);
               
                while (!cancelToken.IsCancellationRequested)
                {
                    manualResetEvent1.WaitOne();//等待线程1的通知
                    Thread.Sleep(200);
                    num = random.Next(10, 15);
                    Console.WriteLine($"Task1 is running, this is number {num} ");
                   
                    manualResetEvent1.Reset();//把线程1发来的通知标志复位
                    manualEvents[0].Set();//给线程1发送状况，表明采集完成
                }
            });

            //线程3
            Task.Factory.StartNew(() =>
            {
                var num = random.Next(5, 10);
                
                while (!cancelToken.IsCancellationRequested)
                {
                    manualResetEvent2.WaitOne();//等待线程1的通知
                    Thread.Sleep(100);
                    num = random.Next(5, 10);
                    Console.WriteLine($"Task2 is running, this is number {num}");
                    manualResetEvent2.Reset();//把线程1发来的通知标志复位
                    manualEvents[1].Set();//给线程1发送状况，表明采集完成
                }
            });

            Console.ReadLine();
            cancelToken.Cancel();
            Console.WriteLine("task cancelled");
            Console.ReadLine();
        }