CompletableFuture 的核心是声明式、可组合、可错误处理的异步任务执行，而非直接替代 Thread；它通过 supplyAsync 等方法封装线程调度，支持链式响应、多任务编排（thenCompose/thenCombine/allOf）及显式异常处理（exceptionally/handle/whenComplete），并需按任务类型选用合适线程池。
用 CompletableFuture 替代 new Thread(...).start()，核心不是“怎么启动一个线程”，而是“如何以声明式、可组合、可错误处理的方式执行异步任务”。它不直接替代 Thread 的底层控制，而是封装并管理线程调度，让开发者聚焦在“做什么”，而非“在哪做、怎么切线程”。
用 supplyAsync 启动异步计算（最常用）
传统写法：
new Thread(() -> {
String result = doHeavyWork();
System.out.println("结果：" + result);
}).start();
等价的 CompletableFuture 写法：
CompletableFuture.supplyAsync(() -> doHeavyWork())
.thenAccept(result -> System.out.println("结果：" + result));
说明：
立即学习“Java免费学习笔记（深入）”；
-
supplyAsync默认使用ForkJoinPool.commonPool()，无需手动创建/管理线程 - 任务自动提交执行，返回的
CompletableFuture可链式响应，天然支持回调 - 若需指定线程池（推荐生产环境这么做），传入自定义
Executor：
ExecutorService executor = Executors.newFixedThreadPool(4);
CompletableFuture.supplyAsync(() -> doHeavyWork(), executor)
.thenAccept(System.out::println);
区分 CPU 密集型和 I/O 密集型，选对线程池
直接用 commonPool 容易导致阻塞任务拖慢整个池。应按任务类型分离执行器：
Alibabacloud Sdk Client Initialization For Java
下载
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- CPU 密集型（如复杂计算、JSON 解析）：线程数 ≈ CPU 核心数，用
newFixedThreadPool(Runtime.getRuntime().availableProcessors()) - I/O 密集型（如 HTTP 调用、DB 查询）：线程数可适当放大（如 2×~4×核数），或用
newCachedThreadPool()（注意避免无限创建） - 关键：把
Executor作为参数显式传给supplyAsync、runAsync等方法
替代多线程协作：用 thenCompose / thenCombine 组合任务
传统多线程协作常靠 join() 或共享变量，容易出错。CompletableFuture 提供函数式编排：
-
thenCompose：前一个异步结果作为下一个异步任务的输入（扁平化嵌套） -
thenCombine：并行执行两个任务，合并结果 -
allOf/anyOf：等待多个异步任务完成或任一完成
示例：先查用户，再查其订单，最后合并展示
CompletableFuture<User> userFut = CompletableFuture.supplyAsync(() -> findUser(id));
CompletableFuture<Order> orderFut = CompletableFuture.supplyAsync(() -> findOrder(userId));
userFut.thenCombine(orderFut, (user, order) -> new UserWithOrder(user, order))
.thenAccept(System.out::println);
异常处理不能靠 try-catch 包裹 runAsync
runAsync 和 supplyAsync 内部抛出的异常不会打断主线程，但会静默失败——必须显式处理：
-
exceptionally(Function)：捕获异常，返回默认值或兜底结果 -
handle(BiFunction)：无论成功或失败都执行，统一处理 -
whenComplete(BiConsumer)：仅做副作用（如打日志、清理资源），不改变结果
错误示范（异常被吞）：
CompletableFuture.runAsync(() -> {
throw new RuntimeException("出错了");
}); // ← 不加 exceptionally，这个异常你看不到
正确做法：
CompletableFuture.runAsync(() -> {
throw new RuntimeException("出错了");
}).exceptionally(throwable -> {
log.error("任务失败", throwable);
return null;
});
不复杂但容易忽略：CompletableFuture 是异步编程的“胶水”，它本身不创建线程，而是委托给 Executor；真正替代的是“手管线程+手工同步+手动异常传播”这一整套低效模式。
