前几天，技术群里有个群友问了一个关于线程池的问题，内容如图所示：

关于线程池相关知识可以先看下这篇：为什么阿里巴巴Java开发手册中强制要求线程池不允许使用Executors创建？

那么就来和大家探讨下这个问题，在线程池中，线程会从 workQueue 中读取任务来执行，最小的执行单位就是 Worker，Worker 实现了 Runnable 接口，重写了 run 方法，这个 run 方法是让每个线程去执行一个循环，在这个循环代码中，去判断是否有任务待执行，若有则直接去执行这个任务，因此线程数不会增加。

如下是线程池创建线程的整体流程图：

首先会判断线程池的状态，也就是是否在运行，若线程为非运行状态，则会拒绝。接下来会判断线程数是否小于核心线程数，若小于核心线程数，会新建工作线程并执行任务，随着任务的增多，线程数会慢慢增加至核心线程数，如果此时还有任务提交，就会判断阻塞队列 workQueue 是否已满，若没满，则会将任务放入到阻塞队列中，等待工作线程获得并执行，如果任务提交非常多，使得阻塞队列达到上限，会去判断线程数是否小于最大线程数 maximumPoolSize，若小于最大线程数，线程池会添加工作线程并执行任务，如果仍然有大量任务提交，使得线程数等于最大线程数，如果此时还有任务提交，就会被拒绝。

现在我们对这个流程大致有所了解，那么让我们去看看源码是如何实现的吧！

线程池的任务提交从 submit 方法来说，submit 方法是 AbstractExecutorService 抽象类定义的，主要做了两件事情：

  1. 把 Runnable 和 Callable 都转化成 FutureTask
  2. 使用 execute 方法执行 FutureTask

execute 方法是 ThreadPoolExecutor 中的方法，源码如下：

public void execute(Runnable command) {
    // 若任务为空，则抛 NPE，不能执行空任务
    if (command == null) {
        throw new NullPointerException();
    }
    int c = ctl.get();
    // 若工作线程数小于核心线程数，则创建新的线程，并把当前任务 command 作为这个线程的第一个任务
    if (workerCountOf(c) < corePoolSize) {
        if (addWorker(command, true)) {
            return;
        }
        c = ctl.get();
    }
    /**
        * 至此，有以下两种情况：
        * 1.当前工作线程数大于等于核心线程数
        * 2.新建线程失败
        * 此时会尝试将任务添加到阻塞队列 workQueue
        */
    // 若线程池处于 RUNNING 状态，将任务添加到阻塞队列 workQueue 中
    if (isRunning(c) && workQueue.offer(command)) {
        // 再次检查线程池标记
        int recheck = ctl.get();
        //