流式传输期货列表的最有效方式

Question

我通过在对象列表上进行流式处理来调用异步客户端方法。该方法返回Future。

迭代调用后返回的Futures列表的最佳方法是什么（以便处理那些首先出现的Future）？

注意：异步客户端只返回Future而不是CompletableFuture。

代码如下：

List<Future<Object>> listOfFuture = objectsToProcess.parallelStream()
    .map((object) -> {
        /* calling an async client returning a Future<Object> */ })
    .collect(Collectors.toList());

Answer 1

拥有此列表

这是因为流api使用公共池进行并行处理，并且您将对这些未来调用get（如果处理需要很长时间），您将阻止应用程序中使用并行操作的所有其他流操作，直到完成此操作为止。

这有点像这样：

forJoinPool.submit( () -> list.stream().parallel().map(future -> future.get()).collect(Collectors.toList())).get();

我会选择这里所示的定制泳池