ReentrantLocknewCondition创建多等待队列方法

ReentrantLock 通过 newCondition() 方法支持为同一把锁创建多个独立的 Condition 实例，每个 Condition 拥有专属等待队列，从而实现按业务状态（如“非空”“非满”）精准分组等待与唤醒，彻底摆脱 synchronized 只能依赖单一隐式等待队列的限制；这种机制在生产者-消费者等典型场景中展现出强大解耦能力——读线程只响应 notEmpty 信号，写线程仅受 notFull 控制，共享锁资源却不互相干扰，配合循环条件检查、正确加解锁和 await/signal 使用规范，既保障线程安全，又大幅提升并发协作的灵活性与可靠性。

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();
private final Condition notEmpty = lock.newCondition();
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

本篇关于《ReentrantLocknewCondition创建多等待队列方法》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！