news 2026/4/23 17:25:01

深入浅出Java Condition 的await和signal机制(一)

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
深入浅出Java Condition 的await和signal机制(一)
每个对象都可以调用 Object 的 wait/notify 方法来实现等待/通知机制。而 Condition 接口也提供了类似的方法。
Condition 接口一共提供了以下 7 个方法:
  • await():线程等待直到被通知或者中断。类似于Object.wait()
  • awaitUninterruptibly():线程等待直到被通知,即使在等待时被中断也不会返回。没有与之对应的 Object 方法。
  • await(long time, TimeUnit unit):线程等待指定的时间,或被通知,或被中断。类似于Object.wait(long timeout),但提供了更灵活的时间单位。
  • awaitNanos(long nanosTimeout):线程等待指定的纳秒时间,或被通知,或被中断。没有与之对应的 Object 方法。
  • awaitUntil(Date deadline):线程等待直到指定的截止日期,或被通知,或被中断。没有与之对应的 Object 方法。
  • signal():唤醒一个等待的线程。类似于Object.notify()
  • signalAll():唤醒所有等待的线程。类似于Object.notifyAll()
以下是Object 类的主要方法,我们来做一下对比:
  • wait():线程等待直到被通知或者中断。
  • wait(long timeout):线程等待指定的时间,或被通知,或被中断。
  • wait(long timeout, int nanos):线程等待指定的时间,或被通知,或被中断。
  • notify():唤醒一个等待的线程。
  • notifyAll():唤醒所有等待的线程。

Condition 源码分析

