怎么利用 Object.wait() 和 notify() 实现多线程间的经典生产者消费者协作-java教程-PHP中文网

不能直接在普通对象上调用wait()和notify()，因为它们必须在synchronized块中执行且当前线程需持有该对象锁，否则抛illegalmonitorstateexception；正确做法是用synchronized(buffer)包裹所有相关逻辑，wait()须置于while循环中防虚假唤醒，notifyall()确保不遗漏等待方。

怎么利用 object.wait() 和 notify() 实现多线程间的经典生产者消费者协作

为什么不能直接在普通对象上调用 `wait()` 和 `notify()`

因为这两个方法必须在同步上下文中执行——也就是当前线程必须持有该对象的监视器锁。否则会抛出 IllegalMonitorStateException。常见错误是忘了加 synchronized 块，或者锁的对象和调用 wait() 的对象不一致。

正确做法是：所有对共享缓冲区的操作（读/写/等待）都必须在同一个锁对象上同步，通常就是缓冲区实例本身。

用 synchronized(buffer) 包裹所有涉及 wait()/notify() 的逻辑
避免用 this 或新创建的锁对象，否则生产者和消费者无法看到彼此的通知
wait() 一定要放在 while 循环里判断条件，不能用 if——防止虚假唤醒

如何用 `wait()`/`notify()` 实现带边界检查的阻塞队列

核心是把“缓冲区满”和“缓冲区空”作为两个独立等待条件，通过同一个锁对象协调。

示例中用一个 ArrayList 模拟固定容量队列，生产者在满时 wait()，消费者在空时 wait()；任一操作完成后都调用 notifyAll()（不是 notify()），确保不会漏掉等待方。

public class BoundedBuffer {
    private final List<string> buffer = new ArrayList();
    private final int capacity = 5;

    public void produce(String item) throws InterruptedException {
        synchronized (buffer) {
            while (buffer.size() == capacity) {
                buffer.wait(); // 等待有空间
            }
            buffer.add(item);
            buffer.notifyAll(); // 唤醒可能等待取数据的消费者
        }
    }

    public String consume() throws InterruptedException {
        synchronized (buffer) {
            while (buffer.isEmpty()) {
                buffer.wait(); // 等待有数据
            }
            String item = buffer.remove(0);
            buffer.notifyAll(); // 唤醒可能等待放数据的生产者
            return item;
        }
    }
}</string>