exchanger仅保证引用交换的原子性与配对性,不保障数据内容的线程安全;使用者须通过显式同步、内存屏障(如varhandle.storefence)、所有权协议及超时机制补全安全性。

Exchanger 本身不直接“保障”数据交换的安全性,它只保证引用交换动作的原子性与配对性。真正的线程安全,必须由使用者通过明确协议、显式同步和生命周期管理来补全。
交换动作本身是原子且配对的
两个线程调用同一个 Exchanger 实例的 exchange() 方法时,必须同时到达才能完成交换。JVM 内部使用 CAS 和 LockSupport 实现,确保:
- 交换过程不可中断、不可重排,是一次完整的“手拉手”操作
- 双方拿到的一定是对方传入的对象引用,不会出现中间态或部分交换
- 泛型类型在编译期强制一致,避免运行时类型错乱
但交换后访问数据仍需额外同步
Exchanger 只交换引用,不复制内容,也不自动建立内存可见性边界。比如交换一个 byte[]:
Java项目代码review工具。分析Git变更+完整调用链路上下文,推断业务需求,进行多维度评分和分类汇总,生成完整PRD文档。包含细粒度Java代码审查清单(Null安全、异常处理、Streams、并发、equals/hashCode、资源管理、API设计、性能、MyBatis/ORM、事务边界、SQL/DD...
- 发送方填完数组后调用
exchange(),接收方拿到引用后,可能读不到最新写入的内容——JVM 不保证数组元素的修改对另一线程立即可见 - 若双方都继续读写同一数组,会引发脏读、覆盖写、伪共享等问题
- 解决办法:发送方应在
exchange()前完成所有写操作,并配合volatile boolean flag或VarHandle.storeFence()确保写操作对对方可见
必须约定数据所有权与使用边界
Exchanger 不定义语义,只提供机制。安全的前提是双方严格遵守协作协议:
- 交换即移交使用权:接收方获得该对象的独占读/写权,发送方此后不得再访问(建议交换后立即将本地引用置为
null或清空缓冲区) - 禁止复用已交换对象做本地判断:返回值是对方的数据,不是自己传入的原值
- 大对象建议封装进带
volatile字段的容器类(如class BufferHolder { volatile byte[] data; }),并在交换前写入
防止单点故障导致阻塞卡死
Exchanger 要求严格双线程配对,现实场景中极易因异常、延迟或生命周期错位而失败:
- 永远使用带超时的
exchange(x, timeout, unit),例如exchange(buffer, 300, TimeUnit.MILLISECONDS) - 捕获
TimeoutException后主动清理资源(如重置 buffer、记录告警、触发降级) - 捕获
InterruptedException后恢复中断状态:Thread.currentThread().interrupt() - 避免在线程池中复用 Exchanger,防止“上一轮的 A 已退出,下一轮的 B 无人配对”
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










