Java中wait()和notify()的正确使用方式

// 消费者
synchronized (lock) {
    while (conditionNotMet) {           // 必须用 while，不是 if！（防止虚假唤醒）
        lock.wait();                    // 释放锁并等待
    }
    // 条件满足，消费
    doConsume();
}

// 生产者
synchronized (lock) {
    // 生产
    doProduce();
    lock.notify();          // 或 notifyAll()
    // 离开 synchronized 块后，被唤醒的线程才有机会抢锁
}

// 错误写法（极易出问题）
if (queue.isEmpty()) {
    lock.wait();   // 被虚假唤醒后，可能直接往下执行，而队列还是空的
}

// 正确写法（生产环境唯一推荐）
while (queue.isEmpty()) {
    lock.wait();
}

import java.util.LinkedList;
import java.util.Queue;

public class ProducerConsumer {

    private final Queue<Integer> queue = new LinkedList<>();
    private final int MAX_SIZE = 10;
    private final Object lock = new Object();

    class Producer implements Runnable {
        @Override
        public void run() {
            try {
                while (true) {
                    synchronized (lock) {
                        while (queue.size() == MAX_SIZE) {
                            System.out.println("队列已满，生产者等待...");
                            lock.wait();
                        }
                        int item = (int) (Math.random() * 100);
                        queue.offer(item);
                        System.out.println("生产: " + item + "，当前大小: " + queue.size());
                        lock.notifyAll();  // 唤醒所有等待的消费者
                    }
                    Thread.sleep(500); // 模拟生产耗时
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }

    class Consumer implements Runnable {
        @Override
        public void run() {
            try {
                while (true) {
                    synchronized (lock) {
                        while (queue.isEmpty()) {
                            System.out.println("队列为空，消费者等待...");
                            lock.wait();
                        }
                        int item = queue.poll();
                        System.out.println("消费: " + item + "，当前大小: " + queue.size());
                        lock.notifyAll();  // 唤醒可能等待的生产者
                    }
                    Thread.sleep(800); // 模拟消费耗时
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }

    public static void main(String[] args) {
        ProducerConsumer pc = new ProducerConsumer();
        new Thread(pc.new Producer(), "生产者-1").start();
        new Thread(pc.new Consumer(), "消费者-1").start();
        new Thread(pc.new Consumer(), "消费者-2").start();
    }
}