温馨提示×

C# ManualResetEvent怎样实现多线程协作

c#
小樊
84
2024-10-12 07:58:00
栏目: 编程语言

ManualResetEvent 是 C# 中的一个同步原语,它允许一个或多个线程等待,直到另一个线程设置事件。要实现多线程协作,你可以使用 ManualResetEvent 来同步线程的执行。

下面是一个简单的示例,展示了如何使用 ManualResetEvent 实现两个线程的协作:

using System;
using System.Threading;

class Program
{
    static ManualResetEvent _event1 = new ManualResetEvent(false);
    static ManualResetEvent _event2 = new ManualResetEvent(false);

    static void Thread1()
    {
        Console.WriteLine("Thread1 开始执行");
        _event1.WaitOne(); // 等待线程2发出信号
        Console.WriteLine("线程2已发出信号,Thread1继续执行");
        _event2.Set(); // 设置事件,唤醒等待的线程3
        Console.WriteLine("Thread1 已设置事件,线程3将被唤醒");
    }

    static void Thread2()
    {
        Console.WriteLine("Thread2 开始执行");
        Thread.Sleep(1000); // 模拟耗时操作
        Console.WriteLine("Thread2 执行完毕,准备发出信号");
        _event1.Set(); // 设置事件,唤醒等待的线程1
        Console.WriteLine("Thread2 已设置事件,线程1将被唤醒");
    }

    static void Thread3()
    {
        Console.WriteLine("Thread3 开始执行");
        _event2.WaitOne(); // 等待线程1发出信号
        Console.WriteLine("线程1已发出信号,Thread3继续执行");
        Console.WriteLine("Thread3 执行完毕");
    }

    static void Main(string[] args)
    {
        Thread thread1 = new Thread(new ThreadStart(Thread1));
        Thread thread2 = new Thread(new ThreadStart(Thread2));
        Thread thread3 = new Thread(new ThreadStart(Thread3));

        thread1.Start();
        thread2.Start();
        thread3.Start();

        thread1.Join();
        thread2.Join();
        thread3.Join();

        Console.WriteLine("所有线程执行完毕");
    }
}

在这个示例中,我们创建了三个线程:Thread1Thread2Thread3Thread1Thread3 需要等待 Thread2 的信号才能继续执行,而 Thread2 在执行完耗时操作后需要发出信号以唤醒 Thread1

我们使用两个 ManualResetEvent 对象 _event1_event2 来实现线程间的同步。_event1 用于同步 Thread1Thread2_event2 用于同步 Thread2Thread3

Thread1Thread3 中,我们使用 WaitOne() 方法等待相应的事件被设置。在 Thread2 中,我们使用 Set() 方法设置事件以唤醒等待的线程。

最后,在 Main 方法中,我们启动这三个线程并等待它们执行完毕。

0