Exchanger 是 Java 并发包中用于两个线程安全同步交换数据的工具，通过配对等待机制实现原子性双向交换，适用于双缓冲、流水线交接等场景，不支持多线程且需注意阻塞与引用安全问题。
Exchanger 是 Java 并发包（java.util.concurrent）中一个轻量级的线程协作工具，专用于**两个线程之间安全、同步地交换数据**。它不依赖锁或条件变量，而是通过内部的“配对等待”机制实现线程间的一对一数据交换，典型场景如：双缓冲、生产者-消费者协同、流水线阶段交接等。
Exchanger 的核心工作原理
Exchanger 就像一个“交换站”：两个线程各自调用 exchange(V x) 方法，传入自己的数据；当两个线程都到达该点时，它们会自动配对，原子性地交换彼此的数据并返回对方的数据；若只有一个线程到达，则会阻塞等待另一个线程到来（可设超时）。整个过程线程安全，无需额外同步。
关键特性：
- 严格限于两个线程参与，第三个线程调用会立即抛出
IllegalStateException - 交换是双向且原子的：A 得到 B 的数据，B 同时得到 A 的数据，不存在中间状态
- 支持超时重载方法
exchange(V x, long timeout, TimeUnit unit)，避免无限等待
实战示例：双缓冲图像处理
模拟图形渲染中常见的“前台缓冲/后台缓冲”切换场景：线程 A 负责绘制新帧（写入后台缓冲），线程 B 负责显示上一帧（读取前台缓冲），二者通过 Exchanger 交换缓冲区引用，实现零拷贝切换。
立即学习“Java免费学习笔记（深入）”；
代码片段：
Exchanger<byte[]> exchanger = new Exchanger<>();
byte[] frontBuffer = new byte[1024];
byte[] backBuffer = new byte[1024];
// 渲染线程（填充后台缓冲）
new Thread(() -> {
while (true) {
// 模拟绘制：向 backBuffer 写入数据
Arrays.fill(backBuffer, (byte) 0xFF);
try {
// 与显示线程交换：我交出 backBuffer，换回当前 frontBuffer
frontBuffer = exchanger.exchange(backBuffer);
// 此时 backBuffer 已变成上一轮的 frontBuffer，可复用为新后台
byte[] temp = backBuffer;
backBuffer = frontBuffer;
frontBuffer = temp;
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
}
}
}).start();
// 显示线程（消费前台缓冲）
new Thread(() -> {
while (true) {
try {
// 等待渲染线程交换，拿到最新渲染好的缓冲区
byte[] toDisplay = exchanger.exchange(frontBuffer);
// 模拟显示操作（如 sendToGPU）
System.out.println("Displayed buffer of length: " + toDisplay.length);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
break;
}
}
}).start();
注意：实际使用中建议配合 volatile 或 AtomicReference 控制缓冲区生命周期，避免因 GC 或重用导致数据错乱。
使用注意事项与常见陷阱
Exchanger 看似简单，但易踩坑：
- 必须成对调用：若一个线程异常退出未调用 exchange，另一线程将永久阻塞（除非设超时）——建议始终搭配 try-catch + timeout 使用
- 数据引用安全：Exchanger 交换的是对象引用，不是深拷贝。交换后双方持有同一对象的不同引用，需确保后续操作无竞态（例如不要在交换后继续修改原缓冲区）
-
不适用于多线程广播：Exchanger 不支持 3 个及以上线程同时交换，如需多方协作，请改用
CyclicBarrier或Phaser - 性能敏感场景慎用：虽然无锁，但线程挂起/唤醒有开销；高频率短数据交换下，直接共享 volatile 变量可能更高效
替代方案对比：什么情况下不该用 Exchanger？
并非所有“线程交换”需求都适合 Exchanger：
- 需要异步非阻塞交换 → 考虑
TransferQueue（如SynchronousQueue） - 涉及多个线程轮转协作（如 4 阶段流水线）→ 用
Phaser或带状态的BlockingQueue - 只需单向通知+传递少量状态 →
CountDownLatch或CompletableFuture更简洁 - 交换数据需持久化或跨 JVM → 应走消息队列（Kafka/RocketMQ）而非内存级工具
Exchanger 的价值在于语义精准、开销低、代码直观——当你明确只需要两个线程“一手交钱、一手交货”式协作时，它就是最贴切的选择。
