Java 中 CompletableFuture 怎么通过 supplyAsync 异步执行有返回值任务-java教程-PHP中文网

completablefuture.supplyasync()是java中启动异步任务并获取返回值的常用方式，使用forkjoinpool.commonpool()或自定义线程池执行supplier函数，支持链式转换（thenapply/thenaccept）、异常处理（exceptionally/handle）。

java 中 completablefuture 怎么通过 supplyasync 异步执行有返回值任务

CompletableFuture.supplyAsync() 是 Java 中启动异步任务并获取返回值最常用的方式之一。它内部默认使用 ForkJoinPool.commonPool()（或你指定的线程池），执行一个 Supplier<t></t> 函数，该函数必须有返回值，返回值会成为 CompletableFuture 的结果。

基本用法：无参 supplyAsync

适用于不需要外部参数、纯计算型任务：

CompletableFuture<string> future = CompletableFuture.supplyAsync(() -> {
    System.out.println("当前线程: " + Thread.currentThread().getName());
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    return "Hello from async";
});
<p>// 阻塞获取结果（生产环境慎用）
String result = future.join(); // 或 future.get()
System.out.println(result); // 输出：Hello from async
</p></string>

指定自定义线程池（推荐）

避免挤占公共线程池，提升可控性和稳定性：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

ExecutorService customPool = Executors.newFixedThreadPool(4);
<p>CompletableFuture<integer> future = CompletableFuture.supplyAsync(() -> {
return 42 * 2;
}, customPool); // 显式传入线程池</integer></p><p>Integer result = future.join();
System.out.println(result); // 输出：84</p><p>// 记得在合适时机关闭线程池（如应用关闭时）
// customPool.shutdown();
</p>

链式处理返回值（thenApply / thenAccept）

supplyAsync 返回的是 CompletableFuture<t></t>，可直接用后续方法消费或转换结果：

thenApply：对结果做转换，返回新的 CompletableFuture
thenAccept：消费结果（无返回），适合日志、通知等副作用操作

CompletableFuture<string> future = CompletableFuture.supplyAsync(() -> "world");
<p>// 转换为大写，并返回新 CompletableFuture
CompletableFuture<string> upperFuture = future.thenApply(s -> s.toUpperCase());</string></p>
<p>// 消费最终结果
upperFuture.thenAccept(System.out::println); // 输出：WORLD</p>
<p>// 或一步到位
CompletableFuture.supplyAsync(() -> "java")
.thenApply(String::toUpperCase)
.thenAccept(System.out::println);
</p></string>

异常处理：exceptionally / handle

supplyAsync 中抛出的异常不会中断主线程，但需显式捕获，否则调用 join() 或 get() 时会抛出 CompletionException：

exceptionally：仅在异常时提供备选值（类似 try-catch 的 catch 块）
handle：统一处理成功和异常（带结果和异常两个参数）

CompletableFuture<integer> future = CompletableFuture.supplyAsync(() -> {
    if (Math.random() > 0.5) throw new RuntimeException("随机失败");
    return 100;
});
<p>// 异常时返回默认值
Integer result = future.exceptionally(ex -> {
System.err.println("执行出错：" + ex.getMessage());
return -1;
}).join();</p>
<p>// 或更灵活的 handle
future.handle((value, ex) -> {
if (ex != null) {
System.err.println("失败：" + ex.getMessage());
return -1;
}
System.out.println("成功：" + value);
return value * 2;
}).join();
</p></integer>

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南