Java并发编程：线程池中任务执行异常处理案例

原创素颜马尾好姑娘i 2024-10-21 05:54 24阅读 0赞

在Java的并发编程中，线程池是一个常用的工具，它可以帮助我们管理大量的线程，提高程序的性能和稳定性。然而，在使用线程池时，任务执行的异常情况是需要进行妥善处理的。

下面我将提供一个简单的线程池任务执行异常处理案例：

```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExceptionHandler {

public static void main(String[] args) {
        // 创建线程池，大小为5个线程
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交任务到线程池，如果任务执行异常，会抛出受检异常
        try {
            for (int i = 0; i < 10; i++) {
                // 这里模拟一个可能会抛出异常的任务
                final int value = i;
                executor.execute(() -> {
                    try {
                        // 模拟任务执行可能抛出的异常
                        throw new IllegalArgumentException("Value " + value + " is invalid.");
                    } catch (Exception e) {
                        // 处理受检异常
                        System.out.println("Error occurred while executing task: " + e.getMessage());
                        e.printStackTrace();
                    }
                });
            }
        } catch (Exception e) {
            // 这里处理可能在任务执行过程中抛出的异常
            System.out.println("An unexpected error occurred in thread pool execution: " + e.getMessage());
            e.printStackTrace();
        }

// 关闭线程池，释放资源
        executor.shutdown();

// 确保所有任务已经完成
        while (!executor.isTerminated())) {
            // 如果还有未完成的任务，可以在这里进行适当的等待或处理
            try {
                Thread.sleep(1000); // 模拟等待时间
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

System.out.println("Thread pool execution completed successfully.");
    }
}
```

这个案例中，我们创建了一个线程池来执行任务。在提交任务时，如果任务执行过程中抛出了异常，我们会捕获到这个受检异常，并按照需要进行处理。

最后，我们关闭线程池以释放资源，并确保所有任务已经完成。