如何调试CompletableStage死锁问题？

我完全懂这种异步死锁有多棘手！尤其是当依赖关系藏在业务逻辑深处，甚至牵扯到多个三方组件时，排查起来简直像拆盲盒——明明代码看起来都没问题，程序就是莫名卡住不动。结合我踩过的坑，给你梳理下这类问题的核心原因、排查思路和解决办法：

为什么会出现这种死锁？ #

本质上是循环依赖+不当的阻塞调用搞的鬼：

• 两条（或多条）CompletionStage链互相等待对方的结果，比如链A在某个步骤调用了chainB.join()/chainB.get()，而链B反过来也在等待链A的结果；
• 如果这些阻塞操作都在同一个线程池里执行，线程池的线程会被全部占满，每条链都卡在等待对方释放资源的状态，最终形成死锁。

举个最直白的错误示例：

// 链A：依赖链B的结果，用阻塞的join()获取
CompletableFuture<String> chainA = CompletableFuture.supplyAsync(() -> {
    try {
        return "A的结果依赖：" + chainB.join();
    } catch (Exception e) {
        throw new RuntimeException("链A执行失败", e);
    }
});

// 链B：反过来依赖链A的结果，同样用join()阻塞
CompletableFuture<String> chainB = CompletableFuture.supplyAsync(() -> {
    try {
        return "B的结果依赖：" + chainA.join();
    } catch (Exception e) {
        throw new RuntimeException("链B执行失败", e);
    }
});

// 调用时直接死锁
String result = chainA.join();

怎么排查这类隐藏的死锁？ #

1. dump线程栈：这是最直接的方法。找到卡住的进程，导出线程栈（比如Java用jstack命令），找那些状态为WAITING且阻塞在CompletableFuture.join()/get()的线程，查看它们等待的Future对应的任务ID，顺着依赖关系找循环点。
2. 梳理依赖图谱：把涉及的CompletionStage节点逐个列出来，标记每个节点依赖的前置任务，哪怕是跨模块、跨服务的依赖，画成图后很容易发现循环的环。
3. 加关键日志：在每个CompletionStage的thenApply()/thenCompose()等节点加上日志，标记任务的开始、结束时间和状态，看哪些任务一直停留在PENDING状态，锁定可疑的依赖链。

解决与预防方案 #

1. 尽量用非阻塞链式调用代替阻塞操作 #

这是从根源上避免死锁的最佳方式。CompletionStage提供了大量非阻塞的组合方法，比如thenCompose()、thenCombine()、whenComplete()，让异步操作自然流转，不要手动调用join()/get()来阻塞等待。

比如如果链A需要链B的结果，应该写成：

CompletableFuture<String> chainB = CompletableFuture.supplyAsync(() -> "B的结果");
// 用thenCompose串联，完全非阻塞
CompletableFuture<String> chainA = chainB.thenCompose(bResult -> 
    CompletableFuture.supplyAsync(() -> "A处理" + bResult)
);

2. 消除业务上的循环依赖 #

很多时候异步死锁的根源是业务逻辑本身存在循环依赖，比如A服务需要B服务的结果，B服务又需要A服务的结果。这种情况下要先梳理业务，把公共依赖抽出来做成独立的异步任务，让所有链都依赖这个公共任务，而不是互相依赖。

3. 合理分配线程池 #

如果确实需要使用阻塞调用，不要让所有异步任务都共用同一个线程池：

• 给不同的业务链分配独立的线程池，避免一条链的阻塞操作占满整个线程池；
• 调整线程池的核心大小和最大大小，确保有足够的线程处理等待中的任务。

4. 给异步操作加超时机制 #

即使不小心出现死锁，也能快速发现问题而不是一直卡住。可以用CompletableFuture.orTimeout()或者completeOnTimeout()给任务加上超时时间：

CompletableFuture<String> chainA = CompletableFuture.supplyAsync(() -> {
    // 业务逻辑
})
.orTimeout(5, TimeUnit.SECONDS); // 5秒超时

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