Java CompletableFuture 超时后怎么取消底层任务

Java CompletableFuture 超时后，orTimeout 只负责让这个结果以 TimeoutException 结束，并不会自动停止已经提交给执行器的底层任务。要真正减少无效工作，需要同时保留 ExecutorService.submit 返回的 Future，在超时分支调用 Future.cancel(true)，再让任务代码检查中断或使用底层 I/O 自带的超时。

先把“结果超时”和“任务取消”分开

这类问题最容易误判的地方，是把一个异步调用看成一个状态。实际上至少有两条线：调用方等待的结果线，以及执行器里正在消耗线程和连接的任务线。前者超时，不代表后者已经停止。

orTimeout 只改变结果，不会替你停掉供应商任务

把超时链直接写成 CompletableFuture.supplyAsync(supplier, pool).orTimeout(800, MILLISECONDS) 很简洁，但它没有留下执行器任务的取消句柄。超时发生后，调用方可以收到异常，supplier 仍可能继续占用线程，直到自身返回或遇到自己的阻塞期限。

因此，性能排查要记录两组指标：调用方超时率、超时后的任务尾部运行时长。只看前一组，无法判断线程池是否真的减压。

让底层执行器真正拥有可取消句柄

可以用一个手动完成的 CompletableFuture 接收结果，再把实际执行交给 submit。超时回调只在确认是 TimeoutException 时取消底层 Future：

ExecutorService pool = Executors.newFixedThreadPool(8);
CompletableFuture result = new CompletableFuture();
AtomicReference> handle = new AtomicReference();

Future> submitted = pool.submit(() -> {
    try {
        // 任务内部的阻塞调用也应配置自己的超时。
        String value = callRemoteService();
        result.complete(value);
    } catch (InterruptedException ex) {
        // 收到 cancel(true) 后保留中断标记，并结束本次任务。
        Thread.currentThread().interrupt();
        result.completeExceptionally(ex);
    } catch (Throwable ex) {
        // 让非取消异常仍然回到异步结果。
        result.completeExceptionally(ex);
    }
});
handle.set(submitted);

result.orTimeout(800, TimeUnit.MILLISECONDS)
      .whenComplete((value, error) -> {
          if (error instanceof TimeoutException) {
              // 只向真正的执行器任务发出取消请求。
              Future> task = handle.get();
              if (task != null) task.cancel(true);
          }
      });

这个写法的关键不是“把 true 写上就强制杀线程”，而是把取消请求送到了正确的句柄。任务是否马上退出，仍取决于代码是否响应中断；如果它卡在不响应中断的外部调用里，还必须使用该客户端提供的连接或读取超时。

用可观测指标确认取消真的生效

改完后不要只看接口是否返回超时。至少同时观察：超时请求数、调用方收到 TimeoutException 的数量、Future.cancel(true) 返回值、任务收到中断后的退出时长、线程池 active count，以及外部连接在超时后的释放时长。若超时率下降但 active count 和尾部任务时长不变，通常只是结果线变快，执行线没有被取消。

压测时先固定并发量和任务耗时分布，再比较“只用 orTimeout”与“保存 Future 后取消”的两组结果。不要把一次机器空闲时的平均耗时当成取消成功的证据，重点看 P95/P99 尾部和取消后的资源回收。

几个容易踩坑的边界

• 不要把 CompletableFuture.cancel(false) 当成底层执行器的取消；它主要改变 future 的完成状态。
• 不要在所有异常上都调用 cancel(true)，业务失败和超时的处理意图不同。
• 不要吞掉 InterruptedException；恢复中断标记后尽快退出，避免线程继续执行后续副作用。
• 提交任务前就超时的排队项，应取消其 Future；已经完成的任务再取消只会返回失败或没有实际效果。

相关问题

orTimeout 会创建一个新的 CompletableFuture 吗？

它返回当前的 CompletableFuture，是在原对象上增加超时完成行为；不要因此推断底层 supplier 会被停止。

为什么 cancel(true) 后任务还打印了日志？

取消是请求，已运行线程可能在收到中断前又执行一小段代码；任务应在循环、阻塞点和副作用前检查退出条件。

网络请求只靠线程中断够吗？

不够。HTTP 客户端、数据库驱动或 RPC 客户端还应设置连接、读取和整体调用期限，具体名称以所用组件的官方文档为准。

什么时候只使用 orTimeout？

当底层任务成本很小、可自然完成，或者底层库已经用独立期限管理资源时，可以只让结果按时失败；否则应保留可取消句柄并观测尾部任务。