链少可完成未来操作

Question

我有几个单独的操作，我想以与JS中的promise相同的风格链接这些操作。

所以目前我有这样的代码：

    CompletableFuture<Data1> data1 = ...;
    CompletableFuture<Data2> data2 = ...;

    // Fetch in parallel!
    CompletableFuture.allOf(
            data1,
            data2
    ).join(); // wait 2 threads to finish

    CompletableFuture<Data3> data3 = ... // i need data1 here
    data3.join();

可以在一个链中重写吗？有点：

CompletableFuture.allOf(
        data1,
        data2
)
.then((result1, result2) -> return another CompletableFuture)
.then(result3 -> { ...do other stuff here})

Answer 1

CompletableFuture.allOf（…）返回CompletableFuture

给定CompletableFuture的结果（如果有）不会反映在返回的CompletableFuture中，但可以通过单独检查它们来获得。

因此，如果要使用 data1 和 data2 的返回值，则必须获取它们。

Answer 2

使用allOf时，无法在输入期货上调用join以获取依赖函数中的值（尽管您会知道这些调用不会阻塞）。

但是，当您正好有两个期货要组合时，就没有必要使用< code > allOf ；您可以顺利地将它们结合起来:

CompletableFuture<FinalResult> f = data1
    .thenCombine(data2, (result1, result2) -> another CompletableFuture)
    .thenCompose(Function.identity())
    .thenAccept(result3 -> …);

thenAccept将评估将结果值映射到新结果值的函数，而thenCompose将评估将一个结果值映射至新未来的函数。方法thenCombine是theAccept的两个未来变体，允许将两个值映射到一个新值。

但thenCombine没有两个未来变体，因此解决方案是将由两个中间值创建的未来视为一个值（获取未来的未来），然后thenCompose（Function.identity（））来将“值”映射到未来。然后，在未来完成后，我们可以链接一个函数来处理第三个结果。