Java中Exchanger配合线程池提交Callable任务并获取返回值教程-java教程-PHP中文网

exchanger 不支持直接提交 callable 任务或获取返回值，而是作为两个线程间双向交换中间结果的同步工具；callable 的返回值仍需通过 future.get() 获取，exchanger 仅在任务内部用于协作交换数据。

java中exchanger配合线程池提交callable任务并获取返回值教程

Exchanger 本身不直接支持 Callable 任务的提交与返回值获取，它只是一个线程间**双向交换数据**的同步工具。想在线程池中用 Exchanger 配合 Callable 获取结果，关键不是让 Exchanger 承担任务调度或结果传递职责，而是把它作为两个线程之间**协作交换中间结果**的桥梁，而 Callable 的返回值仍由 Future 正常获取。

理解 Exchanger 的定位和限制

Exchanger 是一个用于两个线程之间成对同步交换对象的工具。它要求恰好两个线程调用 exchange() 才能继续执行，多于或少于两个线程都会阻塞等待。它不管理线程生命周期，也不参与任务提交、执行调度或结果封装——这些是 ExecutorService 和 Future 的职责。

因此，“Exchanger 配合线程池提交 Callable 并获取返回值”应理解为：在 Callable 任务内部使用 Exchanger 与其他线程协作交换数据，同时仍通过 Future.get() 获取该 Callable 的最终返回值。

典型协作场景：双线程协同计算

常见适用场景是两个线程需要各自完成一部分计算，再交换中间结果，组合出最终结果。例如：线程 A 处理数据前半段，线程 B 处理后半段，双方交换中间结果后各自生成最终输出。

Java JDK 25

Java JDK 25 来自 OpenJDK 官方归档，版本为 JDK 25，本条下载地址已指向官方 Windows x64 zip 安装包直链，适合调试旧项目或兼容旧版 Java 运行环境。

下载

定义一个 Exchanger exchanger = new Exchanger();
创建两个 Callable 实例（如 TaskA 和 TaskB），都在 run() 中调用 exchanger.exchange(ownResult)；
用 ExecutorService 提交这两个 Callable，得到两个 Future；
分别调用 futureA.get() 和 futureB.get() 获取各自 Callable 的返回值（注意：exchange() 返回的是对方传来的值，但 Callable 的 call() 方法可基于它进一步计算并 return）。

代码示例：双线程交换并生成最终结果

以下是一个完整可运行的简化示例：

Exchanger<string> exchanger = new Exchanger();
ExecutorService pool = Executors.newFixedThreadPool(2);

Callable<string> taskA = () -> {
    String local = "A-data";
    String other = exchanger.exchange(local); // 等待 B 交换
    return "Final-A: " + local + "&" + other;
};

Callable<string> taskB = () -> {
    String local = "B-data";
    String other = exchanger.exchange(local); // 等待 A 交换
    return "Final-B: " + local + "&" + other;
};

Future<string> fa = pool.submit(taskA);
Future<string> fb = pool.submit(taskB);

System.out.println(fa.get()); // Final-A: A-data&B-data
System.out.println(fb.get()); // Final-B: B-data&A-data
pool.shutdown();
</string></string></string></string></string>

注意：两个 Callable 必须几乎同时执行 exchange()，否则先执行的线程会阻塞；线程池大小设为 2 可避免额外线程干扰配对。