如何利用CompletableFuture实现线程并行执行并合并结果？

一、修复串行执行问题 #

你当前循环调用executeGetCapability后立刻get()，会导致线程阻塞等待单个任务完成，自然变成串行。正确的做法是先批量提交所有异步任务，再统一等待完成后合并结果：

public List<CapabilityDTO> getCapabilities(List<String> ids) {
    // 1. 批量提交异步任务，收集所有CompletableFuture实例
    List<CompletableFuture<CapabilityDTO>> futureList = ids.stream()
            .map(this::executeGetCapability)
            .collect(Collectors.toList());

    // 2. 用allOf等待所有异步任务完成
    CompletableFuture<Void> allCompleted = CompletableFuture.allOf(
            futureList.toArray(new CompletableFuture[0])
    );

    // 3. 所有任务完成后，统一提取结果并返回
    return allCompleted.thenApply(v -> futureList.stream()
            .map(CompletableFuture::join) // join无需捕获检查异常，比get()更便捷
            .collect(Collectors.toList()))
            .join();
}

这个流程里，所有异步任务会被并行提交到你指定的threadPoolCapabilitiesExecutor线程池，不会逐个阻塞，直到所有任务完成后才统一收集结果。

二、CompletableFuture.supplyAsync 用法 #

supplyAsync是CompletableFuture的静态方法，用于直接提交带返回值的异步任务，可替代@Async注解的方式，灵活控制线程池：

• 两个重载版本：
  1. supplyAsync(Supplier<U> supplier)：使用JDK默认的ForkJoinPool.commonPool()执行任务
  2. supplyAsync(Supplier<U> supplier, Executor executor)：指定自定义线程池执行（和你的@Async("threadPoolCapabilitiesExecutor")效果一致）

示例代码：

@Autowired
private Executor threadPoolCapabilitiesExecutor;

// 用supplyAsync替代@Async实现异步方法
public CompletableFuture<CapabilityDTO> executeGetCapability(String id) {
    return CompletableFuture.supplyAsync(() -> {
        // 这里写业务逻辑：比如查询数据库、调用第三方接口等
        return fetchCapabilityById(id);
    }, threadPoolCapabilitiesExecutor);
}

三、CompletableFuture.allOf 用法 #

allOf的核心作用是等待传入的所有CompletableFuture完成，返回一个CompletableFuture<Void>，仅表示所有任务的完成状态，不直接返回任务结果。

关键注意点：

• 无论单个任务成功还是失败，allOf都会在所有任务结束后完成
• 若要获取单个任务的结果，需要提前收集所有CompletableFuture实例，在allOf完成后逐个提取
• 若有任务抛出异常，allOf返回的Future会携带异常，调用join()或get()时会抛出CompletionException，需要额外处理：

异常处理示例：

return allCompleted.handle((unused, throwable) -> {
    if (throwable != null) {
        log.error("部分异步任务执行失败", throwable);
    }
    return futureList.stream()
            .map(future -> {
                try {
                    return future.get();
                } catch (Exception e) {
                    log.error("单个任务执行失败，跳过该结果", e);
                    return null;
                }
            })
            .filter(Objects::nonNull)
            .collect(Collectors.toList());
}).join();

内容的提问来源于stack exchange，提问作者MiGo