CompletableFuture.supplyAsync() 通过异步执行耗时操作实现非阻塞加载：1. 基础用法以 Supplier 提交任务，默认在 commonPool 执行，配合 thenAccept 处理结果、exceptionally 捕获异常；2. IO 密集型任务需指定自定义线程池避免阻塞；3. 主线程不调用 join/get，而是用 thenApply/thenAcceptAsync 或直接返回 CompletableFuture 给框架；4. 支持 allOf（并行）、anyOf（任一）、thenCombine（合并）、thenCompose（串行）等组合方式。
用 CompletableFuture.supplyAsync() 实现异步数据加载，核心是把耗时操作（如 HTTP 请求、数据库查询）放到独立线程执行，主线程立即返回、继续运行，不等待结果。
1. 基础写法：提交任务并链式处理
直接传入一个无参 Supplier，它会在 ForkJoinPool.commonPool()（默认）中异步执行：
- Supplier 返回你要加载的数据（比如一个 List<User> 或 String）
- 用
thenAccept()处理成功结果（在异步线程中执行） - 用
exceptionally()捕获异常，避免整个链中断
示例：
CompletableFuture.supplyAsync(() -> {
// 模拟远程调用或 DB 查询（会阻塞当前异步线程，但不阻塞主线程）
return userService.loadUsersByDept("tech");
})
.thenAccept(users -> {
// 主线程早已继续执行了，这里只是后续回调
System.out.println("加载到 " + users.size() + " 个用户");
})
.exceptionally(throwable -> {
System.err.println("加载失败：" + throwable.getMessage());
return null;
});
2. 指定自定义线程池（重要）
默认使用 commonPool，不适合 IO 密集型任务（如 HTTP、JDBC），容易导致线程饥饿。应显式传入专用于 IO 的线程池：
- 创建固定大小的 ThreadPoolExecutor（比如 10–50 核心线程），配合队列防爆
- 把线程池作为第二个参数传给 supplyAsync
- 避免在 commonPool 中执行 sleep、wait、数据库连接等阻塞操作
示例：
ExecutorService ioPool = Executors.newFixedThreadPool(20);
CompletableFuture.supplyAsync(() -> {
return httpClient.get("/api/users"); // 阻塞式 HTTP 调用
}, ioPool)
.thenAccept(response -> handleResponse(response))
.exceptionally(e -> { logError(e); return null; });
3. 主线程不等待，也不丢失结果
如果你需要把异步结果“带回”主线程上下文（比如更新 UI、组装响应），不要调用 join() 或 get() —— 这会重新阻塞。
- 用
thenApply()/thenCompose()做纯函数式转换 - 用
thenAcceptAsync()把消费逻辑也异步化（可指定 UI 线程池） - Web 场景下，直接返回 CompletableFuture 交给框架（Spring WebFlux/Boot 2.0+ 自动支持）
例如 Spring MVC 中可直接返回：
@GetMapping("/users")
public CompletableFuture<List<User>> listUsers() {
return CompletableFuture.supplyAsync(
() -> userService.findAll(),
ioPool
);
}
4. 组合多个异步加载（并行 or 串行）
多个数据源可并发拉取，提升整体响应速度：
-
CompletableFuture.allOf()：等待全部完成（适合无返回值场景） -
CompletableFuture.allOf(...).thenApply(v -> ...)+ 手动 collect：获取所有结果 -
CompletableFuture.anyOf()：只要一个完成就继续（适合降级或多源冗余） -
thenCompose()：前一个结果作为下一个异步任务的输入（串行依赖）
示例（并行加载用户 + 权限）：
CompletableFuture<User> userFut = CompletableFuture.supplyAsync(() -> loadUser(id), ioPool);
CompletableFuture<Permission> permFut = CompletableFuture.supplyAsync(() -> loadPerm(id), ioPool);
CompletableFuture<UserProfile> profileFut = userFut
.thenCombine(permFut, UserProfile::new); // 并行完成后合并
