当两个独立的值与返回第三个值的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)
的事情,但是我不确定这是不是正确的/建议的方法。我不能说这在任何方面都有助于可读性...
2条答案
按热度按时间5fjcxozz1#
对我来说,
thenCompose
看起来就像是HaskellMonad.bind
的直接等价物。thenCompose
的嵌套方式与Haskell monad bind相同,它也是Haskell中do表达式的结果。类型说明
这可以通过检查函数的类型来看出。
Monad绑定--在Haskell中写成
>>=
--具有以下类型:thenCompose
在Java中具有以下签名:上面的转换为Haskell语法,带有一个额外的参数作为显式的
this
,看起来像这样:我们可以看到它和Haskell类型有着相同的结构,不同的是名称不同,而且事实上Haskell对高级类型的支持并不是用Java接口来表达的。
注意问题中的Haskell代码
但是我对你的Haskell代码有点困惑。在我看来,你的Haskell代码似乎在做以下事情:
也就是说,等待
makeSomeA
操作完成,然后再开始makeSomeB
。另一方面,Java代码并行启动两个操作,然后等待结果,然后再开始C。但这可能是一种懒惰。qco9c6ql2#
我想最简单的解决方案就是在之后应用一个
thenCompose(identity())
:或者,引入一个简单的
Pair
类来合并A和B的结果,并使用thenCompose()
:没有
Pair
的第三种选择: