使用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<Integer> task1 = executor.submit(() -> computePart(1, 100));
Future<Integer> task2 = executor.submit(() -> computePart(101, 200));
Future<Integer> 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 更灵活，支持链式调用和组合操作，适合复杂的结果合并场景。
示例：合并两个异步任务的结果
CompletableFuture<String> part1 = CompletableFuture.supplyAsync(() -> {
// 模拟耗时操作
sleep(1000);
return "Hello";
});
CompletableFuture<String> part2 = CompletableFuture.supplyAsync(() -> {
sleep(500);
return "World";
});
// 合并结果
CompletableFuture<String> combined = part1.thenCombine(part2, (a, b) -> a + " " + b);
String result = combined.get(); // 得到 "Hello World"
System.out.println(result);
也可以使用 allOf 等待多个任务完成后再统一处理：
CompletableFuture<Void> allDone = 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 处理
