// 源码
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) {
if (corePoolSize < 0 ||
maximumPoolSize <= 0 ||
maximumPoolSize < corePoolSize ||
keepAliveTime < 0)
throw new IllegalArgumentException();
if (workQueue == null || threadFactory == null || handler == null)
throw new NullPointerException();
this.corePoolSize = corePoolSize;
this.maximumPoolSize = maximumPoolSize;
this.workQueue = workQueue;
this.keepAliveTime = unit.toNanos(keepAliveTime);
this.threadFactory = threadFactory;
this.handler = handler;
}
参数详解
corePoolSize:核心线程数,也是线程池保留的最小线程数maximumPoolSize:最大线程数,maximumPoolSize ≥ corePoolSizekeepAliveTime:空闲线程存活时间TimeUnit :keepAliveTime 的单位workQueue: 工作队列;等待队列
无界队列有界队列:ArrayBlockingQueue、有界的linkedBlockingQueue、有界的PriorityBlockingQueue、有界的linkedBlockingDueue (双端队列)同步移交:SynchronousQueue threadFactory:线程工厂;线程池中的每一个线程创建都是通过线程工厂,默认的线程工厂会创建一个新的、非守护线程handler:拒绝策略
AbortPolicy:默认的拒绝策略;抛出RejectedExecutionExceptionCallerRunsPolicy:调用者运行策略;不抛弃任务,也不抛出异常,将任务回退给调用者DiscardPolicy: 队列满后直接丢弃新来的任务,不抛异常DiscardOldestPolicy: 抛弃下一个将会被执行的任务,如果是优先级队列,会抛弃优先级最高的; 线程池工作原理:
- 如果当前运行的线程数 < corePoolSize,则会创建新的线程执行任务;线程池初始化时,线程池是空的,如果当前线程数 < corePoolSize,对于新来的任务,会创建新的线程执行该任务;如果当前运行的线程数 ≥ corePoolSize,则会将任务放入 workQueue如果 workQueue 已经被填满,则会创建新的线程来处理新来的任务,而不是先执行 workQueue中的任务如果当前运行线程数超过 maximumPoolSize,会通过拒绝策略拒绝任务



