Java 并发编程中的等待唤醒机制：揭开多线程同步的奥秘

后端

2023-12-02 09:59:42

理解等待唤醒机制

等待唤醒机制是 Java 中一种用于实现线程间通信的原语。它允许一个线程（等待线程）等待另一个线程（通知线程）发出的信号，然后继续执行。

wait()： 等待线程调用 wait() 方法后，它会释放锁并进入等待状态，直到收到 notify() 或 notifyAll() 信号。
notify()： 通知线程调用 notify() 方法后，它会随机唤醒一个正在等待该对象的线程。
notifyAll()： 通知线程调用 notifyAll() 方法后，它会唤醒所有正在等待该对象的线程。

同步和锁

wait() 和 notify() 方法只能在同步上下文中使用，这意味着它们只能在持有对象锁时调用。锁是一种机制，它允许一次只允许一个线程访问共享资源。在 Java 中，synchronized 用于获取和释放锁。

使用等待唤醒机制

以下代码段演示了如何使用等待唤醒机制在两个线程之间实现通信：

public class WaitNotifyExample {
    private static Object lock = new Object();
    private static boolean dataAvailable = false;

    public static void main(String[] args) {
        Thread producer = new Thread(() -> {
            synchronized (lock) {
                while (!dataAvailable) {
                    try {
                        lock.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("Data available: " + dataAvailable);
            }
        });

        Thread consumer = new Thread(() -> {
            synchronized (lock) {
                dataAvailable = true;
                lock.notify();
            }
        });

        producer.start();
        consumer.start();
    }
}