c# ManualResetEvent WaitHandle 实现同步

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

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

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

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

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

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

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();
manualResetEvent2.Set();
Console.WriteLine("Start new turn-----------------------");
}

Thread.Sleep(300);
reached = WaitHandle.WaitAll(manualEvents,400,false);
manualEvents[0].Reset();
manualEvents[1].Reset();
}
});

//线程2
Task.Factory.StartNew(() =>
{
var num = random.Next(10, 15);

while (!cancelToken.IsCancellationRequested)
{
manualResetEvent1.WaitOne();
Thread.Sleep(200);
num = random.Next(10, 15);
Console.WriteLine($"Task1 is running, this is number {num} ");

manualResetEvent1.Reset();
manualEvents[0].Set();
}
});

//线程3
Task.Factory.StartNew(() =>
{
var num = random.Next(5, 10);

while (!cancelToken.IsCancellationRequested)
{
manualResetEvent2.WaitOne();
Thread.Sleep(100);
num = random.Next(5, 10);
Console.WriteLine($"Task2 is running, this is number {num}");
manualResetEvent2.Reset();
manualEvents[1].Set();
}
});