Java中如何确保CompletableFuture完全完成后再执行Collector采集逻辑及问题排查

为什么没有显式阻塞代码却抛出TimeoutException #

• 问题出在query方法的实现：方法内手动创建的new CompletableFuture<>()是一个完全空的、未绑定任何任务的实例，整个代码流程里没有任何位置调用complete()/completeExceptionally()去触发它完成，这个实例会永远处于挂起的未完成状态。
• 链式调用的执行规则：挂在这个空Future上的thenApply回调（也就是执行collector.collectStuff()的逻辑），必须等根Future被触发完成后才会运行。由于根Future永远不会完成，整条CompletableFuture调用链从创建开始就永远走不到完成态。
• 超时触发的逻辑：s.get(1000, TimeUnit.MILLISECONDS)会让当前主线程最多等待1秒等Future完成，因为对应的Future链永远不结束，1秒等待到期后自然抛出TimeoutException；同时因为回调从未执行，collector的计数i始终为0，和实际运行输出完全一致。

finally块能不能保证所有异步任务跑完再执行Collector的释放逻辑 #

• 先明确finally的执行边界：finally只和当前跑try代码块的主线程流程绑定，只要主线程离开try块（不管是正常拿到结果、捕获到TimeoutException、还是中途被中断），就会立刻执行finally里的代码，它根本不会去感知、等待其他异步线程里还没跑完的任务。
• 对应到本例的实际流程：等待1秒超时抛出异常后，主线程立刻捕获TimeoutException，马上进入finally块打印collector.getI()，这时候整条CompletableFuture链还处在永久挂起的状态，collectStuff压根没机会跑，所以最后打印的i值是0。
• 核心结论：只要你用了带超时参数的get方法，超时触发时异步任务基本都没执行完，此时finally的执行时机远早于所有异步任务跑完的时间，完全满足不了“等所有任务做完再释放指标”的需求。

实现指标采集收尾的正确方向 #

• 先修正Future链的构建逻辑：别创建永远挂起的空Future，把实际业务任务和Future实例绑定，任务执行结束后主动触发完成。
• 收尾逻辑必须绑定在Future链的完成回调上：不要靠主线程的finally流程做Collector的释放动作，要等整条CompletableFuture链全部执行完成（不管成功还是失败），再在对应的完成回调里调用Collector的指标释放方法；如果确实需要设置超时阈值，超时后要先显式取消所有未完成的异步任务，再执行收尾，避免任务永久挂起导致指标泄漏。

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