处理多个异步操作并分别进行进一步处理的最佳方式是什么？

Question

在我的项目中，有一个返回类型为未来列表的方法。另一个开发人员也这样迭代过for循环

public List<Future<Object>> method1(){
    List<Future<Object>> lists = new ArrayList();
    for(MultipartFile file : files){
      Future<Object> future = service.method2(file);
      lists.add(future);
    }
   return lists;
}

现在，我必须在处理列表的对象后立即对它执行某些操作。我该怎么做？即使我把一个for循环像

for(Future<Object> future : lists){
  if(future.isDone()){
       performOtherOperation(future.get());
  }
}

如果第一个对象未被处理，isDone（）条件将失败，它将被忽略，第二次迭代将开始，我如何处理它？

这也可以使用ExecutorService完成吗？？我不熟悉ExecutorService。

编辑：所以我编辑了服务类的方法2（文件）

public Future<Object> method2(File){
  object = operation();
  return new AsyncResult(object);
}

公开可完成的未来方法2（文件）；

但是我应该选择与AsyncResult等价的返回类型。AsyncResult是Spring框架的一个实现。

在我100%确定这段代码不会破坏现有的多线程性能或降低性能之前，我无法修改这段代码。

Answer 1

如果您可以更改 service.method2 以返回 CompletableFuture，那么问题就变得微不足道了：

for(CompletableFuture<Object> future : lists){
  future.whenComplete((obj, err) -> performOtherOperation(obj));
}

如果您绝对不能修改method2，那么您可以将Future对象转换为CompletableFutures，如将Java Future转换为CompleableFuture中所述