CompletableFuture的多个thenAccep块的执行顺序是什么

Question

所以我有一个方法，返回一个完整的未来。在返回之前，该方法添加了一个带有accept的块，该块在CompletableFuture完成后执行。

此方法的调用者还添加了另一个块，其中包含和accept。显然，这可以在多个链式调用中继续进行。

thenAccess调用返回的CompletionStage以什么顺序执行？它是否保证是它们添加的顺序？如果不是，如何保证它们按照添加的顺序执行？

PS：我是根据自己对CompletableFuture和本文的经验提出这个问题的




Answer 1

您正在通过链接来建模完成阶段的依赖关系。如果将两个动作A和B链接到另一个动作C，则定义了关系A→ C和B→ C，但A和B之间没有关系，因此，它们之间没有关系，包括没有排序关系，换句话说，你甚至不能假设一个会在另一个之后运行，例如。

CompletableFuture<String> base=CompletableFuture.supplyAsync(() -> {
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
    return "source";
});
base.thenAccept(s -> {
    System.out.println("entered first consumer in "+Thread.currentThread());
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
    System.out.println("leaving first consumer");
});
LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
base.thenAccept(s -> {
    System.out.println("entered second consumer in "+Thread.currentThread());
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
    System.out.println("leaving second consumer");
});

很可能会打印以下内容

entered first consumer in Thread[ForkJoinPool.commonPool-worker-1,5,main]
entered second consumer in Thread[main,5,main]
leaving second consumer
leaving first consumer

当然，这并不能保证。

为了加强两个消费者之间的依赖性，你必须适当地将他们联系起来，例如：。

CompletableFuture<String> base=CompletableFuture.supplyAsync(() -> {
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
    return "source";
});
CompletableFuture<Void> next = base.thenAccept(s -> {
    System.out.println("entered first consumer in "+Thread.currentThread());
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
    System.out.println("leaving first consumer");
});
LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(2));
base.thenAcceptBoth(next, (s,ignored) -> {
    System.out.println("entered second consumer in "+Thread.currentThread());
    LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
    System.out.println("leaving second consumer");
}).join();

在这里，第二个消费者被链接到基础和下一个，以从基础接收结果，但取决于下一个的完成情况（如果没有结果要传递，您通常不需要这样做，如果您有这样的场景，您可能想重新考虑您的设计）。

或者，您可以将第一个消费者转换为通过值的函数，这样您可以通过应用将其链接，以允许将另一个接受阶段链接到它。