reentrantlock 的 newcondition() 可创建多个独立 condition 实例,各维护专属等待队列,实现按业务逻辑分组等待与精准唤醒;如 notempty 和 notfull 用于生产者-消费者场景,共享锁但唤醒互不干扰。

ReentrantLock 的 newCondition() 方法可以为同一把锁创建多个独立的 Condition 实例,每个 Condition 对应一个等待队列。这让你能按不同业务逻辑或状态对线程进行分组等待和唤醒,避免传统 synchronized + wait/notify 只能有一个隐式等待队列的局限。
每个 Condition 独立维护自己的等待队列
调用多次 lock.newCondition() 得到的多个 Condition 对象互不干扰:
- 它们共享同一把锁(即同一个 ReentrantLock 实例),但各自有独立的等待队列
-
condition1.await()会让线程进入condition1的队列;condition2.signal()只唤醒condition2队列里的线程 - 不同 Condition 的 await/signal 操作完全隔离,不会误唤醒、也不会互相阻塞
典型使用场景:按条件分类等待
比如实现一个带“读取就绪”和“写入就绪”两种等待需求的缓冲区:
-
notEmpty:当缓冲区为空时,读线程在此 condition 上 await;写入后调用notEmpty.signal() -
notFull:当缓冲区满时,写线程在此 condition 上 await;读出后调用notFull.signal() - 两个 condition 共享同一把 lock,但等待/唤醒逻辑完全解耦
关键操作步骤(代码逻辑示意)
以生产者-消费者为例:
- 定义锁和多个 condition:
private final ReentrantLock lock = new ReentrantLock();<br>private final Condition notEmpty = lock.newCondition();<br>private final Condition notFull = lock.newCondition();
- 消费者取数据时:
lock.lock(); try { while (isEmpty()) notEmpty.await(); /* 取数据 */ } finally { lock.unlock(); } - 生产者放数据时:
lock.lock(); try { while (isFull()) notFull.await(); /* 放数据 */ notEmpty.signal(); } finally { lock.unlock(); } - 注意:每次 await 前必须在循环中检查条件(防止虚假唤醒),且必须在持有锁时调用 await / signal
注意事项
使用多个 Condition 时需注意:
- 每个
Condition必须由同一个ReentrantLock实例创建,不能跨锁混用 -
signal()唤醒一个等待线程,signalAll()唤醒全部;选择取决于是否需要公平唤醒或批量响应 - await 会自动释放锁,并在被唤醒重新获取锁后才返回;所以 await 后仍需在 try-finally 中确保 unlock
- 不要在未持有锁时调用 condition 的任何方法,否则抛
IllegalMonitorStateException










