supplyAsync() 应显式传入自定义线程池（如newFixedThreadPool），避免默认commonPool争用；异常需用exceptionally()或handle()显式处理；thenApply()不新开线程，耗时操作须用thenApplyAsync()并指定线程池；禁止在lambda中new Thread。
supplyAsync() 的基本用法和线程池选择
CompletableFuture.supplyAsync() 用来异步执行一个有返回值的 Supplier<T>，它默认使用 ForkJoinPool.commonPool()。但这个公共池是共享的，如果任务耗时长或数量多，容易拖慢其他也用 commonPool 的组件（比如并行流、其他 CompletableFuture），甚至引发拒绝异常。
实际项目中，应该显式传入自定义线程池：
ExecutorService executor = Executors.newFixedThreadPool(4);
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
// 模拟耗时 IO 或计算
Thread.sleep(1000);
return "done";
}, executor);
- 避免用
Executors.newCachedThreadPool()：可能无限制创建线程，OOM 风险高 - 推荐用
newFixedThreadPool(n)或newThreadPoolBuilder().build()（Java 21+） - 线程数不是越多越好，IO 密集型可设为 CPU 核数 × 2～4，CPU 密集型接近核数即可
如何处理 supplyAsync() 中抛出的异常
supplyAsync() 内部抛出的异常不会直接炸掉主线程，而是被封装进 CompletableFuture 的完成状态里。如果不主动处理，调用 get() 时才会以 ExecutionException 包裹抛出，且堆栈顶层看不出原始异常位置。
更安全的做法是用 handle() 或 exceptionally() 显式捕获：
立即学习“Java免费学习笔记（深入）”；
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
if (Math.random() > 0.5) throw new RuntimeException("oops");
return 42;
}).exceptionally(ex -> {
System.err.println("Caught: " + ex.getMessage());
return -1; // 提供兜底值
});
-
exceptionally()只在异常时触发，返回类型必须和原始 future 一致 -
handle()总会执行，接收(result, exception)两个参数，适合做统一日志或转换 - 别在
supplyAsync()lambda 里 try-catch 吞掉异常——这会让错误静默，调试困难
supplyAsync() 和 thenApply() 的组合陷阱
很多人以为 supplyAsync() 后接 thenApply() 就是“异步执行 + 异步转换”，其实 thenApply() 默认在前一个 stage 完成的**同一线程**上执行（即 supplyAsync 的线程），不是新开线程。这意味着：如果 thenApply() 里做了耗时操作，会阻塞该线程，影响后续任务调度。
需要真正异步转换，得用 thenApplyAsync()，并传入自己的线程池：
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "hello", ioExecutor)
.thenApplyAsync(s -> s.toUpperCase(), cpuExecutor); // 明确分离 IO 和 CPU 任务
-
thenApply()：轻量转换（如字段提取、简单映射），复用前序线程 -
thenApplyAsync()：重计算、加锁、DB 查询等，必须指定线程池，否则掉进 commonPool 争抢坑 - 不要混用默认和带 Executor 的版本——行为不一致，代码难维护
为什么不能直接在 supplyAsync() 里写 new Thread(...).start()
有人想“手动控制线程”，在 supplyAsync() 的 lambda 里 new Thread 并 start，这是错的：
// ❌ 错误示范
CompletableFuture.supplyAsync(() -> {
new Thread(() -> {
System.out.println("I'm in a rogue thread");
}).start();
return "done"; // 这个 return 立刻发生，future 状态已完成，和上面的线程无关
});
-
supplyAsync()的 lambda 必须**同步返回结果**，它不等待你内部 spawn 的线程 - 这样写会导致 future 提前完成，而新线程变成孤儿，无法链式处理、无法异常传播、无法取消
- 真要多线程协作，应拆成多个
supplyAsync()+allOf()/anyOf()组合
异步的本质是“交由线程池调度并返回可监听的句柄”，不是自己 new Thread。
