Java 中锁机制怎么利用显式锁 ReentrantLock 的 newCondition() 创建多个等待队列以精准唤醒-java教程-PHP中文网

reentrantlock通过newcondition()创建多个独立condition实例，每个对应专属等待队列，实现按业务条件精准唤醒；必须在持锁状态下使用await/signal，并配合while循环防虚假唤醒。

java 中锁机制怎么利用显式锁 reentrantlock 的 newcondition() 创建多个等待队列以精准唤醒

Java 中利用 ReentrantLock 的 newCondition() 创建多个等待队列，核心在于：每个 Condition 实例对应一个独立的等待队列，从而实现按条件精准唤醒，避免 Object.wait()/notify() 那种“全唤醒再判断”的低效和不确定性。

一个锁配多个 Condition，各管各的等待队列

ReentrantLock 本身只维护一个同步队列（用于争抢锁），但它支持创建任意多个 Condition 对象。每个 Condition 内部持有独立的等待队列（FIFO），线程调用其 await() 就进入该队列，调用 signal() 或 signalAll() 就只唤醒这个队列里的线程。

不是“锁有多个队列”，而是“一个锁 + 多个 Condition → 多个逻辑上分离的等待队列”
不同业务条件（如“缓冲区非空”“缓冲区非满”）应使用不同的 Condition 实例
务必在持有锁的前提下创建和使用 Condition，否则抛 IllegalMonitorStateException

典型场景：生产者-消费者中的双条件精准控制

以有界队列为例，需区分“队列空时消费者等待”和“队列满时生产者等待”。用两个 Condition 可彻底解耦：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

class BoundedBuffer {
    private final ReentrantLock lock = new ReentrantLock();
    private final Condition notEmpty = lock.newCondition(); // 消费者等待队列
    private final Condition notFull  = lock.newCondition(); // 生产者等待队列
    private final List<object> buffer = new ArrayList();
    private final int capacity;

    BoundedBuffer(int capacity) { this.capacity = capacity; }

    void put(Object item) throws InterruptedException {
        lock.lock();
        try {
            while (buffer.size() == capacity)
                notFull.await(); // 进入 notFull 队列等待
            buffer.add(item);
            notEmpty.signal();   // 只唤醒一个在 notEmpty 队列里等的消费者
        } finally {
            lock.unlock();
        }
    }

    Object take() throws InterruptedException {
        lock.lock();
        try {
            while (buffer.isEmpty())
                notEmpty.await(); // 进入 notEmpty 队列等待
            Object item = buffer.remove(0);
            notFull.signal();     // 只唤醒一个在 notFull 队列里等的生产者
            return item;
        } finally {
            lock.unlock();
        }
    }
}</object>

关键细节与避坑点

精准唤醒依赖正确的条件判断和信号发送时机，常见错误包括：

用错 Condition 调用 signal()：比如消费者取完数据后调了 notEmpty.signal() 是对的，但若误调 notFull.signal() 就会唤醒生产者，导致逻辑错乱
虚假唤醒未防护：await() 可能无故返回（spurious wakeup），必须用 while 循环重检条件，不能用 if
signal() vs signalAll()：单个线程满足条件时用 signal() 更高效；多个线程可能同时满足（如批量插入后多个消费者都可取）才用 signalAll()
Condition 必须由同一把锁创建：不同 ReentrantLock 实例创建的 Condition 互不兼容，不能混用