要想深入理解 Condition 的实现原理,就需要挖掘一下 Condiiton 的源码。
创建一个 Condition 对象可以通过lock.newCondition()来创建,这个方法实际上会 new 一个ConditionObject的对象,ConditionObject 是 AQS 的一个内部类,我们就拿 ReentrantLock 来举例说明吧。
public class ReentrantLock implements Lock, java.io.Serializable { abstract static class Sync extends AbstractQueuedSynchronizer { final ConditionObject newCondition() { return new ConditionObject(); } } public Condition newCondition() { return sync.newCondition(); } }
AQS 内部维护了一个先进先出(FIFO)的双端队列,并使用了两个引用 head 和 tail 用于标识队列的头部和尾部。
Condition 内部也使用了同样的方式,内部维护了一个先进先出(FIFO)的单向队列,我们把它称为等待队列。
所有调用 await 方法的线程都会加入到等待队列中,并且线程状态均为等待状态。firstWaiter 指向首节点,lastWaiter 指向尾节点,源码如下:
public class ConditionObject implements Condition, java.io.Serializable { private static final long serialVersionUID = 1173984872572414699L; /** First node of condition queue. */ private transient Node firstWaiter; /** Last node of condition queue. */ private transient Node lastWaiter; }
Node 中的 nextWaiter 指向队列中的下一个节点。并且进入到等待队列的 Node 节点状态都会被设置为 CONDITION。
同时还有一点需要注意:我们可以多次调用newCondition()方法创建多个 Condition 对象,也就是一个 lock 可以持有多个等待队列。
而如果是 Object 方式的话,就只能有一个同步队列和一个等待队列。
因此,ReentrantLock 等 AQS 是可以持有一个同步队列和多个等待队列的,new 多个 Condition 就行了。示意图如下:
AQS持有多个Condition
持有多个等待队列的好处是什么呢?我们可以通过下面这个例子来说明:
public class BoundedBuffer<T> { private final LinkedList<T> buffer; // 使用 LinkedList 作为缓冲区 private final int capacity; // 缓冲区最大容量 private final ReentrantLock lock; // 互斥锁 private final Condition notEmpty; // 缓冲区非空条件 private final Condition notFull; // 缓冲区非满条件 public BoundedBuffer(int capacity) { this.capacity = capacity; this.buffer = new LinkedList<>(); this.lock = new ReentrantLock(); this.notEmpty = lock.newCondition(); this.notFull = lock.newCondition(); } // 放入一个元素 public void put(T item) throws InterruptedException { lock.lock(); try { // 如果缓冲区满,等待 while (buffer.size() == capacity) { notFull.await(); } buffer.add(item); // 通知可能正在等待的消费者 notEmpty.signal(); } finally { lock.unlock(); } } // 取出一个元素 public T take() throws InterruptedException { lock.lock(); try { // 如果缓冲区空,等待 while (buffer.isEmpty()) { notEmpty.await(); } T item = buffer.removeFirst(); // 通知可能正在等待的生产者 notFull.signal(); return item; } finally { lock.unlock(); } } }
考虑这个简单的有界缓冲区 BoundedBuffer,其中生产者放入元素,消费者取出元素。我们将使用两个 Condition:一个表示缓冲区不为空(用于消费者等待),另一个表示缓冲区不满(用于生产者等待)。
生产者调用 put 方法放入元素,如果缓冲区已满,则等待 notFull 条件。消费者调用 take 方法取出元素,如果缓冲区为空,则等待 notEmpty 条件。当一个元素被放入或取出时,相应的条件会发出信号,唤醒等待的线程。
使用多个 Condition 对象的主要优点是为锁提供了更细粒度的控制,可以实现更复杂的同步场景,比如上面提到的有界缓冲区。
版权声明: 本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若内容造成侵权/违法违规/事实不符,请联系邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
网站建设 2026/4/23 15:56:34

简单高效的一体化USB电源管理IC解决方案

电源IC ADI提供了多款简化USB线缆电源转换的器件&#xff0c;其中LTC3455实现了超高水平的功能集成度。LTC3455采用4mm4mmQFN封装&#xff0c;能够无缝管理交流适配器、USB线缆和锂离子电池之间的电源流&#xff0c;同时符合USB供电标准。此外&#xff0c;两个高效率同步降压转…

作者头像 李华
网站建设 2026/4/23 15:56:33

建议收藏:运维大佬都会用的Vim命令技巧

Vim作为一款强大的文本编辑器&#xff0c;是linux运维必会的技能。然而&#xff0c;对于初学者来说&#xff0c;可能只会一些简单的编辑命令。今天&#xff0c;我们将分享一些实用的Vim命令技巧和实用场景&#xff0c;帮助你快速提升运维效率&#xff0c;轻松驾驭Vim&#xff0…

作者头像 李华
网站建设 2026/4/23 14:32:02

什么是分布式内存数据库?它为何性能高?

分布式内存数据库正成为现代高并发、低延迟应用的核心基础设施。它通过将数据存储在多个节点的内存中&#xff0c;并借助分布式架构实现横向扩展&#xff0c;从根本上解决了传统磁盘数据库在性能上的瓶颈。作为一名长期与数据打交道的架构师&#xff0c;我见证了这一技术如何从…

作者头像 李华
网站建设 2026/4/23 14:30:21

强烈安利10个降AIGC工具,千笔帮你轻松降AI率

AI降重工具&#xff1a;让论文更自然&#xff0c;更安全 在当前学术写作环境中&#xff0c;越来越多的高校和机构开始使用AIGC检测系统来评估论文的原创性。对于专科生而言&#xff0c;如何在保证论文质量的同时降低AI痕迹、避免查重率过高&#xff0c;成为了一个亟需解决的问…

作者头像 李华
网站建设 2026/4/23 14:32:02

期货套保系统回测功能深度解析

套期保值策略的有效性验证是产业企业风险管理的关键环节。传统方式依赖历史Excel数据手工回溯&#xff0c;耗时长、误差大&#xff0c;难以系统性评估策略在不同市场环境下的表现。本文将详细介绍期货套保系统中的回测功能模块&#xff0c;帮助企业建立数据驱动的策略评估体系。…

作者头像 李华