exchanger 是 java 并发包中用于两个线程安全交换数据的工具，通过阻塞式双向同步实现原子交换，支持超时、中断和泛型安全，适用于生产者-消费者等成对协作场景。
Exchanger 是 Java 并发包（java.util.concurrent）中一个轻量级的线程协作工具，专用于**两个线程之间安全地交换数据**。它不适用于多线程轮换或广播场景，但对成对协作（如生产者-消费者、双缓冲校验、请求-响应配对）非常高效且语义清晰。
核心机制：阻塞式双向同步交换
调用 exchanger.exchange(data) 时，当前线程会阻塞，直到另一个线程也调用同一实例的 exchange() 方法；两者“碰头”后原子性地交换各自传入的对象，并同时返回对方的数据。整个过程由 JVM 保证线程安全与内存可见性，无需额外加锁或 volatile 修饰。
关键特性：
- 严格配对：每次成功交换必须且仅由两个线程参与；第三个线程调用会一直等待前一对完成
- 可中断：若等待中被
interrupt()，抛出InterruptedException并退出 - 支持超时：
exchange(V x, long timeout, TimeUnit unit)避免无限等待 - 泛型安全：编译期类型检查，避免 ClassCastException
典型场景：双线程数据对换与一致性校验
例如：线程 A 生成一组计算结果，线程 B 执行独立校验逻辑，双方需互换原始输入与校验反馈，确保“谁提交谁负责验证”。此时 Exchanger 天然契合——不是单向传递，而是双向承诺。
示例结构：
- 定义交换载体类（如
DataExchange），含input、result、isValid等字段 - A 线程填充 input + result，调用
exchanger.exchange(packet) - B 线程收到 packet 后执行校验，设置
isValid和错误信息，再调用exchange(packet)返回 - A 拿回经 B 校验后的 packet，检查
isValid决定是否重试或上报
使用注意事项与避坑点
实际使用中易忽略以下细节：
-
实例复用需谨慎：同一个
Exchanger实例可被多对线程重复使用，但必须确保每对线程逻辑上“绑定”，避免跨组错配（比如 A1 本该等 B1，却和 B2 交换了） -
空值允许但需约定：可传
null，但双方应明确语义（如 null 表示终止信号），否则可能引发 NPE -
异常传播要处理：若一方在 exchange 前已异常退出，另一方将永久阻塞（除非设超时），建议配合
try-catch InterruptedException和超时机制 - 不替代共享状态：Exchanger 是“瞬时协作”，不适合长期共享或多次读写；需持久化请配合 BlockingQueue 或 AtomicReference
一个简洁可运行的校验对换示例
以下代码模拟两个线程交换计算任务与校验结果：
Exchanger<dataexchange> exchanger = new Exchanger();
// 线程 A：执行计算
new Thread(() -> {
DataExchange pkt = new DataExchange("input-123", compute("input-123"));
try {
DataExchange resp = exchanger.exchange(pkt, 3, TimeUnit.SECONDS);
if (resp.isValid) {
System.out.println("校验通过：" + resp.message);
} else {
System.err.println("校验失败：" + resp.message);
}
} catch (InterruptedException | TimeoutException e) {
Thread.currentThread().interrupt();
}
}).start();
// 线程 B：执行校验
new Thread(() -> {
try {
DataExchange req = exchanger.exchange(null, 3, TimeUnit.SECONDS);
boolean ok = validate(req.input, req.result);
req.isValid = ok;
req.message = ok ? "OK" : "Checksum mismatch";
exchanger.exchange(req); // 把结果送回 A
} catch (InterruptedException | TimeoutException e) {
Thread.currentThread().interrupt();
}
}).start();
</dataexchange>
注意：此处 B 先用 null 占位等待 A 提交，再校验并回传——体现“先收后发”的协作节奏，而非竞态依赖。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
