Java并发工具类：ExecutorService、Thread池构建示例

原创 Love The Way You Lie 2024-10-31 09:39 20阅读 0赞

在Java中，`ExecutorService` 是一个接口，它提供了一种管理线程池的方法。`ExecutorService`允许你异步地执行任务，并且提供了控制和管理这些任务的机制。以下是如何使用 `ExecutorService` 和 `ThreadPoolExecutor`来构建一个线程池的示例：

###1. 使用 Executors工厂方法创建线程池Java 提供了 `Executors` 类，其中包含了一些工厂方法，可以方便地创建预定义配置的线程池。

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

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

// 创建一个单线程的线程池（串行执行器）
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

// 创建一个可缓存的线程池，根据需要创建新线程的线程池，对于短生命周期的大量任务非常合适ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// 提交任务到线程池 for (int i =0; i <10; i++) {
 final int index = i;
 fixedThreadPool.execute(new Runnable() {
@Override public void run() {
 System.out.println("执行任务：" + index + "线程：" + Thread.currentThread().getName());
 }
 });
 }

// 关闭线程池 fixedThreadPool.shutdown();
 singleThreadExecutor.shutdown();
 cachedThreadPool.shutdown();
 }
}
```###2.手动创建 ThreadPoolExecutor如果你需要更细粒度的控制，可以直接使用 `ThreadPoolExecutor` 类来创建线程池。

```javaimport java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPoolExample {
 public static void main(String[] args) {
//核心线程数int corePoolSize =4;
// 最大线程数int maximumPoolSize =10;
//工作队列BlockingQueue<Runnable> workQueue = new ArrayBlockingQueue<>(10);
//线程没有任务执行时在终止前等待新任务的最长时间 long keepAliveTime =0L;
//单位 TimeUnit unit = TimeUnit.MILLISECONDS;

ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
corePoolSize,
 maximumPoolSize,
 keepAliveTime,
unit,
 workQueue);

// 提交任务到线程池 for (int i =0; i <10; i++) {
 final int index = i;
 threadPoolExecutor.execute(new Runnable() {
@Override public void run() {
 System.out.println("执行任务：" + index + "线程：" + Thread.currentThread().getName());
 }
 });
 }

// 关闭线程池 threadPoolExecutor.shutdown();
 }
}
```### 注意事项- 当不再需要线程池时，应该调用 `shutdown()` 方法来关闭线程池，释放资源。
- `shutdown()` 方法不会立即停止线程池，而是等待正在执行的任务完成。
- 如果需要立即停止，可以调用 `shutdownNow()`，但这可能会导致正在执行的任务被中断。

这些示例展示了如何使用Java的并发工具类来创建和管理线程池，这对于提高程序的并发性能和资源利用率非常重要。