Future.get（）未返回所有结果

Question

我正在创建，比如说，15个Callable任务，并提交它们：

List<Future<MyResult>> futures = new ArrayList<Future<MyResult>>();
List<MyResult> myResults = new ArrayList<MyResult>();

for(int i = 1; i <= 15; i++){
    Callable<MyResult> task = new MyProcessor(//parameters);
    Future<MyResult> future = executorService.submit(task);
    futures.add(future);//used to iterate over to call get() to collect results in next for loop
}

然后我收集15个MyResult对象：

for(Future<MyResult> future : futures){
  try {
    MyResult myResult = future.get();
    processorResults.add(myResult);
    } catch (InterruptedException e) {
      //...
    } catch (ExecutionException e) {
      //...
    }
}

问题是：我没有从get（）方法获得所有15个MyResult对象，而是有时获得不到15个对象。有时12有时10有时甚至更少，有时全部15。

我的印象是，get（）方法是一个阻塞调用，将等待所有15个线程返回各自的结果，但看起来我错过了其中的一些线程并继续前进。我做错了什么？我是否未正确收集结果/等待结果？当任何MyProcessor任务抛出错误时，是否会发生这种情况？

Answer 1

这可能意味着你的一些工作抛出了一个例外。从你的代码中很难判断，但是你需要做一些事情，除了捕捉和忽略它。

Future.get（）当您提交的Callable从call（）方法抛出RuntimeException时，抛出ExecutionException。如果方法使用return正常返回，它将仅返回您的MyResult。您可以通过执行以下操作获取引发的异常：

} catch (ExecutionException e) {
    // account for the throw here, the original exception is in e.getCause()
    // log it, count it, or ...
    logger.error("Job threw exception: " + e.getCause());
}

我的印象是get（）方法是一个阻塞调用，将等待所有15个线程返回相应的结果，

这是正确的。当您调用future.get（）时，该函数将一直阻塞，直到作业完成为止—通过抛出异常或返回。如果执行get（）的线程被中断，那么get（）抛出一个InterruptedException，该异常也应该被捕获，而不仅仅是忽略。