haskell “双”构图与CompletableFuture

mfuanj7w  于 2022-11-14  发布在  其他
关注(0)|答案(2)|浏览(185)

当两个独立的值与返回第三个值的BiFunction组合时,我试图避免嵌套CompletableFuture。目前,使用thenCombine()并不能解决这个问题:

// 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) {...}

如果有CompletableFuture单子的话,我基本上是想找到一种看起来像haskell的方法:

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

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

我在某个地方读到join()是Completable future的flatMap,所以我想我可以用这个方法来做类似aFuture.thenCombine(bFuture, ((Function<CompletableFuture<C>,C>) CompletableFuture::join).compose(this::makeSomeC)的事情,但是我不确定这是不是正确的/建议的方法。我不能说这在任何方面都有助于可读性...

5fjcxozz

5fjcxozz1#

对我来说,thenCompose看起来就像是Haskell Monad.bind的直接等价物。
thenCompose的嵌套方式与Haskell monad bind相同,它也是Haskell中do表达式的结果。

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

类型说明

这可以通过检查函数的类型来看出。
Monad绑定--在Haskell中写成>>=--具有以下类型:

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

thenCompose在Java中具有以下签名:

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接口来表达的。

注意问题中的Haskell代码

但是我对你的Haskell代码有点困惑。在我看来,你的Haskell代码似乎在做以下事情:

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

也就是说,等待makeSomeA操作完成,然后再开始makeSomeB。另一方面,Java代码并行启动两个操作,然后等待结果,然后再开始C。但这可能是一种懒惰。

qco9c6ql

qco9c6ql2#

我想最简单的解决方案就是在之后应用一个thenCompose(identity())

public CompletableFuture<C> doStuff() {
    CompletableFuture<A> aFuture = makeSomeA();
    CompletableFuture<B> bFuture = makeSomeB();
    CompletableFuture<CompletableFuture<C>> cFuture = aFuture.thenCombine(bFuture, this::makeSomeC);
    return cFuture.thenCompose(Function.identity());
}

或者,引入一个简单的Pair类来合并A和B的结果,并使用thenCompose()

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

private static class Pair<A, B> {
    A a;
    B b;

    public Pair(A a, B b) {
        this.a = a;
        this.b = b;
    }
}

没有Pair的第三种选择:

public CompletableFuture<C> doStuff() {
    CompletableFuture<A> aFuture = makeSomeA();
    CompletableFuture<B> bFuture = makeSomeB();
    CompletableFuture<Void> cFuture = CompletableFuture.allOf(aFuture, bFuture);
    return cFuture.thenCompose(__ -> makeSomeC(aFuture.join(), bFuture.join()));
}

相关问题