如何优雅合并循环中多个CompletionStage的执行结果？

原代码存在的问题 #

• 循环内引用了未定义的变量i，会导致编译错误，正确应该使用循环变量future而非futures.get(i)。
• 链式调用thenCombine的方式会强制等待所有Future完成才能得出结果，且每次合并都会创建新的CompletionStage，效率偏低。如果需求是只要有一个结果满足条件就提前返回，这种实现无法利用短路逻辑。

优化方案 #

方案一：利用短路逻辑提前返回（推荐，符合需求） #

因为你的需求是判断是否存在任意一个count>0，可以使用CompletableFuture.anyOf，它会在任意一个Future完成时就触发后续处理，一旦发现有满足条件的结果，就可以立即返回true，无需等待其他Future执行完毕，性能更优。

代码示例：

CompletionStage<Boolean> isAnyOneGreaterThanOne() {
    // 将所有CompletionStage转为CompletableFuture（若getCount返回的不是可转换类型，可手动包装）
    List<CompletableFuture<Long>> futures = names.stream()
            .map(this::getCount)
            .map(CompletionStage::toCompletableFuture)
            .collect(Collectors.toList());

    // 当任意一个Future完成时，检查其结果是否>0
    CompletableFuture<Boolean> firstMatch = CompletableFuture.anyOf(futures.toArray(new CompletableFuture[0]))
            .thenApply(count -> (Long) count > 0);

    // 处理所有Future都不满足的情况：所有任务完成后返回false
    CompletableFuture<Boolean> allCompleted = CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
            .thenApply(v -> false);

    // 优先返回第一个匹配结果，若所有都不匹配则返回false
    return firstMatch.applyToEither(allCompleted, Function.identity());
}

方案二：等待所有Future完成后统一判断 #

如果业务要求必须执行完所有getCount调用，再统一判断结果，可以使用CompletableFuture.allOf：

CompletionStage<Boolean> isAnyOneGreaterThanOne() {
    List<CompletableFuture<Long>> futures = names.stream()
            .map(this::getCount)
            .map(CompletionStage::toCompletableFuture)
            .collect(Collectors.toList());

    return CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
            .thenApply(v -> futures.stream()
                    .map(CompletableFuture::join)
                    .anyMatch(count -> count > 0)
            );
}

解释：allOf会等待所有Future完成后，通过stream().anyMatch统一判断是否存在满足条件的结果，这里用join是安全的，因为allOf已经确保所有任务都已完成，不会阻塞。

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