如何在Java中实现线程池？-蒲公英云

如何在Java中实现线程池？

在Java中，我们可以使用ExecutorService来创建和管理线程池。以下是一个简单的步骤：

导入必要的库：

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

创建一个线程池，这里我们使用固定大小的线程池：
```java
int corePoolSize = 5; // 核心线程数
int maximumPoolSize = 10; // 最大线程数

ExecutorService executor = Executors.newFixedThreadPool(
corePoolSize,
Executors.defaultThreadFactory()
);


3. 使用线程池来执行任务。当工作队列满时，新任务将被添加到等待线程中：
```java
// 提交任务到线程池
executor.execute(() -> {
    // 这里是你需要执行的任务代码
    System.out.println("Task executed by a thread from the pool.");
} });

当所有任务完成后，关闭线程池以释放资源：

executor.shutdown();
try {
 if (!executor.isTerminated()) {
     executor.shutdownNow(); // 如果还有未完成的任务，强制关闭它们
     System.out.println("Some unfinished tasks were force-closed.");
 }
} catch (InterruptedException e) {
 Thread.currentThread().interrupt();
 System.out.println("Interrupted while waiting for termination.");
}