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