将可完成功能列表转换为列表的一个可完成未来

Question

我有一个CompletableFuture实例列表。

List<CompletableFuture<String>> listOfFutures;

如何将他们转变成这样一个未来:

CompletableFuture<List<String>> futureOfList = convert(listOfFutures);

Answer 1

你可以这样做：

public static <T> CompletableFuture<List<T>> convert(List<CompletableFuture<T>> futures) {
    return futures.stream().
            map(f -> f.thenApply(Stream::of)).
            reduce((a, b) -> a.thenCompose(xs -> b.thenApply(ys -> concat(xs, ys)))).
            map(f -> f.thenApply(s -> s.collect(toList()))).
            orElse(completedFuture(emptyList()));
}

Answer 2

这是一元序列运算。用cyclops-monad-api(我写的一个库)你可以写

   AnyM<Stream<String>> futureStream = AnyMonads.sequence(
              AsAnyMList.completableFutureToAnyMList(futures));

   CompletableFuture<Stream<String>> futureOfList = futureStream.unwrap();

当您在FutureOfList内的Stream上调用终端操作时，例如转换为List，它将触发对所有原始期货的连接（）调用，因此应该以类似的方式使用连接（）本身。

    CompletableFuture<List<String>> completed = futureOfList.thenApply(
                  s->s.collect(Collectors.toList());

要专门为CompletableFuture编写自己的版本，您可以这样做

 CompletableFuture<Stream<String>> futureOfList = CompletableFuture.completedFuture(1)
           .thenCompose(one->listOfFutures.stream()
                                         .map(cf->cf.join()));

然后加入

CompletableFuture<List<String>> completed = futureOfList.thenApply(
                s->s.collect(Collectors.toList());

另请参阅此问题和答案，了解使用 allOf 的解决方案（不会阻塞任何其他线程）。