Exchanger是Java中用于两个线程间交换数据的同步工具，通过exchange()方法实现双向数据传递。两个线程调用exchange()时阻塞，直至双方到达后完成数据交换，支持超时机制避免永久等待。示例中生产者发送消息，消费者返回确认，实现协作处理。适用于双缓冲、对战游戏等成对线程协作场景，但仅限两线程使用，需注意异常导致的阻塞风险。
在Java多线程编程中，Exchanger 是一个用于两个线程之间交换数据的同步工具类，位于 java.util.concurrent 包中。它提供了一种简单而高效的双线程协作模型：两个线程通过调用 exchange() 方法，各自传递一个对象，在双方都到达交换点时，数据自动完成交换。
Exchanger的基本原理
Exchanger可以看作是一个“会合点”。两个线程分别执行到 exchange() 调用时会阻塞，直到另一个线程也调用了 exchange()，此时两者的数据进行交换并继续执行。如果只有一个线程调用，它将一直等待，除非设置超时（使用带超时参数的方法）。
主要方法：
- V exchange(V x)：等待另一个线程到达交换点，并交换数据。
- V exchange(V x, long timeout, TimeUnit unit)：在指定时间内等待交换，超时则抛出 TimeoutException。
实际使用示例
下面是一个简单的双线程数据交换场景：生产者线程生成数据放入缓冲区，消费者线程取出数据处理，二者通过 Exchanger 协作交换缓冲区引用。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.Exchanger;
public class ExchangerExample {
public static void main(String[] args) {
Exchanger exchanger = new Exchanger<>();
Thread producer = new Thread(() -> {
String[] data = {"消息1", "消息2", "消息3"};
for (String msg : data) {
try {
System.out.println("生产者准备发送: " + msg);
String received = exchanger.exchange(msg); // 发送自己的数据，接收对方的
System.out.println("生产者收到反馈: " + received);
Thread.sleep(500);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
});
Thread consumer = new Thread(() -> {
for (int i = 0; i < 3; i++) {
try {
String received = exchanger.exchange("已处理"); // 发送确认，接收数据
System.out.println("消费者收到: " + received);
Thread.sleep(800);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
});
producer.start();
consumer.start();
}
} 输出可能如下：
生产者准备发送: 消息1 消费者收到: 消息1 生产者收到反馈: 已处理 生产者准备发送: 消息2 消费者收到: 消息2 生产者收到反馈: 已处理 ...
可以看到，每次 exchange() 调用都会触发一次双向数据传递，实现了线程间的对等协作。
适用场景与注意事项
适用场景：
- 双人对战游戏中的状态同步。
- 流水线式处理中，两个线程交替处理并交换缓冲区（如双缓冲机制）。
- 需要成对协作的任务，比如数据校验、配对计算等。
注意事项：
- Exchanger只支持两个线程之间的交换，多于两个线程的行为不可预测。
- 若一个线程提前退出或异常，另一个线程可能永久阻塞，需谨慎处理中断和超时。
- 交换的数据类型由泛型定义，建议保持一致以避免类型错误。
基本上就这些。Exchanger虽然使用场景有限，但在特定的双线程协作模型中非常简洁高效。合理利用它可以减少锁和条件变量的复杂性，提升代码可读性和性能。不复杂但容易忽略。
