supplyAsync用于异步执行有返回值任务，返回CompletableFuture，默认用ForkJoinPool.commonPool()；需显式指定线程池避免阻塞影响，用join()/get()获取结果，支持thenApply等链式处理及exceptionally异常处理。
Java 中用 supplyAsync 异步执行有返回值的任务，核心是传入一个 Supplier<T> 函数式接口，并返回一个 CompletableFuture<T> 对象。 它默认使用 ForkJoinPool.commonPool() 执行任务，适合轻量、无阻塞的计算型操作。
基本用法：启动异步任务并获取结果
直接传入 lambda 表达式，返回值类型自动推导：
- 任务体必须有返回值（不能是
void），否则编译不通过 - 返回的是
CompletableFuture<String>，不是原始结果，需调用join()或get()获取 -
join()不抛受检异常，get()会抛ExecutionException和InterruptedException
示例：
JavaStoryDevelop
下载
你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。 它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在
CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
return "Hello from async";
});
<p>String result = future.join(); // 阻塞等待，返回 "Hello from async"
指定自定义线程池避免影响公共池
默认使用 commonPool，若任务含 I/O 或阻塞操作，容易拖慢其他异步任务。推荐显式传入线程池：
立即学习“Java免费学习笔记（深入）”；
- 用
Executors.newFixedThreadPool(n)或newCachedThreadPool()创建 - 注意线程池生命周期管理，长期运行应用建议复用或手动关闭
- 传入第二个参数：
supplyAsync(Supplier, Executor)
示例：
ExecutorService executor = Executors.newFixedThreadPool(4);
CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
return 42 * 2;
}, executor);
<p>int value = future.join();
executor.shutdown(); // 用完记得关闭（视场景而定）
链式处理返回值：thenApply、thenAccept、thenCompose
拿到异步结果后，通常需要进一步转换、消费或组合。常用后续操作：
-
thenApply(fn)：对结果做转换，返回新的CompletableFuture（如String → Integer） -
thenAccept(consumer)：只消费结果，不返回新 future（适合日志、存储等副作用） -
thenCompose(fn)：当转换函数本身也返回CompletableFuture时用，避免嵌套 future
示例（链式转换）：
CompletableFuture<String> future = CompletableFuture
.supplyAsync(() -> "hello")
.thenApply(s -> s.toUpperCase())
.thenApply(s -> s + " WORLD");
<p>System.out.println(future.join()); // 输出 "HELLO WORLD"
异常处理：exceptionally 和 handle
异步任务可能抛异常，不能用传统 try-catch 包裹。应使用：
-
exceptionally(Function<Throwable, T>)：捕获异常并提供默认返回值（类型需与原始 future 一致） -
handle(BiFunction<T, Throwable, R>)：统一处理成功结果和异常，更灵活
示例：
CompletableFuture<Integer> future = CompletableFuture
.supplyAsync(() -> {
if (Math.random() > 0.5) throw new RuntimeException("Oops");
return 100;
})
.exceptionally(t -> {
System.err.println("Caught: " + t.getMessage());
return -1; // 返回默认值
});
<p>int result = future.join(); // 要么 100，要么 -1
不复杂但容易忽略线程池选择和异常传播机制，用对了才能真正发挥异步优势。
