CompletableFuture join()未按预期等待完成，顺序执行失效求助

问题原因 #

你现在的代码逻辑有个关键问题：调用getFuture(secondSet)的时候，内部已经通过CompletableFuture.runAsync把第二个任务的所有子任务提交到线程池了——也就是说第二个任务的子线程在你调用getFuture方法时就已经启动执行了，和后续的firstFuture.join()完全无关。这就导致第一个任务还在跑的时候，第二个的任务已经开始输出日志，自然会出现时间戳交叉的情况。

解决办法 #

方法一：延迟创建第二个Future（最直观） #

把第二个getFuture的调用放到第一个join之后，确保第一个任务完全完成后，再提交第二个任务的子线程：

public static void main() {
    Set<Object> firstSet = /* ... */
    Set<Object> secondSet = /* ... */

    CompletableFuture<Void> firstFuture = getFuture(firstSet);
    firstFuture.join(); // 等待第一个任务全部完成
    // 此时才创建并启动第二个任务
    CompletableFuture<Void> secondFuture = getFuture(secondSet);
    secondFuture.join();
}

方法二：用CompletableFuture的链式API（更贴合异步编程风格） #

利用thenCompose实现依赖顺序，避免显式的join嵌套：

public static void main() {
    Set<Object> firstSet = /* ... */
    Set<Object> secondSet = /* ... */

    CompletableFuture<Void> firstFuture = getFuture(firstSet);
    // 第一个任务完成后，再执行第二个任务的创建与执行
    CompletableFuture<Void> combinedFuture = firstFuture.thenCompose(ignored -> getFuture(secondSet));
    combinedFuture.join();
}

这里thenCompose会等待第一个future完成后，才会执行后面的getFuture(secondSet)，确保第二个任务的子线程是在第一个完全结束后才被提交到线程池。

关键注意点 #

• CompletableFuture的runAsync、supplyAsync方法会立即将任务提交到线程池，只要线程池有空闲线程就会启动执行，和你后续是否调用join没有关联。
• 如果你使用的线程池核心线程数较多，第一个任务的子线程还在执行时，第二个任务的子线程就会被调度，这是日志时间戳混乱的直接诱因。

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