getTask方法: 实现救急线程存活keepAliveTime

目录

注意

拿ArrayBlockingQueue举例：

take

poll

 拓展

spinForTimeoutThreshold

getTask 源码解析

---

注意

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

也就是在源码中并不区分线程的性质，当目前的线程数量大于核心线程数，该线程从阻塞队列中拉取任务时就用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;
            }
        }
    }