注意

在线程池中，核心线程和非核心线程其实并没有专门的一个变量来表示。

也就是在源码中并不区分线程的性质，当目前的线程数量大于核心线程数，该线程从阻塞队列中拉取任务时就用poll（可以理解为是非核心线程），小于等于就用take（可以理解为是核心线程）。

拿ArrayBlockingQueue举例：

take

poll

拓展

condition的带有超时时间的等待的源码实现

spinForTimeoutThreshold

自旋的时间阈值是1微秒。

nanosTimeout > spinForTimeoutThreshold 是为了让那些超时时间非常短的线程，不去调用park

，直接快速自旋，因为这个时间非常短，没有必要进行park。

getTask 源码解析

getTask 中，如果当前的工作线程数量大于核心线程数，那么当前该线程就会调用poll方法，如果在超时时间内都没有返回任务，那么下一次循环中就会返回null。

在接收到是null 后就会执行processWorkerExit方法，清除掉该worker。

传入的任务就直接执行执行完毕之后就会去通过getTask 去take / poll队列中的任务继续执行

如果队列中没有任务那么当前 worker 就会在对应的，condition 中await等待，直到有任务来被唤醒。

 private Runnable getTask() {
        boolean timedOut = false; // Did the last poll() time out?

        for (;;) {
            int c = ctl.get();
            int rs = runStateOf(c);

            //如果进入if,需要回收当前工作线程
            //线程池状态为SHUTDOWN、STOP
            //如果线程池状态大于等于STOP,需要移除掉当前工作线程
            //如果线程池状态为SHUTDOWN,并且工作队列为空，需要移除掉当前工作线程
            if (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) {
                decrementWorkerCount();
                return null;
            }

            int wc = workerCountOf(c);

            // 如果某一个线程 在gettask 的时候，发现此时的工作线程数超出了核心线程数
            // 那么当前这个线程就可以理解为 非核心线程
            boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;

            // 非核心线程在poll 超时后 就会被清理
            if ((wc > maximumPoolSize || (timed && timedOut))
                && (wc > 1 || workQueue.isEmpty())) {
                if (compareAndDecrementWorkerCount(c))
                    return null;
                continue;
            }

            try {
                Runnable r = timed ?
                    workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
                    workQueue.take();
                if (r != null)
                    return r;
                timedOut = true;
            } catch (InterruptedException retry) {
                timedOut = false;
            }
        }
    }

文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/92784.html