exchanger是java并发包中专为两个线程成对交换数据设计的轻量级同步工具,通过“碰头即换”机制实现对象引用的原子交换,具备严格双线程配对、阻塞式同步点、零拷贝移交等核心特征。

Exchanger 是 Java 并发包(java.util.concurrent)中一个轻量级但设计精巧的同步工具,专用于**两个线程之间安全、成对地交换数据**。它不提供锁或条件等待的通用能力,而是聚焦于“一对一协作”场景——比如双缓冲、生产者-消费者配对、工作线程轮换等。其核心逻辑不是靠轮询或复杂状态机,而是一条清晰、原子、阻塞式的协作链。
协作起点:两个线程调用 exchange() 形成配对
每个线程调用 exchanger.exchange(data) 时,会尝试寻找另一个也在调用该方法的线程。若未找到,当前线程进入等待;一旦匹配成功,双方线程各自拿到对方传入的数据,并同时从 exchange() 方法返回。
- 匹配是严格一对一的:第三个线程调用时,必须等待前一对完成之后才能参与下一轮配对
- 匹配具有“即时性”:不缓存历史数据,也不支持超时外的重试逻辑(除非使用带超时的重载方法)
- 线程在配对期间处于阻塞状态(默认使用
LockSupport.park()),不消耗 CPU
内部状态流转:基于单个 volatile 字段的“槽位+等待队列”模型
Exchanger 的底层实现(JDK 8 及以后)采用一个 volatile Node[] arena 数组 + 主槽位 slot 字段协同工作,但核心协调逻辑由一个 volatile Object slot 承载:
- 初始时
slot == null,第一个线程将自己封装为Node写入slot,并挂起 - 第二个线程发现
slot != null,尝试 CAS 将其清空,成功则完成交换,唤醒前者 - 若 CAS 失败(如已有其他线程抢先操作),则退化到竞争更小的
arena数组中继续配对,避免单点争用
整个过程无显式锁,全靠 volatile 可见性 + CAS 原子性保障线程安全,逻辑链短、路径明确。
数据同步的本质:交换即发布,无需额外内存屏障
Exchanger 的“同步”并非指让变量对所有线程可见,而是保证:双方线程在 exchange() 返回后,必然已看到对方写入的数据内容。这依赖 JVM 内存模型的 happens-before 规则:
- 线程 A 调用
exchange(a)→ 写 a(happens-before)→ 成功配对 → 线程 B 读到 a(happens-before)→ B 返回 - 同理,B 写 b → A 读到 b,构成双向 happens-before 链
- 因此,交换后的数据天然具备同步语义,后续对这些数据的访问无需再加 volatile 或 synchronized
典型误用与规避要点
Exchanger 不是万能同步器,常见误区包括:
- 试图用它替代
BlockingQueue实现多对多通信——它只支持两两配对,多线程需自行调度配对逻辑 - 忽略线程生命周期管理:若一方异常退出或长时间阻塞,另一方将无限等待(可配合
exchange(V, timeout, unit)设置超时) - 在交换对象中修改共享状态却未考虑线程安全——Exchanger 仅同步“引用传递”,不保护对象内部状态
真正发挥价值的场景,是结构清晰的双角色协作:比如图形渲染中前后帧缓冲区切换、网络协议栈中收发线程交换报文上下文、测试中模拟请求-响应配对等。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











