如何判断所有CompletableFuture都已执行完成

你提到的计数器思路是可行的，只要调整执行顺序就能完全规避瞬时归零的问题，是当前场景下的最优解。

核心实现逻辑 #

核心优化点是先完成所有计数增量操作，再等待计数归零，彻底消除中间阶段瞬时归零的可能性：

1. 初始化线程安全的计数器，初始值为0
2. 遍历Stream时，每生成一个CompletableFuture，先给计数器加1，再给Future绑定完成回调（无论成功失败都给计数器减1）
3. 等Stream遍历完成（所有任务已提交、所有计数增量操作已执行完毕），再等待计数器归零，此时归零即代表所有Future全部执行完成。

代码示例 #

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.atomic.LongAdder;
import java.util.stream.Stream;

public void batchProcessItems(Stream<Item> itemStream) {
    LongAdder unfinishedTaskCounter = new LongAdder();
    // 用于接收所有任务完成的通知
    CompletableFuture<Void> allTasksDone = new CompletableFuture<>();

    itemStream
        .map(item -> {
            // 先加计数，再提交任务，避免任务执行速度快于提交速度导致的计数虚低
            unfinishedTaskCounter.increment();
            // 此处替换为你原有生成CompletableFuture<ItemResult>的业务方法
            return processItem(item)
                .whenComplete((result, throwable) -> {
                    unfinishedTaskCounter.decrement();
                    // 仅当计数归零且未触发过完成通知时，触发回调
                    if (unfinishedTaskCounter.sum() == 0 && !allTasksDone.isDone()) {
                        allTasksDone.complete(null);
                    }
                    // 可选：此处可自行处理单任务异常、结果收集等逻辑
                });
        })
        // 触发流的遍历，仅提交任务不阻塞，不会退化为串行
        .forEach(future -> {});

    // 到此处所有任务已提交完成，计数总增量已固定，后续归零即为全部执行完成
    // 如需阻塞等待完成，调用以下代码即可
    allTasksDone.join();

    // 如需异步处理完成后的逻辑，无需阻塞，绑定回调即可
    // allTasksDone.thenRun(() -> {
    //     // 所有任务完成后的业务逻辑
    // });
}

方案优势 #

• 内存开销极低：不需要存储数十万级的Future实例，仅需要1个计数器和1个通知用的Future对象
• 无并发损耗：所有任务异步执行，没有串行阻塞逻辑，完全保留原有并发能力
• 适用范围广：不依赖执行器实现，无论使用单个还是多个执行器都可正常统计
• 无业务侵入：不需要修改任务逻辑、不需要注入毒丸等特殊对象，实现简洁优雅

注意事项 #

• 确保Stream遍历完成前不要提前等待计数归零，否则仍可能出现瞬时归零的误判
• 单任务的异常需要在whenComplete中自行捕获处理，避免回调中断导致计数器无法正常递减
• 高并发场景下优先使用LongAdder而非AtomicLong，前者通过分段计数减少锁竞争，性能高一个数量级

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