面试题：线程池内“闹情绪”的线程，怎么办？

2024-05-13
福建
本文字数：1491 字
阅读完需：约 5 分钟

在 Java 中，线程池中工作线程出现异常的时候，默认会把异常往外抛，同时这个工作线程会因为异常而销毁，我们需要自己去处理对应的异常，异常处理的方法有几种：

在传递的任务中去处理异常，对于每个提交到线程池中的执行的任务，可以提前通过异常进行捕获，这样即便出现了异常，也不会影响线程池中的工作线程

使用 Future 来捕获异常结果，在线程池中提供了一个 submit(Callable<T>)方法，这个方法会返回一个 Future，可以通过调用 Future.get()方法，来获取任务的执行结果，如果任务执行过程中出现了异常，也会抛出一个 ExecutionException，其中就包含了任务执行过程中出现的异常

我们还可以自定义一个 ThreadFactory,设置一个 UncaughtExceptionHandler,我们可以通过实现 ThreadFactory 的接口来自定义创建线程的方式，然后为每个新创建的线程设置一个 UncaughtExceptionHandler，这个处理器会在线程由于未捕获异常而即将终止的时候被调用

下面是三段代码示例：

捕获线程执行异常

ExecutorService executorService = Executors.newFixedThreadPool(5); executorService.execute(() -> {    try {        // 执行任务    } catch (Exception e) {        // 记录日志        logger.error("An exception occurred: ", e);    }});

复制代码

在执行任务的过程中，如果出现异常，就会被 try-catch 语句捕获，并将异常信息记录到日志中。

使用 Future 来捕获异常结果

ExecutorService executorService = Executors.newFixedThreadPool(5); List<Future<?>> futures = new ArrayList<>(); // 提交任务到线程池for (int i = 0; i < 10; i++) {    Future<?> future = executorService.submit(() -> {        // 执行任务    });    futures.add(future);} // 获取任务结果for (Future<?> future : futures) {    try {        future.get();    } catch (InterruptedException | ExecutionException e) {        // 处理异常        logger.error("An exception occurred: ", e);    }}

复制代码

在这个例子中，我们将多个任务提交到线程池，并将每个任务的 Future 对象保存在 futures 列表中。接着，我们遍历 futures 列表，并调用每个 Future 对象的 get()方法来获取任务的执行结果。如果任务执行过程中出现了异常，则会抛出 ExecutionException 异常，我们在 catch 块中捕获该异常并进行相应的处理。

实现 UncaughtExceptionHandler 接口

public class CustomExceptionHandler implements Thread.UncaughtExceptionHandler {    @Override    public void uncaughtException(Thread t, Throwable e) {        // 记录日志或者进行其它处理        logger.error("Thread " + t.getName() + " encountered an exception: ", e);    }} ExecutorService executorService = Executors.newFixedThreadPool(5); // 设置UncaughtExceptionHandler((ThreadPoolExecutor) executorService).setThreadFactory(r -> {    Thread thread = new Thread(r);    thread.setUncaughtExceptionHandler(new CustomExceptionHandler());    return thread;}); executorService.execute(() -> {    // 执行任务});

复制代码

这种方式需要自定义一个实现了 UncaughtExceptionHandler 接口的异常处理器，当线程出现异常时，异常处理器会被调用，我们可以在其中记录日志或者进行其它处理。接着，我们需要将异常处理器设置到线程池的线程工厂中。当线程池内的线程出现异常时，异常处理器就会被调用，我们可以在其中处理异常。

文章转载自：猫鱼吐泡泡
原文链接：https://www.cnblogs.com/marsitman/p/18187655
体验地址：http://www.jnpfsoft.com/?from=infoq

发布于: 刚刚阅读数: 5

EquatorCoco

关注

还未添加个人签名 2023-06-19 加入

还未添加个人简介

发布

暂无评论

创作场景

面试题：线程池内“闹情绪”的线程，怎么办？

EquatorCoco

评论