ThreadPoolExecutor
1. ThreadPoolExecutor
Spring 中的 ThreadPoolTaskExecutor 是借助于 JDK 并发包中的 java.util.concurrent.ThreadPoolExecutor 来实现的，下面先学习下 ThreadPoolExecutor 中的相关信息，ThreadPoolExecutor 构造函数如下：
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) {
}
参数具体意义：
int corePoolSize：线程池维护线程的最小数量
int maximumPoolSize：线程池维护线程的最大数量
long keepAliveTime：空闲线程的存活时间
TimeUnit unit：时间单位，现有纳秒、微秒、毫秒、秒枚举值
BlockingQueue
RejectedExecutionHandler handler：用来拒绝一个任务的执行，有两种情况会发生这种情况
一是在 execute 方法中若 addIfUnderMaximumPoolSize(command) 为 false，即线程池已经饱和
二是在 execute 方法中, 发现 runState!=RUNNING || poolSize == 0，即已经 shutdown，就调用 ensureQueuedTaskHandled(Runnable command)，在该方法中有可能调用 reject
Reject策略预定义有四种：
(1) ThreadPoolExecutor.AbortPolicy 策略，是默认的策略，处理程序遭到拒绝将抛出运行时 RejectedExecutionException
(2) ThreadPoolExecutor.CallerRunsPolicy 策略 ,调用者的线程会执行该任务，如果执行器已关闭，则丢弃
(3) ThreadPoolExecutor.DiscardPolicy 策略，不能执行的任务将被丢弃
(4) ThreadPoolExecutor.DiscardOldestPolicy 策略，如果执行程序尚未关闭，则位于工作队列头部的任务将被删除，然后重试执行程序（如果再次失败，则重复此过程）
ThreadPoolExecutor 源码分析：
public class ThreadPoolExecutor extends AbstractExecutorService {
……
}
public abstract class AbstractExecutorService implements ExecutorService {
……
}
This chapter requires login to view full content. You are viewing a preview.
Login to View Full ContentCourse Curriculum
编程根基：数据结构、算法与系统基础
Java 内核：JVM 与并发编程
框架与 I/O：Spring、Netty 与 Web 容器
高性能中间件：消息、缓存与存储
架构能力：高可用、DDD 与系统设计
云原生：容器化、可观测性与工程效能
Speaker
