4

我有一个 ExecutorService 用于调用 Callable 对象的集合并返回与集合中的 Callable 元素相对应的 Future 对象列表。

但是，在遍历列表的某个地方，它会引发以下异常：

java.util.concurrent.ExecutionException: java.lang.IndexOutOfBoundsException: Index: 7, Size: 1
at java.util.concurrent.FutureTask.report(Unknown Source)
at java.util.concurrent.FutureTask.get(Unknown Source)
at com.soc.transformcsv.ParallelTransformationPool.doExecute(ParallelTransformationPool.java:91)

我一直在执行的代码是

List<Future<StringBuilder>> futures = executor.invokeAll(builders);
executor.shutdown();
HashMap<String, List<StringBuilder>> allServiceTypeRows = new LinkedHashMap<>();

for (Future<StringBuilder> future : futures) {
    // I have tried putting future.isDone() which always prints true before the exception
    StringBuilder recordBuilder = future.get();
    // do more
}

它给了我future.get()在线错误。

请帮助解决障碍或让我知道我还能提供什么。

4

2 回答 2

4

即使 Callable 中存在异常，结果isDone()也可能为真。从文档中：isDone

如果此任务完成，则返回 true。完成可能是由于正常终止、异常或取消——在所有这些情况下，此方法都将返回 true。

所以有问题的 Future 已经完成，但是在计算时遇到了错误。在您发布的堆栈跟踪下，应该有另一个列出“Caused by:”—这将在您的 Callable 中出现根故障。

例如，请参阅此 ideone 链接的输出。此异常发生在成功检查是否isDone为真之后：

Exception in thread "main" java.util.concurrent.ExecutionException: java.lang.RuntimeException: This is a failure!
    at java.util.concurrent.FutureTask.report(FutureTask.java:122)
    at java.util.concurrent.FutureTask.get(FutureTask.java:192)
    at Ideone.main(Main.java:16)
Caused by: java.lang.RuntimeException: This is a failure!
    at Ideone$SampleCallable.call(Main.java:21)
    at Ideone$SampleCallable.call(Main.java:19)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at Ideone.main(Main.java:14)
于 2015-07-23T19:21:45.357 回答
2

遍历 of 时不会发生异常List<Future>。实际上是在执行您的（其中一个）的方法时IndexOutOfBoundsException发生的。ExecutorServicecall()Callablebuilders

ExecutionException但是仅当您尝试获取Futureusing的结果时，才会引发此异常（包含在future.get().

于 2015-07-23T19:34:34.523 回答