《java.util.concurrent 包源码阅读》11 线程池系列之ThreadPoolExecutor 第一部分

    public void execute(Runnable command) {
        if (command == null)
            throw new NullPointerException();

        /* 如果运行中的worker线程数少于设定的常驻线程数，增加worker线程，把task分配给新建的worker线程 */
        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();
            if (! isRunning(recheck) && remove(command))
                reject(command);
            else if (workerCountOf(recheck) == 0)
                addWorker(null, false);
        }

        // 如果任务数超过了现有worker线程的承受范围，尝试新建worker线程
        // 如果无法添加新的worker线程，则会拒绝该任务
        else if (!addWorker(command, false))
            reject(command);
    }

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

    private boolean addWorker(Runnable firstTask, boolean core) {
        retry:
        for (;;) {
            int c = ctl.get();
            int rs = runStateOf(c);

            // 返回false的情况：
            // 1. rs>shutdown，即shutdown和running以外的状态
            // 2. shutdown的状态
            //     1）firstTask不为null，即有task分配
            //     2）没有task，但是workQueue（等待任务队列）为空
            if (rs >= SHUTDOWN &&
                ! (rs == SHUTDOWN &&
                   firstTask == null &&
                   ! workQueue.isEmpty()))
                return false;

            for (;;) {
                // 1. 如果没有设定线程数的限制，worker线程数不能大于最大值（2的29次方-1）
                // 2. 如果是固定尺寸的线程池，不能大于固定尺寸
                // 3. 如果是可扩展的线程池，不能大于规定的线程数的上限
                int wc = workerCountOf(c);
                if (wc >= CAPACITY ||
                    wc >= (core ? corePoolSize : maximumPoolSize))
                    return false;
                // 用CAS操作增加线程数量，如果失败，重新循环
                if (compareAndIncrementWorkerCount(c))
                    break retry;
                c = ctl.get();  // Re-read ctl
                if (runStateOf(c) != rs)
                    continue retry;
                loop
            }
        }

        // 新建worker线程
        Worker w = new Worker(firstTask);
        Thread t = w.thread;

        final ReentrantLock mainLock = this.mainLock;
        mainLock.lock();
        try {
            int c = ctl.get();
            int rs = runStateOf(c);


            // 检查以下任一状态是否出现：
            // 1. 创建线程失败
            // 2. rs>shutdown，即shutdown和running以外的状态
            // 3. rs==shutdown，有任务分配
            if (t == null ||
                (rs >= SHUTDOWN &&
                 ! (rs == SHUTDOWN &&
                    firstTask == null))) {
                decrementWorkerCount();
                tryTerminate();
                return false;
            }

            workers.add(w);

            int s = workers.size();
            if (s > largestPoolSize)
                largestPoolSize = s;
        } finally {
            mainLock.unlock();
        }

        t.start();
        // 这里考虑一种极少出现的情况，如果worker线程调用start没有完成时，
        // 线程池进入Stop状态，这个时候会调用Thread#interrupt中断每个
        // worker线程，但是 interrupt对没有start的线程不一定起作用，这样
        // 就会漏掉了对这个thread的interrupt，因此在worker线程start之后
        // 检查以下，如果stop了，而这个线程却没有被interrupt，补上这个漏掉
        // 的interrupt。
        if (runStateOf(ctl.get()) == STOP && ! t.isInterrupted())
            t.interrupt();

        return true;
    }