// 消費(fèi)者
synchronized (lock) {
    while (conditionNotMet) {           // 必須用 while，不是 if?。ǚ乐固摷賳拘眩?
        lock.wait();                    // 釋放鎖并等待
    }
    // 條件滿足，消費(fèi)
    doConsume();
}

// 生產(chǎn)者
synchronized (lock) {
    // 生產(chǎn)
    doProduce();
    lock.notify();          // 或 notifyAll()
    // 離開 synchronized 塊后，被喚醒的線程才有機(jī)會搶鎖
}

// 錯誤寫法（極易出問題）
if (queue.isEmpty()) {
    lock.wait();   // 被虛假喚醒后，可能直接往下執(zhí)行，而隊(duì)列還是空的
}

// 正確寫法（生產(chǎn)環(huán)境唯一推薦）
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("隊(duì)列已滿，生產(chǎn)者等待...");
                            lock.wait();
                        }
                        int item = (int) (Math.random() * 100);
                        queue.offer(item);
                        System.out.println("生產(chǎn): " + item + "，當(dāng)前大小: " + queue.size());
                        lock.notifyAll();  // 喚醒所有等待的消費(fèi)者
                    }
                    Thread.sleep(500); // 模擬生產(chǎn)耗時
                }
            } 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("隊(duì)列為空，消費(fèi)者等待...");
                            lock.wait();
                        }
                        int item = queue.poll();
                        System.out.println("消費(fèi): " + item + "，當(dāng)前大小: " + queue.size());
                        lock.notifyAll();  // 喚醒可能等待的生產(chǎn)者
                    }
                    Thread.sleep(800); // 模擬消費(fèi)耗時
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }

    public static void main(String[] args) {
        ProducerConsumer pc = new ProducerConsumer();
        new Thread(pc.new Producer(), "生產(chǎn)者-1").start();
        new Thread(pc.new Consumer(), "消費(fèi)者-1").start();
        new Thread(pc.new Consumer(), "消費(fèi)者-2").start();
    }
}