CompletableFuture，然后Compose方法

Question

我对函数的契约有一些误解

返回一个新的CompletionStage，当此阶段正常完成时，将此阶段作为提供函数的参数执行。

函数似乎接受这个完成阶段的结果，而不是完成阶段本身。那么这是什么意思呢？

那么由返回的CompletableFuture表示的任务呢？

Runnable r;
ExecutorService es;
Function<Void, CompletableFuture<Void>>f;
//...
CompletableFuture.runAsync(r, es)
.thenCompose(f);

这是否意味着，由返回的CompletableFuture表示的任务将在与可运行r相同的线程池中执行？

Answer 1

这似乎是JavaDoc中的一个错误。其他方法，例如thenApply使用以下公式：

返回一个新的CompletionStage，当此阶段正常完成时，该阶段将以此阶段的结果作为提供的函数的参数执行。[…]

（重点是我自己）

此外，在Java9中，现在的表述是：

返回一个新的CompletionStage，该阶段使用与给定函数返回的CompletionStage相同的值完成。

当该阶段正常完成时，调用给定函数，并将该阶段的结果作为参数，返回另一个CompletionStage。当该阶段正常完成时，此方法返回的CompletionStage将使用相同的值完成。[…]

至于哪个线程/线程池将执行该函数，这实际上取决于实现。

对于CompletableFuture，这在文档顶部显示：

为非异步方法的依赖完成提供的操作可以由完成当前CompletableFuture的线程或完成方法的任何其他调用者执行。

在实践中，似乎有两种可能的情况：

1. 如果此阶段已经完成，则该函数将立即应用于调用thencose（）的线程

请注意，在可完成的未来中没有“任务”。返回的CompletableFuture所做的唯一“任务”是将传递函数返回的结果与自身绑定。您负责执行将完成函数返回的CompletableFuture的任务。