Java并发编程中的Condition与等待通知机制-java教程-PHP中文网

Condition是java.util.concurrent.locks中需配合ReentrantLock使用的多条件等待工具，区别于Object的wait/notify在于：一个锁可绑定多个Condition实现语义分离，而synchronized仅有一个隐式队列；await/signal必须在lock后unlock前调用，且需用while防虚假唤醒。

java并发编程中的condition与等待通知机制

Condition 是什么，和 Object 的 wait/notify 有什么区别

Condition 是 java.util.concurrent.locks 包中用于替代 Object.wait() / Object.notify() 的协作工具，必须配合 ReentrantLock 使用。它不是独立存在的，也不能在 synchronized 块里用 —— 这是第一个容易踩的坑。

核心区别在于：一个 ReentrantLock 可以绑定多个 Condition 实例，而 synchronized 块里的每个对象只有一个隐式等待队列。这意味着你可以按业务语义拆分等待逻辑，比如生产者用 notFull、消费者用 notEmpty，互不干扰。

wait()/notify() 必须在 synchronized 方法或块中调用，否则抛 IllegalMonitorStateException
Condition.await()/signal() 必须在 lock.lock() 之后、lock.unlock() 之前调用，否则抛 IllegalMonitorStateException
notifyAll() 是“唤醒全部”，但无法指定唤醒哪类线程；Condition.signalAll() 只唤醒该 Condition 上等待的线程，更精准

如何正确创建和使用 Condition 实例

不能直接 new Condition，必须通过 Lock.newCondition() 获取。常见错误是把同一个 Condition 实例混用于不同条件判断，或者在未持有锁时调用 await()。

典型写法是为每种等待场景定义独立的 Condition 变量：

private final ReentrantLock lock = new ReentrantLock();
private final Condition notEmpty = lock.newCondition();
private final Condition notFull = lock.newCondition();

// 消费者等待非空
public void take() throws InterruptedException {
    lock.lock();
    try {
        while (queue.isEmpty()) {
            notEmpty.await(); // 释放锁并进入等待
        }
        // ...取元素
        notFull.signal(); // 通知生产者可以继续放了
    } finally {
        lock.unlock();
    }
}