java - 可完成的 future | thenApply 与 thenCompose

Question

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

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

来自 Java 文档:

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

Returns a new CompletionStage that, when this stage completesnormally, is executed with this stage's result as the argument to thesupplied function.

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

Returns a new CompletionStage that, when this stage completesnormally, is executed with this stage as the argument to the suppliedfunction.

我知道 thenCompose 的第二个参数扩展了 thenApply 没有的 CompletionStage。

有人可以提供一个示例，在这种情况下我必须使用 thenApply 以及何时使用 thenCompose？

Answer 1

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

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

如果您有异步映射函数(即返回 CompletableFuture 的函数)，则使用

thenCompose。然后它将直接返回带有结果的 future ，而不是嵌套的 future 。

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