CompletableFuture.allOf().get()永久阻塞 50次并行异步任务问题排查

问题根因定位 #

1. 数组空值问题 #

你的循环逻辑是w从2到50，合计只有49次迭代，但初始化的deviationsFutures数组长度为50，最后一位元素是null。CompletableFuture.allOf()传入包含null的数组时会出现不可预期的行为，部分JDK版本会直接抛出空指针，部分版本会因为等待不存在的任务完成进入永久阻塞。

2. 异步回调线程池不匹配 #

supplyAsync指定了自定义的forkJoinPool执行，但后续的thenAcceptAsync没有传入线程池参数，默认会使用JDK全局的ForkJoinPool.commonPool()。该线程池的默认并行度是CPU核心数减1，通常只有个位数线程，如果回调逻辑有阻塞操作、或者并发任务量大，很容易出现线程耗尽，剩余的回调任务永远无法执行，对应的Future始终处于未完成状态，导致allOf.get()永久阻塞。

3. 自定义线程池参数不合理 #

如果你的findProfileByDateAndW方法中存在IO操作、锁等待等阻塞逻辑，而自定义的forkJoinPool并行度设置过小（默认是CPU核心数减1，仅适配CPU密集型任务），会导致所有工作线程都被阻塞，后续任务永远无法执行完成。

4. 无超时机制和异常兜底 #

当前代码没有给get()操作设置超时，一旦出现任务卡住就会永久阻塞；同时没有给异步任务加异常兜底逻辑，如果某个任务抛出未捕获的异常，会直接导致对应Future进入异常完成状态，部分场景下也会出现阻塞问题。

修复方案 #

1. 修正数组长度：将CompletableFuture<Void>[] deviationsFutures = new CompletableFuture[50];改为new CompletableFuture[49];，或者调整循环逻辑保证数组所有位置都被赋值，不存在null元素。
2. 统一异步线程池：给thenAcceptAsync传入你自定义的forkJoinPool，修改为：

.thenAcceptAsync(
    deviationSumByW -> {
      System.out.println("AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA");
      deviations.add(deviationSumByW);
    }, forkJoinPool)

3. 调优线程池参数：如果任务是IO密集型，将自定义forkJoinPool的并行度调整到合理值（比如20~50，可根据实际压测结果调整）。
4. 增加超时和异常兜底：
   • 给get()操作加超时：CompletableFuture.allOf(deviationsFutures).get(30, TimeUnit.SECONDS);，超时直接抛出异常方便排查。
   • 给异步任务加异常处理，避免异常被吞：在supplyAsync之后追加exceptionally逻辑打印异常日志。

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