C#相当于java的wait和notify

C#中的wait和notify方法相当于Java中的wait和notify方法吗？在本篇文章中，我们将探讨C#和Java之间的这些方法的相似之处以及它们在编程中的使用。我们还将提供一些案例代码来帮助读者更好地理解这些方法的功能和用法。

java
class Message {
    private String message;
    public synchronized String getMessage() {
        while (message == null) {
            try {
                wait();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                return null;
            }
        }
        String msg = message;
        message = null;
        notifyAll();
        return msg;
    }
    public synchronized void setMessage(String message) {
        while (this.message != null) {
            try {
                wait();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                return;
            }
        }
        this.message = message;
        notifyAll();
    }
}
class Producer implements Runnable {
    private Message message;
    public Producer(Message message) {
        this.message = message;
    }
    @Override
    public void run() {
        String[] messages = {"Hello", "World", "Goodbye"};
        for (String msg : messages) {
            message.setMessage(msg);
            System.out.println("Produced: " + msg);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                return;
            }
        }
        message.setMessage(null); // Signal termination
    }
}
class Consumer implements Runnable {
    private Message message;
    public Consumer(Message message) {
        this.message = message;
    }
    @Override
    public void run() {
        String msg = message.getMessage();
        while (msg != null) {
            System.out.println("Consumed: " + msg);
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                return;
            }
            msg = message.getMessage();
        }
    }
}
public class WaitNotifyExample {
    public static void main(String[] args) {
        Message message = new Message();
        Thread producerThread = new Thread(new Producer(message));
        Thread consumerThread = new Thread(new Consumer(message));
        producerThread.start();
        consumerThread.start();
    }
}

csharp
using System;
using System.Threading;
class Message {
    private string message;
    private object lockObj = new object();
    public string GetMessage() {
        lock (lockObj) {
            while (message == null) {
                Monitor.Wait(lockObj);
            }
            string msg = message;
            message = null;
            Monitor.PulseAll(lockObj);
            return msg;
        }
    }
    public void SetMessage(string message) {
        lock (lockObj) {
            while (this.message != null) {
                Monitor.Wait(lockObj);
            }
            this.message = message;
            Monitor.PulseAll(lockObj);
        }
    }
}
class Producer {
    private Message message;
    public Producer(Message message) {
        this.message = message;
    }
    public void Run() {
        string[] messages = {"Hello", "World", "Goodbye"};
        foreach (string msg in messages) {
            message.SetMessage(msg);
            Console.WriteLine("Produced: " + msg);
            Thread.Sleep(1000);
        }
        message.SetMessage(null); // Signal termination
    }
}
class Consumer {
    private Message message;
    public Consumer(Message message) {
        this.message = message;
    }
    public void Run() {
        string msg = message.GetMessage();
        while (msg != null) {
            Console.WriteLine("Consumed: " + msg);
            Thread.Sleep(1000);
            msg = message.GetMessage();
        }
    }
}
public class WaitNotifyExample {
    public static void Main(string[] args) {
        Message message = new Message();
        Thread producerThread = new Thread(new Producer(message).Run);
        Thread consumerThread = new Thread(new Consumer(message).Run);
        producerThread.Start();
        consumerThread.Start();
    }
}