Java线程池：核心概念与阻塞队列实例

原创 ╰+攻爆jí腚メ 2024-10-18 09:42 35阅读 0赞

Java线程池是Java中处理多个并发任务的一种机制。其主要核心概念包括以下几个部分：

1. **工作线程（Worker Threads）**：这是线程池中的实际执行线程，它们在需要时从线程池中获取。

2. **任务队列（Task Queue）**：当一个任务被提交到线程池时，它会被放入这个队列中等待处理。

3. **线程池大小（Pool Size）**：线程池的容量限制了同时运行的工作线程数量。当线程池中的工作线程达到上限后，新的任务将会被阻塞直到有线程空闲出来。

实例：
```java
// 创建一个配置良好的线程池
ExecutorService executor = Executors.newFixedThreadPool(5); // 限制最多5个线程同时运行

// 提交任务到线程池，会被放入队列等待处理
Future<Integer> future1 = executor.submit(() -> {
    System.out.println("Task 1 started");
    try {
        Thread.sleep(2000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return 10 * Math.random(); // 生成一个0到99之间的随机数
}));

// 提交任务到线程池，会被放入队列等待处理
Future<Double> future2 = executor.submit(() -> {
    System.out.println("Task 2 started");
    try {
        Thread.sleep(5000); // 等待更长的时间
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return Math.PI; // 返回圆周率
}));

// 关闭线程池，释放所有资源
executor.shutdown(); // 设置为shutdown模式（等待所有任务完成）
while (!executor.isTerminated()) { // 等待所有任务完成后关闭
    try {
        Thread.sleep(100); // 每100ms检查一次
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}
```
这段代码创建了一个固定大小的线程池，然后提交了两个异步任务到线程池。当所有任务完成后，线程池会自动关闭释放资源。