java - 具有CompletableFuture的“Double”组成

我试图避免将2个独立的CompletableFuture与返回第三个的BiFunction结合使用时嵌套thenCombine()。
当前，使用CompletableFuture不会削减它:

// What I have
public CompletableFuture<CompletableFuture<C>> doStuff() {
    CompletableFuture<A> aFuture = makeSomeA();
    CompletableFuture<B> bFuture = makeSomeB();
    CompletableFuture<CompletableFuture<C>> cFuture = aFuture.thenCombine(bFuture, this::makeSomeC);
    return cFuture;
}

// What I want
public CompletableFuture<C> doStuff() {
    CompletableFuture<A> aFuture = makeSomeA();
    CompletableFuture<B> bFuture = makeSomeB();
    // obv this method does not exist
    CompletableFuture<C> c = aFuture.thenBicompose(bFuture, this::makeSomeC);
}

private CompletableFuture<A> makeSomeA() {...}
private CompletableFuture<B> makeSomeB() {...}
private CompletableFuture<C> makeSomeC(A a, B b) {...}

我基本上是试图找到一种方法，如果有一个join() monad，它看起来就像haskell:

doStuff :: CompletableFuture C
doStuff = do
    a <- makeSomeA
    b <- makeSomeB
    makeSomeC a b

makeSomeA :: CompletableFuture A
makeSomeB :: CompletableFuture B
makeSomeC :: A -> B -> CompletableFuture C

我在某处读到flatMap是可完成的 future 的aFuture.thenCombine(bFuture, ((Function<CompletableFuture<C>,C>) CompletableFuture::join).compose(this::makeSomeC)，所以我认为我可以使用此方法来执行类似ojit_code的操作，但是我不确定这是正确/建议的方法。我不能说这以任何方式都有助于提高可读性...

最佳答案

在我看来，thenCompose与Haskell Monad.bind直接等效。

可以使用与Haskell monad绑定(bind)相同的方式嵌套thenCompose，这也是Haskell中do-expression的结果。使用它可以像下面这样解决您的问题:

public CompletableFuture<C> doStuff() {
    CompletableFuture<A> aFuture = makeSomeA();
    CompletableFuture<B> bFuture = makeSomeB();
    return aFuture.thenCompose(a -> bFuture.thenCompose(b -> makeSomeC(a, b)));
}

类型说明

通过检查功能的类型可以看出这一点。

Monad绑定(bind)-在Haskell中用>>=编写-具有以下类型:

(>>=) :: Monad m => m a -> (a -> m b) -> m b

Java中的thenCompose具有以下签名:

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

上面的代码转换为Haskell语法，带有一个额外的参数作为显式this，如下所示:

thenCompose :: CompletionStage T -> (T -> CompletionStage U) -> CompletionStage U

我们可以看到它具有与Haskell类型相同的结构。区别在于名称，而Haskell对更高种类的支持并不完全由Java接口(interface)表达。

注意问题中的Haskell代码

但是您的Haskell代码让我有些困惑。在我看来，您的Haskell代码正在执行以下操作:

public CompletableFuture<C> doStuff() {
    return makeSomeA().thenCompose(a -> makeSomeB().thenCompose(b -> makeSomeC(a, b)));
}

也就是说，等待makeSomeA操作完成之后再开始makeSomeB。另一方面，Java代码并行启动这两个操作，然后在开始使用C之前等待结果。但是也许这是懒惰的事情。