Java异常处理：多线程中抛出的异常

原创左手的ㄟ右手 2024-09-27 23:42 60阅读 0赞

在Java编程中，特别是在多线程环境中，可能会出现异常。以下是如何捕获和处理这些异常的例子：

1. **线程抛出异常**：
   当一个线程在其执行过程中抛出了一个异常时，这个异常会传播到调用该线程的代码。

2. **使用try-catch-finally**：
   为了有效地捕获并处理这些异常，你可以使用Java的`try-catch-finally`结构：

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

public class MultiThreadExceptionHandling {
    public static void main(String[] args) {
        // 创建一个线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

// 提交多个任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskIndex = i;
            executor.submit(() -> {
                try {
                    // 这里可能会抛出异常
                    processTask(taskIndex);
                } catch (Exception e) {
                    // 记录并处理异常
                    System.out.printf("Error processing task %d: %s%n", taskIndex, e.getMessage(), e);
                }
            });
        }

// 关闭线程池
        executor.shutdown();

// 等待所有任务完成（或者超时）
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(1000); // 每秒检查一次
            } catch (InterruptedException e) {
                System.out.println("Interrupted during task checking.");
                e.printStackTrace();
            }
        }

System.out.println("All tasks completed.");
    }

// 假设这里有一个处理任务的函数，可能会抛出异常
    private static void processTask(int taskIndex) throws Exception {
        if (taskIndex == 5) { // 这里模拟可能引发异常的情况
            throw new IllegalArgumentException("Invalid task index: " + taskIndex);
        }

// 正常的任务处理逻辑
        System.out.printf("Processing task %d...%n", taskIndex);

Thread.sleep(1000); // 模拟任务处理时间
    }
}
```

在这个示例中，我们创建了一个线程池来并发执行任务。每个任务都会尝试`processTask()`方法，这个方法可能会抛出异常。

在主线程中，我们定期检查每个任务的状态，并记录和处理任何捕获的异常。最后，当所有任务完成时，打印一条消息。