Callable如何处理任务异常？invokeAll提交任务异常未被捕获问题

在tasks.add添加的Callable任务执行流程中尝试抛出异常（异常发生在paymentDao.savePayment()方法内），调试时已确认代码执行到抛出异常的行，但异常从未出现在日志中，也没有进入外层预设的catch逻辑，需要明确Callable任务内部异常的处理规则。

对应问题代码：

private final ExecutorService service = Executors.newFixedThreadPool(100,namedThreadFactory);
List<Callable<Object>> tasks = new ArrayList<>();

try {
  if (cacheService.isPayment(
      (PaidPending) logProcessor.getCache().asMap().get(fileName), fileName)) {
    tasks.add(
        () -> {
          long startTime = System.currentTimeMillis();
          paymentDao.savePayment(paymentR, fileName);
          log.info(
              "Time taken by savePaymentSummary Key {} : {}",
              key,
              System.currentTimeMillis() - startTime);
          return null;
        });
  service.invokeAll(tasks);

} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
    throw new CustomException("Failed to insert payment " , e);
} catch (CustomeException e) {
    log.error("Error here {}", e);
    throw new CustomException("Failed to fetch Payment", e);
}

• invokeAll()方法本身仅在提交任务的主线程被中断时抛出InterruptedException，任务执行过程中抛出的所有异常都会被线程池框架捕获，包装后存储在每个任务对应的Future返回值中，不会直接抛到调用invokeAll的主线程栈。
• 当前代码调用service.invokeAll(tasks)后没有接收返回的Future列表，也没有调用Future.get()触发异常的抛出，因此任务内部的异常一直被封装在Future对象中，既不会打印日志，也不会进入外层的catch块。
• 代码中编写的catch (CustomeException e)本身存在两个问题：一是异常类名拼写错误（正确应为CustomException），二是跨线程的异常不会直接传播到主线程的调用栈，即使拼写正确也无法捕获工作线程中抛出的自定义异常。

• 接收invokeAll返回的Future列表，遍历每个Future调用get()方法，捕获ExecutionException即可拿到任务内部抛出的原始异常，参考实现：

List<Future<Object>> futures = service.invokeAll(tasks);
for (Future<Object> future : futures) {
    try {
        future.get();
    } catch (ExecutionException e) {
        // e.getCause() 就是paymentDao.savePayment()抛出的原始业务异常
        Throwable realException = e.getCause();
        log.error("支付数据保存失败", realException);
        throw new CustomException("Failed to insert payment ", realException);
    }
}

• 修正异常类名的拼写错误，统一使用CustomException。
• 如果不需要同步等待任务执行结果，也可以为线程池配置自定义的ThreadFactory，给工作线程设置UncaughtExceptionHandler统一处理未捕获异常，但对于Callable提交的任务，通过Future获取执行结果和异常是更符合规范的实现方式。

内容的提问来源于stack exchange，提问作者Cris Manrique