Spring 自带的线程池说明

Spring 自带的线程池 配置参数

< bean id=“taskExecutor” class=“org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor”> < !-- 核心线程数 --> < property name=“corePoolSize” value=“10” /> < !-- 最大线程数 --> < property name=“maxPoolSize” value=“100” /> < !-- 队列最大长度 >=mainExecutor.maxSize --> < property name=“queueCapacity” value=“1000” /> < !-- 线程池维护线程所允许的空闲时间 --> < property name=“keepAliveSeconds” value=“300” /> < !-- 线程池对拒绝任务(无线程可用)的处理策略 --> < property name=“rejectedExecutionHandler”> < bean class=“java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy” /> </ property> </ bean>

配置的属性字段说明如下： corePoolSize：线程池维护线程的最少数量 keepAliveSeconds：允许的空闲时间 maxPoolSize：线程池维护线程的最大数量 queueCapacity：缓存队列 rejectedExecutionHandler：对拒绝task的处理策略

线程池的参数运行原理：

如果此时线程池中的数量小于corePoolSize配置的值，即使线程池中的线程都处于空闲状态，也会创建新的线程来处理被添加的任务。

如果此时线程池中的数量等于 corePoolSize配置的值，但是缓冲队列 workQueue未满时，任务就会被放入缓冲队列中。

如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量小于maxPoolSize，建新的线程来处理被添加的任务。

如果此时线程池中的数量大于corePoolSize，缓冲队列workQueue满，并且线程池中的数量等于maxPoolSize，通过handler所指定的策略来处理此任务。 解释 处理任务的优先级为： 核心线程corePoolSize、 任务队列workQueue、 最大线程 maximumPoolSize， 如果以上三者都满了， 使用handler处理被拒绝的任务。

当线程池中的线程数量大于corePoolSize时，如果某线程空闲时间超过keepAliveTime，线程将被终止，线程池可以动态的调整池中的线程数。