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” 状态,从而通知其他等待的线程可以继续执行。