使用spring async进行并行调用后加入结果

Question

我正在使用 spring @Async 对同一方法/后端进行并行调用。有没有一种干净的方法可以将他们的结果加入列表中？这是我提出的用于调用/合并结果的伪代码，但我不确定这是最干净的方式。

List<Future<String>> futureStringList = new ArrayList<Future<String>>();
for(each backend call){
           Future<String> futureString = backend.retrieve();
           futureStringList.add(futureString);
}


List<String> actualStringList = new ArrayList<String>();

    while(!futureStringList.isEmpty()){
           for(Future<String> futureString: futureStringList){
                          if(futureString.isDone()){
                                         actualStringList.add(futureString.get());
                                         futureStringList.remove(futureString);
                          }
           }
    }

Answer 1

Future.get() 是一个阻塞调用，因此您实际上可以遍历您的 Future 列表，并且您知道，在循环结束时，您所有的未来都完成了。

List<Future<String>> futureStringList = new ArrayList<Future<String>>();
for(each backend call){
    Future<String> futureString = backend.retrieve();
    futureStringList.add(futureString);
}

List<String> actualStringList = new ArrayList<String>();
for (Future<String> stringFuture : futureStringList) {
  actualStringList.add(stringFuture.get()); // blocking call
}

// all your Strings are retrieved at this point