应使用 thenApply()、thenAccept() 或 whenComplete() 等非阻塞回调获取 supplyAsync() 结果，避免 get()/join() 阻塞主线程；I/O 任务须指定自定义线程池，异常需通过 exceptionally() 或 handle() 处理并解包 getCause()。
supplyAsync() 返回值怎么取，别直接 get() 阻塞主线程
调用 CompletableFuture.supplyAsync() 后拿到的是一个未完成的 CompletableFuture<t></t>，它本身不包含结果，只是个“承诺”。直接在主线程里调用 get() 或 join() 会阻塞当前线程，失去异步意义，尤其在 Web 请求或 UI 线程中极易引发超时或卡顿。
正确做法是用回调式组合：用 thenApply()、thenAccept() 或 whenComplete() 处理结果，让结果自然流入后续逻辑。
-
thenApply()：有返回值，适合转换结果（如把 String 转成 Integer） -
thenAccept()：无返回值，适合纯消费（如打印日志、存数据库） -
whenComplete()：无论成功失败都执行，第二个参数是Throwable，适合统一兜底处理
supplyAsync() 的两个重载版本，线程池选错容易拖垮系统
supplyAsync() 有两个签名：supplyAsync(Supplier) 和 supplyAsync(Supplier, Executor)。前者用的是 ForkJoinPool.commonPool()，这个共享池默认并行度 = CPU 核数 -1，一旦有 CPU 密集型任务长期占用，其他异步任务就会排队等待。
常见错误是没传 Executor，却在 supplyAsync() 里做数据库查询、HTTP 调用等 I/O 操作，导致 commonPool 被拖慢，连带影响 parallelStream() 等其它依赖它的功能。
- I/O 密集型任务（如 HTTP、DB）：显式传入自定义线程池，比如
Executors.newFixedThreadPool(20)或 Spring 的TaskExecutor - CPU 密集型任务：若必须用 commonPool，确保任务极轻量；否则也建议隔离线程池，避免干扰
- 不要在 Lambda 里捕获异常却不处理——
supplyAsync()内抛出的异常不会打断主线程，但会静默失败，除非你用exceptionally()或handle()显式接收
获取返回值时遇到 CompletionException，本质是原始异常被包装了
当你调用 join() 或 get() 时抛出 CompletionException，这不是新问题，而是 supplyAsync() 内部异常被封装了一层。真正的原因藏在 getCause() 里。
例如 supplyAsync(() -> { throw new SQLException("timeout"); })，最终抛出的是 CompletionException，但 e.getCause() 才是 SQLException。直接 catch CompletionException 容易漏掉业务逻辑判断。
- 调试时立刻打日志：
log.error("task failed", e.getCause()) - 用
exceptionally(Function<throwable t>)</throwable>提供降级值，注意参数是原始异常，不是CompletionException - 用
handle(BiFunction<t throwable r>)</t>统一收口，第一个参数是结果（可能为 null），第二个是异常（可能为 null）
多个 supplyAsync() 结果合并，别手写 await，用 allOf + join
要等多个异步任务都完成并收集返回值，别用循环加 get()，也不要用 CountDownLatch 手动同步。Java 自带组合工具：
CompletableFuture<String> a = CompletableFuture.supplyAsync(() -> "hello"); CompletableFuture<Integer> b = CompletableFuture.supplyAsync(() -> 123); CompletableFuture<Void> all = CompletableFuture.allOf(a, b); // allOf 返回的是 CompletableFuture<Void>，不携带结果 // 需要手动 join 并取值 String resultA = a.join(); Integer resultB = b.join();
注意 allOf() 不聚合泛型结果，只表示“全部完成”，值还得从原始 future 里单独取。如果需要自动打包（如转成 List<object></object>），得配合 thenApply() 手动构造，或者改用 CompletableFuture.allOf(...).thenApply(v -> Arrays.asList(a.join(), b.join())) ——但要小心 join() 在回调中是否仍属异步上下文。
更安全的方式是：每个 future 先用 thenApply() 把结果映射成容器对象，再用 allOf() + thenApply() 组装，避免在回调里意外阻塞。
