使用ExecutorService配合Future或CompletableFuture实现多线程任务结果合并：先拆分任务并提交，再获取各子任务结果进行汇总。Future适用于固定数量任务，逻辑清晰但get()阻塞；CompletableFuture支持异步组合与链式调用，适合复杂场景，可结合allOf统一处理多个结果，建议根据任务复杂度选择合适方式，并注意异常处理。
在Java中实现多线程任务结果合并，通常使用 ExecutorService 配合 Future 或 CompletableFuture 来完成。核心思路是：将任务拆分为多个子任务并行执行，最后汇总各个子任务的结果。
使用 Future 和 Callable 合并结果
通过 ExecutorService.submit() 提交多个 Callable 任务，每个任务返回一个 Future，然后调用 get() 获取结果并合并。
示例：
import java.util.concurrent.*;
public class FutureMergeExample {
public static void main(String[] args) throws Exception {
ExecutorService executor = Executors.newFixedThreadPool(4);
// 提交多个任务
Future task1 = executor.submit(() -> computePart(1, 100));
Future task2 = executor.submit(() -> computePart(101, 200));
Future task3 = executor.submit(() -> computePart(201, 300));
// 获取结果并合并
int result = task1.get() + task2.get() + task3.get();
System.out.println("合并结果: " + result);
executor.shutdown();
}
static int computePart(int start, int end) {
return IntStream.rangeClosed(start, end).sum();
}
}
优点是逻辑清晰，适合任务数量固定的情况。缺点是调用 Future.get() 是阻塞的，需注意异常处理和超时控制。
立即学习“Java免费学习笔记（深入）”；
使用 CompletableFuture 实现异步合并
CompletableFuture 更灵活，支持链式调用和组合操作，适合复杂的结果合并场景。
示例：合并两个异步任务的结果
CompletableFuturepart1 = CompletableFuture.supplyAsync(() -> { // 模拟耗时操作 sleep(1000); return "Hello"; }); CompletableFuture part2 = CompletableFuture.supplyAsync(() -> { sleep(500); return "World"; }); // 合并结果 CompletableFuture combined = part1.thenCombine(part2, (a, b) -> a + " " + b); String result = combined.get(); // 得到 "Hello World" System.out.println(result);
也可以使用 allOf 等待多个任务完成后再统一处理：
CompletableFutureallDone = CompletableFuture.allOf(task1, task2, task3); allDone.thenRun(() -> { try { int total = task1.get() + task2.get() + task3.get(); System.out.println("总和: " + total); } catch (Exception e) { e.printStackTrace(); } });
实际应用建议
根据任务特点选择合适方式：
- 任务少且结构简单 → 使用 Future + ExecutorService
- 需要非阻塞、链式处理或动态编排 → 使用 CompletableFuture
- 结果合并涉及复杂逻辑（如聚合、转换）→ 结合 Stream 和 CompletableFuture.allOf
- 注意异常处理：CompletableFuture 默认不抛出异常，需用 exceptionally 或 handle 处理
