嵌套期货未执行

Question

我遇到了一个奇怪的情况。我正在摆弄CompletableFuture，当运行以下代码时，我得到了意想不到的结果：

public static void main(String[] args) {     
    CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<Object>>>>>> completableFutureCompletableFuture = CompletableFuture.supplyAsync(() -> {
        System.out.println("first");
        return CompletableFuture.supplyAsync(() -> {
            System.out.println("second");
            return CompletableFuture.supplyAsync(() -> {
                System.out.println("third");
                return CompletableFuture.supplyAsync(() -> {
                    System.out.println("fourth");
                    return CompletableFuture.supplyAsync(() -> {
                        System.out.println("fifth");
                        return CompletableFuture.completedFuture(null);
                    });
                });
            });
        });
    });

   completableFutureCompletableFuture.get();
}

没有抛出异常（即使使用时exceptionally），我看到的是控制台输出是

first
second
third // appears sometimes

现在，显然这段代码没有真正的生产价值，但这代表了一种情况，即您的代码具有未知数量的嵌套，其中每个或其中一些嵌套创建的嵌套CompleteableFutures将不会被执行。

任何解释（以及如何修复的示例）将不胜感激

Answer 1

这不起作用的原因是，在您的简单测试中，虚拟机在所有任务完成之前退出。

当您调用时，completableFutureCompletableFuture.get()期货的第一次嵌套就保证已完成。虚拟机退出，所有线程都被终止。

换句话说，第一个嵌套的 future 可能仍然“未完成”，因为它的线程可能仍然很忙。但是，当您尝试使用它获取结果时，get当然会等到它完成并且它会按预期工作。你试一试：

completableFutureCompletableFuture.get().get().get().get().get()

...然后你强制所有 future 完成并且一切都按预期进行。

Answer 2

发生这种情况是因为您的 CompletableFuture 是异步执行的，但您的程序在第五次调用发生之前终止（我假设您在单个 main 中运行它并在创建 future 后立即返回）。

因为您可能不知道您的 Future 中堆叠了多少个 Future（由于类型擦除）。您可能想要执行递归 .get()。

看 ：

public static void main(String[] args) throws InterruptedException, ExecutionException {

    CompletableFuture<?> futures = getFutures();
    recursiveGet(futures);
    System.out.println("finished");

}

public static CompletableFuture<?> getFutures() {
    CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<CompletableFuture<Object>>>>>> compositeCompletable = CompletableFuture.supplyAsync(() -> {
        System.out.println("first");
        return CompletableFuture.supplyAsync(() -> {
            System.out.println("second");
            return CompletableFuture.supplyAsync(() -> {
                System.out.println("third");
                return CompletableFuture.supplyAsync(() -> {
                    System.out.println("fourth");
                    return CompletableFuture.supplyAsync(() -> {
                        System.out.println("fifth");
                        return CompletableFuture.completedFuture(null);
                    });
                });
            });
        });
    });
    return compositeCompletable;
}

public static void recursiveGet(Future<?> future) throws InterruptedException, ExecutionException{
    Object result = future.get();
    if(result instanceof Future){
        recursiveGet((Future<?>) result);
    }
}

返回

first
second
third
fourth
fifth
finished