Java中CompletableFuture.thenApply未按预期阻塞的原因问询

在Java 17的Spring Boot应用中，直接从main方法调用测试代码时，遇到了不符合预期的异步行为。根据认知，CompletableFuture.thenApply()应该是阻塞式的，但实际表现却和thenApplyAsync()一致，主线程在调用thenApply()的代码行并未被阻塞。

测试代码 #

System.out.println("Main Thread: " + Thread.currentThread().getName());

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    try {
        TimeUnit.SECONDS.sleep(5);
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }

    var otherThread = Thread.currentThread().getName();
    System.out.println("Future Thread: " + otherThread);

    return otherThread;
});

System.out.println("Code before thenApply: " + Thread.currentThread().getName());
var result = future.thenApply(res -> {
    System.out.println("Future Thread in Result: " + res);

    System.out.println("Then Apply Thread: " + Thread.currentThread().getName());

    return res;
});

System.out.println("Code after thenApply: " + Thread.currentThread().getName());

try {
    var finalResult = result.get();
    System.out.println("Code after get: " + Thread.currentThread().getName());
    System.out.println("After get result:" + finalResult);

} catch (InterruptedException e) {
    throw new RuntimeException(e);
} catch (ExecutionException e) {
    throw new RuntimeException(e);
}

运行日志 #

Main Thread: main
Code before thenApply: main
Code after thenApply: main
Future Thread: ForkJoinPool.commonPool-worker-1
Future Thread in Result: ForkJoinPool.commonPool-worker-1
Then Apply Thread: ForkJoinPool.commonPool-worker-1
Code after get: main
After get...ForkJoinPool.commonPool-worker-1

你对thenApply()的理解存在误区：thenApply()本身并不会阻塞调用它的线程，它的作用只是注册一个回调函数，当上游CompletableFuture完成时，这个回调才会被执行。

回调的执行线程遵循以下规则：

• 如果上游future在调用thenApply()之前就已经完成，回调会在当前调用thenApply()的线程（这里是main线程）同步执行，此时主线程会执行回调逻辑，看起来像是“阻塞”。
• 如果上游future还未完成，回调会由完成上游future的那个线程来执行（这里就是ForkJoinPool.commonPool-worker-1），调用thenApply()的主线程会直接继续往下走，不会等待回调执行。

在你的测试代码中，supplyAsync()里有5秒的休眠，当主线程调用thenApply()时，上游future还在执行中并未完成。因此thenApply()的回调逻辑会在完成future的ForkJoinPool线程中执行，主线程不会被阻塞，直接走到Code after thenApply的打印步骤。

而thenApplyAsync()的区别在于，不管上游future是否完成，回调都会提交到指定的线程池（默认是ForkJoinPool）执行，不会占用调用线程或上游完成线程。

你看到的日志完全符合这个逻辑：主线程注册完回调后继续执行，5秒后future完成，由它所在的线程执行thenApply()的回调，最后主线程调用get()时才会等待整个流程完成，执行后续逻辑。

内容的提问来源于stack exchange，提问作者Ivan M