Exchanger是Java并发包中专为两个线程设计的原子交换工具,依靠“碰头即换”机制实现无锁、无队列的双向数据移交,要求严格双线程配对、轻量调用、显式处理超时与中断,禁止在线程池复用或在exchange()内执行耗时操作。

Exchanger 是 Java 并发包中专为两个线程设计的原子交换工具,不靠锁、不靠队列,靠“碰头即换”完成数据移交。它不是万能通信通道,而是精准服务于严格成对、双向协作的场景——用对了,轻量高效;用错了,容易卡死或错配。
双线程配对是硬约束
一个 Exchanger 实例只支持同时两个线程成功交换。第三个线程调用 exchange() 会无限等待,因为它找不到“搭档”。这不是排队机制,没有等待队列,也没有重连逻辑。
- 线程池中复用同一个 Exchanger 很危险:线程被回收再分配后,上一轮的等待可能残留,导致新任务无法配对
- 启动三个同类型工作线程(比如两个生产者+一个消费者),必然至少一个永久阻塞
- 必须确保两个协作线程长期存活、稳定调用,比如固定生命周期的渲染线程 + 显示线程
交换动作本身要轻量
exchange() 是同步点,不是执行点。它只负责“交出当前对象,拿回对方对象”,所有耗时操作必须放在调用前后。
- 填满缓冲区后再调用 exchange(buffer),别在方法里边读边写
- 避免在 exchange() 中触发 GC、网络请求或磁盘 IO,否则会拖慢配对线程,放大整体延迟
- 图像/音视频流水线中常见做法:A 线程处理完 frontBuffer → clear() → exchange() → 拿到 backBuffer 开始下轮;B 线程同理
超时与异常必须主动应对
生产环境几乎不用无参 exchange(V),因为单边失败会导致另一方永远挂起。带超时的版本是健壮性的底线。
- 推荐统一使用 exchange(V, timeout, unit),超时时间略大于正常处理耗时(如处理平均 800ms,设 1.5s)
- 捕获 TimeoutException 后应释放资源、上报指标,必要时触发降级流程(如跳过本帧、返回默认 buffer)
- 遇到 InterruptedException 要立即恢复中断状态:Thread.currentThread().interrupt(),不能忽略
类型安全与缓冲区管理细节
泛型保证编译期一致,但运行时仍需注意语义和生命周期。
- 声明 Exchanger<ByteBuffer> 就只接受 ByteBuffer,混用 byte[] 会 ClassCastException
- 交换的是引用,不是拷贝——双方必须约定好缓冲区状态(如每次 exchange 后调用 clear() 或 compact())
- 避免传 null,除非双方明确支持;更稳妥的做法是用哑值(如 new byte[0])或封装 Optional
- 缓冲区实例建议在线程内长期持有,不要每轮 new,减少 GC 压力

















