线程池在Java并发编程中占据核心地位,通过复用线程资源,可以极大地提高系统资源利用率和响应速度。Java中的java.util.concurrent.ThreadPoolExecutor
类提供了丰富的参数配置以满足不同场景的需求。下面我们将逐一介绍线程池的主要构建参数,并给出相应的例子说明:
1. corePoolSize
:核心线程数
corePoolSize
决定了线程池的基本规模,即线程池即使在没有任务执行时也会保有的线程数量。这些线程始终存活在线程池中,除非设置了允许它们超时关闭的策略。
int corePoolSize = 5; // 设置线程池核心线程数为5
2. maximumPoolSize
:最大线程数
maximumPoolSize
限制了线程池能够容纳的最大线程数。当线程池中活跃线程数超过corePoolSize
,且任务队列已满时,线程池会创建新的线程来处理任务,直到达到maximumPoolSize
为止。
int maximumPoolSize = 10; // 设置线程池最大线程数为10
3. keepAliveTime
:存活时间
keepAliveTime
参数指定了线程在没有任务执行时可以保持空闲状态的最大时间。如果超过了这个时间,且线程池中的线程数大于corePoolSize
,那么超出部分的空闲线程将会被终止。
long keepAliveTime = 60L; // 设置空闲线程存活时间为60秒
4. unit
:时间单位
与keepAliveTime
配套使用,用来指定存活时间的单位,可以是TimeUnit.MILLISECONDS
、TimeUnit.SECONDS
、TimeUnit.MINUTES
等七种预定义的时间单位之一。
TimeUnit unit = TimeUnit.SECONDS; // 设置存活时间单位为秒
5. workQueue
:任务队列
这是一个阻塞队列,用于存储等待执行的任务。常见的选择有LinkedBlockingQueue
、ArrayBlockingQueue
、SynchronousQueue
等。线程池会按照队列策略决定何时创建新线程或拒绝任务。
BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(10); // 创建一个容量为10的任务队列
6. threadFactory
:线程工厂
用于创建新线程的工厂类,可以根据需要定制线程的名称、优先级、是否守护线程等属性。默认情况下,线程工厂创建的线程是正常优先级、非守护线程。
ThreadFactory threadFactory = Executors.defaultThreadFactory(); // 使用默认线程工厂
// 或者自定义线程工厂
ThreadFactory customFactory = r -> {
Thread t = new Thread(r);
t.setName("CustomThread");
t.setDaemon(true);
return t;
};
7. handler
:拒绝策略
当线程池无法接受新提交的任务时(例如线程池已关闭,或者队列已满且线程数达到maximumPoolSize
),则需要采用一种拒绝策略来处理新任务。Java中有四种预定义的拒绝策略:
AbortPolicy
(默认):直接抛出RejectedExecutionException
异常。CallerRunsPolicy
:调用者所在的线程执行任务。DiscardPolicy
:默默丢弃任务。DiscardOldestPolicy
:丢弃队列中最旧的任务(即将最早进入队列但还未被执行的任务),尝试提交当前任务。
RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); // 使用默认的拒绝策略
// 或者自定义拒绝策略
RejectedExecutionHandler customHandler = (r, executor) -> System.out.println("Task " + r + " is rejected by the pool.");
结合以上参数,我们可以创建一个完整的线程池实例:
ThreadPoolExecutor executor = new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime,
unit,
workQueue,
threadFactory,
handler
);
这样就完成了一个可以根据业务需求灵活配置的线程池。在实际应用中,根据任务特性合理设置这些参数可以极大提升系统的并发处理能力和资源利用率。
标签:Java,示例,队列,keepAliveTime,maximumPoolSize,corePoolSize,任务,线程 From: https://blog.csdn.net/qq_29752857/article/details/136703276