如何在不调用Future的情况下将Future转换为流。收到

Question

假设我有一个未来对象的列表<代码>列表

List<Data> list=new ArrayList();
for(Future future:futures){
    list.addAll(future.get());
}
return list.steam();

但此方法必须等待所有期货返回，然后才能返回流
我想让它像管道一样工作，上层从流中提取数据并根据需要进行处理，无需等待所有的未来完成。

Answer 1

你想要这样的东西吗？

List<Future<List<Data>>> futures;
return futures.stream().flatMap(future->future.get().stream());

只有在实际使用它们时才会运行map（）和flatMap（）。

这样，您就不会避免get（）调用，但它只在您使用它的时候被调用。