CompletableFuture | thenApply与thenCompose

Question

我无法理解thenApply(）和之间的区别thenCompose()。

那么，有人可以提供有效的用例吗？

从Java文档中：

thenApply(Function<? super T,? extends U> fn)

返回一个新值CompletionStage，当此阶段正常完成时，将使用该阶段的结果作为所提供函数的参数来执行该操作。

thenCompose(Function<? super T,? extends CompletionStage<U>> fn)

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

我得到thenCompose扩展的CompletionStage 的第二个参数，而thenApply没有扩展。

有人可以提供一个例子，说明我必须在什么情况下使用thenApply以及何时使用thenCompose？

Answer 1

thenApply 如果您具有同步映射功能，则使用。

CompletableFuture<Integer> future = 
    CompletableFuture.supplyAsync(() -> 1)
                     .thenApply(x -> x+1);

thenCompose如果您具有异步映射函数（即返回a的函数CompletableFuture），则使用。然后它将直接返回带有结果的Future，而不是嵌套的Future。

CompletableFuture<Integer> future = 
    CompletableFuture.supplyAsync(() -> 1)
                     .thenCompose(x -> CompletableFuture.supplyAsync(() -> x+1));