Java多线程生产者-消费者模型运行结果不符预期的原因咨询

1. 条件判断用if而非while，唤醒后未重新校验状态 #

这是最常见的错误。如果你的代码里用if判断队列是否满/空，比如：

// 生产者代码示例（错误写法）
synchronized (lock) {
    if (queue.size() == MAX_SIZE) {
        lock.wait();
    }
    queue.put(product);
    System.out.println("Produced:" + product);
    lock.notifyAll();
}

当wait()被notifyAll()唤醒后，线程会直接跳过if判断，执行后续的生产逻辑。假设此时队列依然是满的（比如多个生产者被同时唤醒），就会出现连续生产的情况；同理，如果消费者用if判断队列是否为空，可能在队列空的时候被唤醒，直接执行消费逻辑，就会出现消费先于生产的异常输出。

正确的写法必须用while循环，确保每次被唤醒后都重新校验队列状态：

// 生产者代码示例（正确写法）
synchronized (lock) {
    while (queue.size() == MAX_SIZE) {
        lock.wait();
    }
    queue.put(product);
    System.out.println("Produced:" + product);
    lock.notifyAll();
}

2. notifyAll()唤醒所有等待线程，线程竞争存在随机性 #

调用notifyAll()会唤醒所有在该锁上等待的线程，这些线程会同时竞争锁资源。比如生产者生产完唤醒所有线程后，可能刚好另一个生产者线程先抢到锁，此时队列还没满，就会继续生产，导致连续生产的情况；同理，消费者线程也可能在生产者还未完成生产时，先抢到锁（比如初始状态下），但如果用了while判断，它会进入wait()，不会出现消费先于生产的问题——但如果没正确判断，就会直接执行消费逻辑。

3. 线程调度的天然随机性 #

Java线程的调度由JVM和底层操作系统决定，即使代码逻辑正确，线程获得CPU时间片的顺序也无法完全控制。比如一个生产者线程生产完后，可能刚好再次获得CPU时间片，抢到锁后发现队列还能生产，就会继续执行生产逻辑，出现连续生产的情况。这种属于正常的调度现象，严格的交替执行并不是多线程环境下的必然结果，除非通过额外的同步逻辑强制控制，但这通常没必要。

4. 锁的释放时机问题 #

wait()方法会立即释放锁，但notifyAll()不会——只有当前线程退出同步代码块时，锁才会被释放。比如生产者线程在生产完调用notifyAll()后，并不会立刻释放锁，它会继续执行同步块内的后续代码（比如循环判断是否继续生产），直到队列满了调用wait()才会释放锁。这就可能导致同一个生产者连续生产多个产品，直到队列满才会让消费者线程有机会执行。

内容的提问来源于stack exchange，提问作者Archsx