exchanger是java并发包中专为两个线程配对交换数据设计的轻量级同步工具,通过“碰头即换”机制在汇合点原子性移交数据,要求双方同时到达才能触发交换,单线程调用将无限等待(除非启用超时),仅支持严格双向协作,不适用于多线程场景。

Exchanger 是 Java 并发包中专为两个线程配对交换数据设计的轻量级同步工具。它不依赖锁、不涉及复杂队列,而是通过“碰头即换”的机制,在汇合点完成原子性数据移交——既安全,又高效。
Exchanger 的核心行为:成对阻塞与即时交换
调用 exchanger.exchange(data) 的线程会立即挂起,直到另一个线程也调用同一实例的该方法。此时两者被唤醒,彼此交付数据,各自拿到对方的对象后继续执行。
- 不是“谁先谁后”,而是“必须两人同时到场”才触发交换
- 若只有单个线程调用,它将无限等待(除非使用带超时的重载方法)
- 三个或更多线程共用一个 Exchanger 时,仅两两配对成功;未配对者持续阻塞,容易引发死等
适用场景:双工协作型任务
它天然适合双向流水线式协作,比如:
- 前后台缓冲区轮换:渲染线程填满 backBuffer 后交换给显示线程,显示线程把刚用完的 frontBuffer 交回
- 生产-消费配对处理:一个线程生成数据块,另一个线程做校验/压缩/转发,双方在固定节点交换批次
- 网络双工通信中的帧协商:客户端与服务端模拟“握手交换”上下文信息(如 session key、序列号)
使用要点与避坑提醒
看似简单,但几个关键细节决定是否真正稳定高效:
-
类型必须一致:泛型声明
Exchanger<byte></byte>就只接受 byte[],混用会编译报错或运行时 ClassCastException -
超时是保命机制:建议优先选用
exchange(V, timeout, unit),避免因某线程异常退出导致另一方永久挂起 -
公平性参数慎用:构造时传
true启用公平模式,虽能保证等待久的线程优先配对,但会引入额外队列开销,吞吐通常下降 10%~20% - 不可复用已交换对象做后续逻辑判断:交换返回的是对方数据,不是自己传入的原值;常见错误是误把 received 当作本地处理结果
对比其他机制:为什么选 Exchanger?
比起 BlockingQueue 或 SynchronousQueue 实现双线程交换,Exchanger 优势明显:
- 无中间存储:不缓存、不排队,内存占用恒定为两个引用
- 零拷贝语义:交换的是对象引用,不是内容复制(对大数组/缓冲区尤其友好)
- 语义清晰:代码意图一目了然,“我要和另一个线程换数据”,而非“我放一个、再取一个”
- 无竞争路径:内部无 CAS 自旋争抢,高并发下延迟更稳定











