CompletableFuture.allOf()我想实现和的混合,CompletableFuture.anyOf()其中一旦所有元素成功完成,返回的 future 就会成功完成,或者只要任何元素异常完成,它就会异常完成(具有相同的异常)。在多个元素失败的情况下,返回其中任何一个的异常就足够了。
我有一个任务需要聚合CompletableFutures 列表返回的子结果,但是一旦其中任何一个失败,该任务就应该停止等待。我知道子任务将继续运行,这没关系。
我发现等待未来的列表最初看起来像是一个重复的问题,但接受的答案使用CompletionService需要Callable或Runnable作为输入。我正在寻找一种将已运行的CompletionStages 作为输入的解决方案。