CompletableFuture不中断子任务，但可通过orTimeout()触发超时异常、completeOnTimeout()提供默认值、allOf()组合限时任务，并需协同HTTP/DB客户端及线程池超时配置实现优雅降级。
CompletableFuture 本身不中断正在运行的子任务，但可以通过组合超时控制、降级逻辑和线程协作机制，实现“感知超时 + 主动放弃 + 平滑兜底”的优雅处理。关键不是强行杀线程，而是让整个异步链对超时有响应能力。
用 orTimeout() 触发超时信号
这是 JDK 9+ 提供的最轻量级超时方案，适合声明式控制：
-
作用明确：在指定时间未完成时，自动将 CompletableFuture 置为异常完成状态，抛出
TimeoutException - 不干预执行线程：底层任务仍在运行（比如远程调用线程可能还在等 socket 响应），但后续链路已感知失败
- 必须配合 exceptionally() 或 handle() 使用，否则异常会静默丢失
示例：
CompletableFuture<String> result = CompletableFuture.supplyAsync(() -> {
Thread.sleep(3000); // 模拟慢接口
return "success";
}, executor)
.orTimeout(1, TimeUnit.SECONDS)
.exceptionally(ex -> {
if (ex instanceof TimeoutException) {
return "超时降级：缓存数据";
}
return "其他异常兜底";
});
用 completeOnTimeout() 替换结果而非报错
当业务允许“超时即默认”，且不希望中断流程时更合适：
立即学习“Java免费学习笔记（深入）”；
Java 接口排错助手
下载
在调试 Java 后端 API 故障时使用此技能，尤其适用于以下任务：分析日志、跨 Controller、Service 和 Mapper 层追踪请求、定位异常根因、检查 SQL 执行或参数流转，以及生成简洁的诊断结论与修复方案。
- 超时后不会抛异常，而是直接
complete()一个预设值 - 原任务仍继续执行，但其结果会被忽略（除非你额外保留引用）
- 适合读缓存、查配置等强可用场景
示例：
CompletableFuture<List<Item>> items = CompletableFuture.supplyAsync(this::fetchFromDb)
.completeOnTimeout(Collections.emptyList(), 800, TimeUnit.MILLISECONDS);
并行任务中统一超时边界
多个独立异步任务（如并发查多个服务）需整体限时，不能只看单个：
- 避免用
allOf()后再join()—— 它不支持超时参数 - 推荐：每个子任务单独加
orTimeout()，再用allOf()组合 - 或改用
CompletableFuture.anyOf()+ 超时任务兜底，实现“最快响应”策略
示例（全任务限时 1.5 秒）：
CompletableFuture<String> a = callServiceA().orTimeout(1500, TimeUnit.MILLISECONDS);
CompletableFuture<String> b = callServiceB().orTimeout(1500, TimeUnit.MILLISECONDS);
CompletableFuture<Void> all = CompletableFuture.allOf(a, b);
CompletableFuture<Object[]> result = all.thenApply(v -> new Object[]{a.join(), b.join()})
.exceptionally(ex -> {
log.warn("部分服务超时，返回降级", ex);
return new Object[]{"降级A", "降级B"};
});
注意线程池与任务自身超时的协同
CompletableFuture 的超时是“等待结果超时”，不是“执行超时”。要真正防止长耗时任务霸占线程，还需底层配合：
- HTTP 客户端（如 OkHttp、Feign）设置 connect/read timeout
- 数据库连接池（如 HikariCP）配置 connection-timeout 和 query-timeout
- 自定义线程池拒绝策略 + 任务包装器，避免无界堆积
例如，supplyAsync 不建议用 commonPool，应传入带监控的固定线程池：
ExecutorService worker = new ThreadPoolExecutor(
4, 8, 60L, TimeUnit.SECONDS,
new LinkedBlockingQueue<>(100),
r -> new Thread(r, "cf-worker-%d")
); 
