首页 / Concurrency / CompletableFuture 链式调用
Concurrency 中级

CompletableFuture 链式调用

使用 CompletableFuture 链式异步操作，无需阻塞。

代码对比
✕ Pre-Java 8 
Future<String> future =
    executor.submit(this::fetchData);
String data = future.get(); // blocks
String result = transform(data);
✓ Java 8+ 
CompletableFuture.supplyAsync(
    this::fetchData
)
.thenApply(this::transform)
.thenAccept(IO::println);
发现此代码有问题？ 告诉我们。
为什么现代方式更好
🔗

可链式调用

将异步步骤组合成可读的管道。

⚡

非阻塞

线程不会等待中间结果——只在需要时阻塞。

🔀

可组合

使用 thenCombine、allOf、anyOf 组合多个 Future。

旧方式
阻塞式 Future.get()
现代方式
CompletableFuture
自 JDK
8
难度
中级
JDK 支持
CompletableFuture 链式调用
可用

自 JDK 8 起广泛可用（2014 年 3 月）

工作原理

CompletableFuture 支持非阻塞异步管道。链式操作使用 thenApply、thenCompose 和 thenCombine，仅在最终结果需要时阻塞。

相关文档
CompletableFuture ↗
相关模式
Concurrency 高级

Stable values

Java 8
private volatile Logger logger;
Logger getLogger() {
    if (logger == null) {
        synchronized (this) {
            if (logger == null)
                logger = createLogger();
        }
    }
    return logger;
}
Java 25 (Preview)
private final StableValue<Logger> logger =
    StableValue.of(this::createLogger);

Logger getLogger() {
    return logger.get();
}
悬停查看现代版 ➜
JDK 25+ →
Concurrency 高级

Scoped values

Java 8
static final ThreadLocal<User> CURRENT =
    new ThreadLocal<>();
void handle(Request req) {
    CURRENT.set(authenticate(req));
    try { process(); }
    finally { CURRENT.remove(); }
}
Java 25
static final ScopedValue<User> CURRENT =
    ScopedValue.newInstance();
void handle(Request req) {
    ScopedValue.where(CURRENT,
        authenticate(req)
    ).run(this::process);
}
悬停查看现代版 ➜
JDK 25+ →
Concurrency 高级

Structured concurrency

Java 8
ExecutorService exec =
    Executors.newFixedThreadPool(2);
Future<User> u = exec.submit(this::fetchUser);
Future<Order> o = exec.submit(this::fetchOrder);
try {
    return combine(u.get(), o.get());
} finally { exec.shutdown(); }
Java 25 (Preview)
try (var scope = new StructuredTaskScope
        .ShutdownOnFailure()) {
    var u = scope.fork(this::fetchUser);
    var o = scope.fork(this::fetchOrder);
    scope.join().throwIfFailed();
    return combine(u.get(), o.get());
}
悬停查看现代版 ➜
JDK 25+ →
分享 𝕏 🦋 in ⬡