ManualResetEvent
是 C# 中的一个同步原语,它用于在多线程环境中控制对共享资源的访问
ManualResetEvent
的工作原理如下:
初始化:创建一个 ManualResetEvent
对象时,可以选择将其设置为初始状态为 “signaled”(已信号)或 “non-signaled”(未信号)。如果初始状态为 “signaled”,则一个或多个线程可以立即通过 WaitOne()
方法获取到信号并继续执行;如果初始状态为 “non-signaled”,则线程必须等待直到其他线程调用 Set()
方法将其设置为 “signaled” 状态。
等待(WaitOne):当一个线程想要访问共享资源时,它需要调用 ManualResetEvent
对象的 WaitOne()
方法。如果当前状态为 “non-signaled”,则该线程将被阻塞,直到其他线程调用 Set()
方法将其设置为 “signaled” 状态。如果有多个线程在等待,只有一个线程会被唤醒并继续执行,其他线程仍然处于阻塞状态。
设置(Set):当一个线程完成了对共享资源的访问并希望通知其他等待的线程时,它需要调用 ManualResetEvent
对象的 Set()
方法。这将把对象的状态从 “non-signaled” 设置为 “signaled”,唤醒一个或多个等待的线程。
重置(Reset):有时,你可能希望将 ManualResetEvent
对象的状态从 “signaled” 设置回 “non-signaled”,以便其他线程可以继续等待。这可以通过调用 Reset()
方法来实现。需要注意的是,在调用 Reset()
方法之前,没有其他线程应该调用 WaitOne()
方法,否则它们将被阻塞。
下面是一个简单的示例,展示了如何使用 ManualResetEvent
来同步两个线程:
using System;
using System.Threading;
class Program
{
static ManualResetEvent _event = new ManualResetEvent(false); // 初始状态为 "non-signaled"
static void Main()
{
Thread t1 = new Thread(DoWork);
Thread t2 = new Thread(DoWork);
t1.Start();
t2.Start();
t1.Join();
t2.Join();
}
static void DoWork()
{
Console.WriteLine("Thread 1 waiting for event...");
_event.WaitOne(); // 等待事件被设置为 "signaled"
Console.WriteLine("Thread 1 has access to the shared resource.");
Console.WriteLine("Thread 2 waiting for event...");
_event.WaitOne(); // 等待事件被设置为 "signaled"
Console.WriteLine("Thread 2 has access to the shared resource.");
}
}
在这个示例中,我们创建了两个线程 t1
和 t2
,它们都需要访问共享资源。我们使用一个 ManualResetEvent
对象 _event
来同步这两个线程。当线程 t1
或 t2
访问共享资源之前,它们会调用 WaitOne()
方法等待事件被设置为 “signaled” 状态。当一个线程完成对共享资源的访问后,它会调用 Set()
方法将事件设置为 “signaled” 状态,从而通知其他等待的线程可以继续执行。