线程池的生命周期

 private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));

 ThreadPoolExecutor使用一个ctl变量代表两个信息，线程池的运行状态 (runState) 和 线程池内有效线程的数量 (workerCount)，高三位表示状态。

workerCount：线程池内有效线程的数量，工作线程允许开始，不允许停止，使用ctl的低29位表示

runState：线程的生命周期，是有序的随时间递增，也就是状态不可逆的。

    private static final int COUNT_BITS = Integer.SIZE - 3;private static final int CAPACITY   = (1 << COUNT_BITS) - 1;// runState is stored in the high-order bitsprivate static final int RUNNING    = -1 << COUNT_BITS;private static final int SHUTDOWN   =  0 << COUNT_BITS;private static final int STOP       =  1 << COUNT_BITS;private static final int TIDYING    =  2 << COUNT_BITS;private static final int TERMINATED =  3 << COUNT_BITS;// Packing and unpacking ctlprivate static int runStateOf(int c)     { return c & ~CAPACITY; }private static int workerCountOf(int c)  { return c & CAPACITY; }private static int ctlOf(int rs, int wc) { return rs | wc; }

 任务调度

execute

  public void execute(Runnable command) {
//判断任务是否为空if (command == null)throw new NullPointerException();
//获取当前工作线程数量和线程状态int c = ctl.get();
//如果工作线程数小于核心线程数if (workerCountOf(c) < corePoolSize) {
//增加一个核心线程去执行任务
//增加成功结束if (addWorker(command, true))return;
//增加失败，再次获取当前线程池的工作线程数量和线程状态c = ctl.get();}
//如果当前线程池正在运行
//将任务放入阻塞队列if (isRunning(c) && workQueue.offer(command)) {
//插入成功★
//再次获取当前线程池的工作线程数量和线程状态int recheck = ctl.get();
//此时（并发情况）线程池非Running状态
//将任务移除阻塞队列if (! isRunning(recheck) && remove(command))
//移除成功，执行抛弃策略reject(command);
//移除失败，则判断当前的工作线程数是否为0else if (workerCountOf(recheck) == 0)
//为0则增加一个空工作线程，（去执行★之前插入成功的任务）addWorker(null, false);}
//创建一个非核心线程去执行任务else if (!addWorker(command, false))
//创建失败，执行拒绝策略reject(command);}

 submit

submit传入任务以及其返回值类型，如果任务是Runnable的话上会将任务包装成Callable任务也就是RunnableFuture，然后再丢给execute去执行。

阻塞队列

线程池使用阻塞队列将要执行的任务与线程分开，用生产者和消费者模型实现。

当任务数量超过核心线程数，后续任务就会放入阻塞队列中进行排队。

因为实现了BlockingQueue所以都是线程安全的。

任务拒绝

当线程池的缓存队列已满，线程数也达到了maximumPoolSize 时，再新增任务就会触发拒绝策略。

拒绝策略收到三个参数影响：corePoolSize 、maximumPoolSize 、workQueue 。

当任务提交后，如果没达到核心线程数，则会直接创建核心线程运行，如果达到了核心线程数则会放入队列中等待，当任务数大于workQueue.size+maximumPoolSize则触发拒绝策略。

常用线程池