线程池执行过程中遇到异常会发生什么，怎样处理?

Bertha 。 2023-10-13 12:27 5阅读 0赞

在Java中，线程池是一种用于管理和复用线程的机制。当线程池执行任务时，如果任务发生异常，会有不同的处理方式，具体取决于你如何配置和处理异常。

当线程池中的线程执行任务时，如果任务抛出未捕获的异常，这个异常会传递给线程池的异常处理器(Thread.UncaughtExceptionHandler)。异常处理器是一个接口，可以自定义实现。如果没有显式地设置异常处理器，则会使用默认的处理器来处理异常。

默认的异常处理器会打印异常堆栈跟踪信息，并终止抛出异常的线程。如果线程是由线程池创建的，线程池会注意到线程终止并从池中移除该线程，然后创建一个新的线程来替代它，以保持线程池中的线程数量不变。

为了处理线程池中任务的异常，我们可以采取以下步骤：

### 　　1.自定义异常处理器 ###

实现Thread.UncaughtExceptionHandler接口，并重写uncaughtException()方法来定义你自己的异常处理逻辑。例如，你可以记录异常日志、发送警报或采取其他适当的操作。

public class CustomExceptionHandler implements Thread.UncaughtExceptionHandler {
        @Override
        public void uncaughtException(Thread t, Throwable e) {
            // 自定义异常处理逻辑
            System.out.println("Exception occurred in thread: " + t.getName());
            e.printStackTrace();
            // 其他处理操作...
        }
    }

### 　　2.在创建线程池时设置异常处理器 ###

在创建线程池时，使用ThreadPoolExecutor的构造函数之一，并传递自定义的异常处理器。

Thread.UncaughtExceptionHandler exceptionHandler = new CustomExceptionHandler();
    ExecutorService executorService = new ThreadPoolExecutor(
        corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS,
        new LinkedBlockingQueue<>(), exceptionHandler
    );

这样，当线程池中的线程执行任务时发生异常，就会调用自定义的异常处理器进行处理。

### 　　3.在任务的执行体中捕获异常 ###

如果我们的任务实现了Runnable接口或Callable接口，我们可以在任务的run()或call()方法中使用try-catch块来捕获异常，并在捕获到异常后进行适当的处理。这种方式可以防止异常传播到线程池的异常处理器中。

Runnable task = new Runnable() {
        @Override
        public void run() {
            try {
                // 任务执行代码
            } catch (Exception e) {
                // 异常处理逻辑
                e.printStackTrace();
                // 其他处理操作...
            }
        }
    };

通过上述方式，我们可以自定义处理线程池中任务抛出的异常。这样可以确保我们对异常有完全的控制，并能采取适当的操作，如记录日志、处理错误、发送通知等。