C#中的ManualResetEvent类如何使用

K-seo • 2024-02-03 05:52 • 网站运维 • 95 views

在.NET Framework中，ManualResetEvent类是一个同步原语，用于线程间的通信，它允许一个或多个等待的线程继续执行，当某个条件得到满足时。ManualResetEvent可以被设置为非信号状态（默认）或信号状态，当ManualResetEvent处于信号状态时，所有等待该事件的线程都将被允许继续执行；如果ManualResetEvent处于非信号状态，则等待的线程将会阻塞，直到事件被显式地设置为信号状态。

使用场景

ManualResetEvent通常用于以下几种情况：

1、当你想让一个线程等待另一个线程完成某项任务时。

2、当你需要协调多个线程以同步访问共享资源时。

3、当你需要实现生产者-消费者模式时。

如何使用ManualResetEvent

下面是使用ManualResetEvent的基本步骤：

创建 ManualResetEvent 对象

创建一个ManualResetEvent实例时，可以指定其初始状态是已信号状态还是未信号状态。

ManualResetEvent manualResetEvent = new ManualResetEvent(false); // 初始为非信号状态

等待事件信号

线程可以通过调用WaitOne()方法来等待ManualResetEvent的信号。

manualResetEvent.WaitOne(); // 线程将在这里等待，直到收到信号

还有重载版本的WaitOne，允许你指定超时时间。

bool receivedSignal = manualResetEvent.WaitOne(5000); // 等待5秒，如果在5秒内没有收到信号，则返回false

发送事件信号

通过调用Set()方法，可以将ManualResetEvent设置为信号状态，从而允许等待的线程继续执行。

manualResetEvent.Set(); // 发送信号，唤醒等待的线程

ManualResetEvent还有一个Reset()方法，可以将事件状态重新设置为非信号状态。

manualResetEvent.Reset(); // 重置事件状态为非信号状态

关闭事件

一旦完成使用，应该通过调用Close()方法来释放与ManualResetEvent相关的资源。

manualResetEvent.Close(); // 关闭事件并释放资源

示例代码

下面是一个使用ManualResetEvent的简单示例，其中一个线程生成数据，另一个线程消费数据。

using System;
using System.Threading;
class Program
{
    static ManualResetEvent manualResetEvent = new ManualResetEvent(false);
    static bool dataReady = false;
    static void Main()
    {
        Thread producerThread = new Thread(Producer);
        Thread consumerThread = new Thread(Consumer);
        producerThread.Start();
        consumerThread.Start();
    }
    static void Producer()
    {
        Console.WriteLine("Producer is producing data...");
        Thread.Sleep(2000); // 模拟数据生成过程
        dataReady = true;
        Console.WriteLine("Data is ready!");
        manualResetEvent.Set(); // 发送信号给消费者线程
    }
    static void Consumer()
    {
        Console.WriteLine("Consumer is waiting for data...");
        manualResetEvent.WaitOne(); // 等待生产者信号
        Console.WriteLine("Consumer received the signal, consuming data...");
        dataReady = false;
        manualResetEvent.Reset(); // 重置事件状态
    }
}