为什么CompletableFuture调用join后无后续输出且会阻塞线程？

示例代码如下：

CompletableFuture<HttpResponse<String>> completableFuture =
        client.sendAsync(request, HttpResponse.BodyHandlers.ofString());
completableFuture
        .thenApplyAsync(HttpResponse::headers)
        .thenAcceptAsync(System.out::println);
HttpResponse<String> response = completableFuture.join();

System.out.println("test");

核心原因 #

• 请求无响应/未配置超时：默认JDK HttpClient 没有配置超时的话，发起的异步请求如果遇到网络阻塞、目标服务无返回等情况，会一直处于等待状态，对应的CompletableFuture永远不会进入完成态。而join()是同步阻塞方法，会无限等待Future完成，导致后续代码全部卡住。
• 线程池资源耗尽：sendAsync、thenApplyAsync、thenAcceptAsync如果没有指定自定义线程池，默认使用JDK公共ForkJoinPool，该池默认线程数为CPU核心数减1。如果有大量异步任务占用了所有池线程、任务队列也被占满，当前Future的任务和回调都无法分配到执行资源，会导致Future永远无法完成，join()持续阻塞。
• 异常未被捕获处理：如果异步请求执行过程中抛出异常（比如连接失败、SSL校验不通过、参数错误），异常会被封装到CompletableFuture中。调用join()时会直接抛出未捕获的CompletionException，如果上层逻辑吞掉了异常且没有打印日志，就会表现为没有任何输出、后续代码不执行。

解决方案 #

• 给HttpClient和HttpRequest都配置超时时间，避免无限等待：

// 配置客户端连接超时
HttpClient client = HttpClient.newBuilder()
        .connectTimeout(Duration.ofSeconds(10))
        .build();
// 配置请求整体超时
HttpRequest request = HttpRequest.newBuilder()
        .uri(URI.create("你的请求地址"))
        .timeout(Duration.ofSeconds(15))
        .build();

• 调用join()时主动捕获异常，避免未捕获异常中断流程：

try {
    HttpResponse<String> response = completableFuture.join();
    System.out.println("test");
} catch (CompletionException e) {
    // 打印异常排查问题
    e.printStackTrace();
    // 自定义异常处理逻辑
}

• 高并发场景下给异步回调指定独立的自定义线程池，避免公共池资源耗尽：

ExecutorService customAsyncPool = Executors.newFixedThreadPool(10);
completableFuture
        .thenApplyAsync(HttpResponse::headers, customAsyncPool)
        .thenAcceptAsync(System.out::println, customAsyncPool);

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