ExecutorService如何处理异常

ExecutorService 是 Java 并发包 java.util.concurrent 中的一个接口，它提供了一种将任务提交给线程池执行的方式。当使用 ExecutorService 提交任务时，可能会遇到异常。处理这些异常的方法取决于你使用的任务类型（实现了 Runnable 还是 Callable）以及你的需求。

1. 对于实现了 Runnable 接口的任务：

   当你提交一个实现了 Runnable 接口的任务时，如果任务抛出了未捕获的异常，那么这个异常将被 Thread.UncaughtExceptionHandler 处理。默认情况下，这个处理器会打印异常的堆栈跟踪信息。你可以通过以下方式自定义异常处理器：

   Thread.setDefaultUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
       @Override
       public void uncaughtException(Thread t, Throwable e) {
           // 在这里处理异常
       }
   });
   

   或者，在创建线程池时，可以为每个线程设置一个 UncaughtExceptionHandler：

   ThreadPoolExecutor executor = new ThreadPoolExecutor(
       corePoolSize,
       maximumPoolSize,
       keepAliveTime,
       TimeUnit.SECONDS,
       new LinkedBlockingQueue<>(),
       new ThreadFactory() {
           @Override
           public Thread newThread(Runnable r) {
               Thread thread = new Thread(r);
               thread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
                   @Override
                   public void uncaughtException(Thread t, Throwable e) {
                       // 在这里处理异常
                   }
               });
               return thread;
           }
       }
   );
   

2. 对于实现了 Callable 接口的任务：

   当你提交一个实现了 Callable 接口的任务时，ExecutorService 会返回一个 Future 对象。你可以通过调用 Future.get() 方法来获取任务的返回值。如果任务在执行过程中抛出了异常，那么 get() 方法会抛出一个 ExecutionException，你可以捕获这个异常并处理它：

   Future<?> future = executorService.submit(new MyCallableTask());
   try {
       future.get();
   } catch (InterruptedException e) {
       // 处理中断异常
   } catch (ExecutionException e) {
       // 处理任务执行过程中的异常
       Throwable cause = e.getCause();
       // 在这里处理 cause
   }
   

总之，处理 ExecutorService 中的异常需要根据任务类型和需求来选择合适的方法。对于 Runnable 任务，可以自定义 Thread.UncaughtExceptionHandler；对于 Callable 任务，可以通过 Future.get() 方法捕获 ExecutionException。