Java中的并发工具：ExecutorService和ThreadPoolExecutor的应用示例

原创川长思鸟来 2024-12-07 00:06 16阅读 0赞

在Java中，`ExecutorService`和`ThreadPoolExecutor`是两个用于管理线程的工具。以下是这两个类的应用示例：

1. **创建ExecutorService实例**（使用默认参数）

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

// 创建一个固定大小的线程池
ExecutorService executor = Executors.newFixedThreadPool(5); // 限制线程数为5

// 线程池提供服务，你可以将任务放入队列中等待执行
executor.execute(new Runnable() {
    @Override
    public void run() {
        System.out.println("Task executed by a thread from the pool.");
    }
}));
```

2. **创建ThreadPoolExecutor实例并自定义参数**（如核心线程数、最大线程数等）

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

// 创建一个可动态调整大小的线程池
ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newThreadPool(); // 核心线程数默认为线程池大小一半，这里不显式指定

// 设置最大线程数和超时时间（如：20个最大线程数，5秒后自动关闭线程池）
executor.setCorePoolSize(10); // 设置核心线程数
executor.setMaxPoolSize(20); // 设置最大线程数
executor.setKeepAliveTime(3, TimeUnit.SECONDS)); // 设置空闲线程存活时间
executor.setQueueCapacity(50); // 设置任务队列容量

// 现在，你可以将任务放入这个线程池中执行
executor.execute(new Runnable() {
    @Override
    public void run() {
        System.out.println("Task executed by a thread from the pool.");
    }
}));
```

以上示例展示了如何使用`ExecutorService`和`ThreadPoolExecutor`管理Java并发编程。