在Java中,ThreadPoolExecutor是一个用于执行和管理线程的类。要配置ThreadPoolExecutor,您需要设置以下参数:
- 核心线程数(corePoolSize):这是线程池中始终保持活跃的线程数量。即使这些线程处于空闲状态,也会保留在线程池中。
- 最大线程数(maximumPoolSize):线程池中允许的最大线程数量。当任务数量超过核心线程数时,线程池会创建新的线程,直到达到最大线程数。
- 任务队列(workQueue):用于存储等待执行的任务的队列。当线程池中的线程都在忙碌时,新提交的任务会被放入任务队列中。
- 线程工厂(ThreadFactory):用于创建新线程的工厂。可以自定义线程名称、优先级等属性。
- 拒绝策略(RejectedExecutionHandler):当任务队列已满且线程池中的线程都在忙碌时,新提交的任务会触发拒绝策略。有多种内置的拒绝策略可供选择,如抛出异常、丢弃任务等。
以下是一个配置ThreadPoolExecutor的示例:
import java.util.concurrent.*;
public class ThreadPoolExecutorConfig {
public static void main(String[] args) {
int corePoolSize = 5; // 核心线程数
int maximumPoolSize = 10; // 最大线程数
long keepAliveTime = 60L; // 空闲线程的存活时间(单位:秒)
TimeUnit unit = TimeUnit.SECONDS; // 存活时间的单位
BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(20); // 任务队列
ThreadFactory threadFactory = Executors.defaultThreadFactory(); // 默认线程工厂
RejectedExecutionHandler rejectedExecutionHandler = new ThreadPoolExecutor.CallerRunsPolicy(); // 拒绝策略
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
threadFactory,
rejectedExecutionHandler
);
// 使用线程池执行任务
for (int i = 0; i < 30; i++) {
int finalI = i;
threadPoolExecutor.submit(() -> {
System.out.println("Task " + finalI + " is executed by thread " + Thread.currentThread().getName());
});
}
// 关闭线程池
threadPoolExecutor.shutdown();
}
}
在这个示例中,我们创建了一个包含5个核心线程、最大线程数为10的线程池。空闲线程在60秒后会被回收。任务队列的容量为20,使用默认线程工厂和CallerRunsPolicy拒绝策略。