Java并发编程：线程池管理和异常处理案例

原创清疚 2024-09-29 07:03 71阅读 0赞

在Java中，线程池是一种常用的并发资源管理方式。以下是一个简单的线程池管理案例，以及异常处理的示例。

1. **线程池管理案例**：

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

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

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            Runnable task = () -> System.out.println("Task " + i);
            executor.execute(task); // 提交任务
        }

// 关闭线程池，释放资源
        executor.shutdown();
        try {
            if (!executor.awaitTermination(60, TimeUnit.SECONDS))) { 
                // 线程池没有在等待时间内关闭
                System.err.println("Executor did not terminate!");
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

2. **异常处理示例**：

在上述线程池管理案例中，我们可能会遇到如线程池未及时关闭导致任务滞留等问题。这时可以通过异常处理来应对。

例如，在关闭线程池时，可以捕获`InterruptedException`，提示用户线程池未能正常关闭：

```java
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS))) { 
        // 线程池没有在等待时间内关闭
        System.err.println("Executor did not terminate! Due to InterruptedException: " + e.getMessage());
        catch (InterruptedException e) {
            // 线程中断异常处理
            e.printStackTrace();
        }
    }
} catch (Exception e) {
    // 其他未捕获异常
    e.printStackTrace();
}
```

以上案例展示了Java并发编程中线程池的管理以及异常处理的基本方法。