关于C#中Monitor的wait/pulse的理解

news2024/11/28 14:36:18

wait：表示释放对象上的锁并阻止当前线程，直到它重新获取该锁。

pulse：表示通知等待队列中的线程锁定对象状态的更改。

当线程调用 Wait 时，它会释放对象上的锁并进入对象的等待队列。对象的就绪队列中的下一个线程 (如果有一个) 获取锁并独占使用该对象。调用 Wait 的所有线程都保留在等待队列中，直到它们收到来自 Pulse 或 PulseAll 的信号，由锁的所有者发送。如果 Pulse 发送，则只会影响等待队列头部的线程。如果 PulseAll 发送，则等待对象的所有线程都会受到影响。收到信号后，一个或多个线程离开等待队列并进入就绪队列。允许就绪队列中的线程重新获取锁。

实例1：Wait(object);

 public class MonitorTest
 {

     private object _lock = new object();


     public void FuncA()
     {

         lock (_lock)
         {
             Console.WriteLine("进入函数A");

             Monitor.Wait(_lock);
 
             Console.WriteLine("退出函数A");

         }

     }

     public void FuncB()
     {
         Thread.Sleep(300);

         lock (_lock)
         {
             Console.WriteLine("进入函数B");

             Thread.Sleep(3000);
             Monitor.Pulse(_lock);
 
             Thread.Sleep(3000);
             Console.WriteLine("退出函数B");
         }
     }


 }


调用：

MonitorTest monitorTest = new MonitorTest();
Task.Run(() => monitorTest.FuncA());
Task.Run(() => monitorTest.FuncB());

首先线程A通过wait方法释放锁，让线程B获取锁后成功开始执行，线程A进入等待队列，线程B执行过程中不再需要锁定对象后，则会调用pulse发送释放锁的信号，让收到信号的线程A从等待队列进入就绪队列，当线程B执行完成释放锁后，线程A重新获得锁，继续执行。

可以看到在线程B中发出Pulse信号后，线程A收到信号，进入就绪队列，此时线程B还没有释放锁，直到线程完成3s等待后，线程A才重新获取锁，wait(object)才返回。

说明1：发出pulse信号并不是释放锁，只是给等待队列中发送一个信号，收到信号的等待线程就会移动到就绪队列。

说明2：收到信号的Wait(object);不会立即返回，必须等到重新获取到锁后，才会返回，继续往下执行。如果收不到pulse信号，此等待将无限期的等待下去。

实例2：wait(object, int32);

此函数会在指定的时间内等待信号，如果超时则会自动进入就绪线程。当重新获取锁返回后，返回值为fasle.表示未在指定时间内获取锁，否则返回true.

public class MonitorTest
{

    private object _lock = new object();

    public void FuncA()
    {

        lock (_lock)
        {
            Console.WriteLine("进入函数A");

            bool flag = false;

            while (!flag)
            {
                flag = Monitor.Wait(_lock, 1000);
                Console.WriteLine("是否真实信号:" + flag);
            }

            Console.WriteLine("是否真实信号:" + flag);

            Console.WriteLine("退出函数A");

        }

    }

    public void FuncB()
    {
        Thread.Sleep(300);

        lock (_lock)
        {
            Console.WriteLine("进入函数B");

            Thread.Sleep(3000);
            //Monitor.Pulse(_lock);
 
            Console.WriteLine("退出函数B");
        }
    }


}



调用：
MonitorTest monitorTest = new MonitorTest();
Task.Run(() => monitorTest.FuncA());
Task.Run(() => monitorTest.FuncB());