Java Exchanger解决线程间数据同步交换的核心方法

Exchanger 的核心机制在于 exchange() 方法，它能够实现两个线程之间的原子性引用交换。无参版本要求严格配对并阻塞线程，生产环境建议使用带超时参数的重载版本以避免级联阻塞。开发人员需自行确保类型安全及空值处理。Exchanger 不支持超过两个线程的配对，没有内部状态，其实例可重复使用。

Exchanger 最核心的方法是 exchange()——可以形象地理解为两个线程约定好“面对面交货”。双方抵达同步点后，同时阻塞、原子交换、零拷贝，直接将对象引用传递到对方手中。

先来看无参版本：线程一调用 exchange() 后立即进入 WAITING 状态，不消耗 CPU，也不自旋，保持等待。它不会继续执行，直到另一个线程也调用同一 Exchanger 实例的 exchange() 方法。注意，这里并非“先来后到”，而是必须双方同时到达才能触发。一旦配对成功，双方在一次原子操作中互换引用：线程 A 传入的对象交给线程 B，同时线程 B 的对象交给线程 A。返回值始终是对方的数据，而非自己原本传入的对象。这好比两人交换笔记本，拿到的一定是对方的那本。

但在生产环境中，无参版本容易引发级联阻塞，因此推荐使用带超时参数的重载版本：exchange(V x, long timeout, TimeUnit unit)。若超时，会抛出 TimeoutException，当前线程可捕获后执行降级逻辑——例如记录告警、释放资源、切换到备用缓冲区，避免单个线程拖垮整体流程。需要注意的是，超时仅影响当前线程，另一方若稍后到达，交换仍会完成，只是结果无人接收。建议根据任务类型设定合理的超时阈值：I/O 类任务可设为 2–5 秒，纯计算类可缩短至 100–500 毫秒。

类型安全与空值控制方面，Exchanger 本身不做校验，需要开发者自行保障。两个线程必须使用相同的泛型声明（例如 Exchanger），否则运行时会抛出 ClassCastException。虽然语法上允许传递 null，但这极易引发下游的空指针异常（NPE）；建议在初始化时使用哑值（如 new byte[0]）或在业务层提前判空。值得注意的是，exchange() 交换的是引用而非副本，对于大型数组（byte[]、int[]）而言，可以避免内存拷贝，带来显著性能提升。

最后需要注意的是：Exchanger 并非队列，它没有内部缓冲，也不缓存历史数据。第三个线程调用 exchange() 会一直等待，直到第四个线程出现才能配对，逻辑不可控。每次 exchange() 都是一次独立事件，实例可重复使用，无需 reset 或 cleanup。公平性问题同样值得关注：默认构造不保证公平性，若启用公平模式（new Exchanger(true)），吞吐量将降低约 10%–20%。