Java 阻塞队列怎么通过 Condition 实现精准唤醒-java教程-PHP中文网

java阻塞队列通过reentrantlock配两个condition实现精准唤醒：notempty供消费者等待非空，notfull供生产者等待非满，避免synchronized单等待队列的混淆与无效唤醒。

java 阻塞队列怎么通过 condition 实现精准唤醒

Java 阻塞队列（如 ArrayBlockingQueue、LinkedBlockingQueue）底层并不直接暴露 Condition 给用户，但其内部正是通过 ReentrantLock + Condition 实现“精准唤醒”的——即：生产者只唤醒等待消费的线程，消费者只唤醒等待生产的线程，避免无差别 notifyAll() 带来的无效调度。

为什么需要 Condition 而不是 synchronized？

synchronized 只有一个隐式等待队列和一个 wait()/notify() 机制，无法区分“等数据”和“等空间”两类等待者。而阻塞队列需同时支持：

消费者在空时阻塞 → 等待“非空”条件
生产者在满时阻塞 → 等待“非满”条件

用一个锁配两个独立 Condition，就能让这两类线程分别挂起、分别唤醒，互不干扰。

ArrayBlockingQueue 中的两个 Condition 实例

以 ArrayBlockingQueue 为例，它在构造时创建：

final ReentrantLock lock = new ReentrantLock();
private final Condition notEmpty = lock.newCondition(); // 消费者等待这个
private final Condition notFull  = lock.newCondition(); // 生产者等待这个

关键逻辑节选：

javascript-pro

专注现代 ECMAScript、异步编程、性能优化和全栈的 JavaScript 专家，适用于现代开发

下载

put(E e)：加锁后，若队列满，调用 notFull.await()；插入成功后，调用 notEmpty.signal() 唤醒一个等待消费的线程
take()：加锁后，若队列空，调用 notEmpty.await()；取走元素后，调用 notFull.signal() 唤醒一个等待生产的线程

注意：用的是 signal() 而非 signalAll()，因为只需唤醒一个对应角色的线程，减少上下文切换开销。

自己手写精准唤醒队列的关键点

若想基于 ReentrantLock 和 Condition 实现简易阻塞队列，需注意：

所有共享状态访问（如 count、items[]）必须在锁保护下进行
判断条件必须用 while 循环包裹 await()，防止虚假唤醒
signal() 必须在修改状态后、释放锁前调用，否则唤醒的线程可能立即再次 await
不要在持有锁时执行耗时操作（如 I/O），否则会阻塞其他线程

示例片段（简化）：

public void put(E e) throws InterruptedException {
    lock.lock();
    try {
        while (count == items.length) {
            notFull.await(); // 等待有空位
        }
        items[putIndex] = e;
        if (++putIndex == items.length) putIndex = 0;
        ++count;
        notEmpty.signal(); // 唤醒一个消费者
    } finally {
        lock.unlock();
    }
}