ThreadPoolExecutor抛出异常？Java 8多线程并行化问题排查

看起来你遇到了两个核心问题：主线程未等待任务完成就访问结果，以及多线程环境下的线程安全问题，咱们一个个来拆解：

1. 输出截断：主线程提前访问未完成的结果 #

你调用executor.shutdown()后直接遍历solution.results，但shutdown()的作用只是让线程池停止接受新任务，并不会等待已经提交的任务执行完毕。这时候主线程很可能在部分任务还没跑完、results数组对应位置还没被赋值的情况下就开始输出，自然会出现结果截断的情况。加延迟能“碰巧”让任务完成，但这是不可靠的做法。

正确做法：等待所有任务执行完毕 #

在shutdown()之后，调用awaitTermination()来阻塞主线程，直到所有任务完成或者超时：

executor.shutdown();
try {
    // 等待60秒（可根据你的任务耗时调整），直到所有任务完成
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        // 超时后强制关闭线程池，中断未完成的任务
        executor.shutdownNow();
        // 再次等待确认线程池终止
        if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
            System.err.println("线程池无法正常终止");
        }
    }
} catch (InterruptedException e) {
    // 捕获中断异常，强制关闭线程池并恢复当前线程的中断状态
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

// 现在所有任务都已完成，安全遍历结果
for (int result : solution.results) {
    System.out.println(result);
}

2. 大量异常：线程安全问题导致的并发冲突 #

你提到多线程运行时出现大量异常，大概率是因为共享资源没有做好线程安全防护，可能的点包括：

• Solution类的solve方法存在共享可变状态：如果solve方法内部修改了Solution的其他成员变量（不是results数组的对应索引），多个线程同时操作这些共享变量就会引发并发冲突，比如ConcurrentModificationException、数据错乱甚至空指针。
• Graph或nodeSet不是线程安全的：如果多个线程在执行solve时会修改Graph的结构，或者遍历nodeSet这类非线程安全的集合，也会抛出异常。
• 虽然results数组每个索引只有一个线程写入（iQuery唯一），这部分本身是线程安全的，但其他共享资源的问题会导致异常。

解决方案：修复线程安全问题 #

• 让solve方法无状态化：如果solve不需要依赖Solution的其他成员，把它改成静态方法，或者把所有需要的参数都通过方法传入，避免共享状态。
• 保护共享资源：如果必须使用共享变量，用synchronized块或线程安全的集合（比如ConcurrentHashMap代替普通HashMap）来同步访问。
• 确保Graph和nodeSet只读：在多线程执行期间，不要让任何线程修改Graph或nodeSet的状态，如果需要修改，要加同步锁。
• 用Callable捕获任务异常：如果想明确知道每个任务抛出的异常，建议用Callable代替Runnable，通过Future获取任务结果和异常：

List<Future<Integer>> futures = new ArrayList<>();
for (int iQuery = 0; iQuery < nQueries; iQuery++) {
    final int queryIdx = iQuery;
    // 提交Callable任务，捕获执行过程中的异常
    Future<Integer> future = executor.submit(() -> solution.solve(graph, nodeSet));
    futures.add(future);
}

// 收集结果并处理异常
for (int i = 0; i < futures.size(); i++) {
    try {
        solution.results[i] = futures.get(i).get();
    } catch (InterruptedException | ExecutionException e) {
        // 打印异常信息，方便排查问题
        System.err.println("任务" + i + "执行失败：");
        e.printStackTrace();
        // 给失败的任务设置默认值
        solution.results[i] = -1;
    }
}

这样你能清楚看到每个任务的异常原因，更容易定位问题。

内容的提问来源于stack exchange，提问作者Mark Lavin