Java线程池--原理--keepAliveTime的作用

原文网址：Java线程池--原理--keepAliveTime的作用_IT利刃出鞘的博客-CSDN博客

        本文介绍Java的线程池中的keepAliveTime的作用

        worker 线程会从阻塞队列中获取需要执行的任务，这个方法不是简单的 take 数据。

         你也许好奇是怎样判断线程有多久没有活动了，是不是以为线程池会启动一个监控线程，专门监控哪个线程正在偷懒？想太多，其实只是在线程从工作队列 poll 任务时，加上了超时限制，如果线程在 keepAliveTime 的时间内 poll 不到任务，那我就认为这条线程没事做，可以干掉了 。

源码分析

ThreadPoolExecutor#getTask() 

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

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

            // Check if queue empty only if necessary.
            if (rs >= SHUTDOWN && (rs >= STOP || workQueue.isEmpty())) {
                decrementWorkerCount();
                return null;;//返回 null，则当前 worker 线程会退出
            }

            int wc = workerCountOf(c);

			// timed 变量用于判断是否需要进行超时控制。
			// allowCoreThreadTimeOut 默认是 false，也就是核心线程不允许进行超时；
 			// wc > corePoolSize，表示当前线程池中的线程数量大于核心线程数量；
 			// 对于超过核心线程数量的这些线程，需要进行超时控制
            // Are workers subject to culling?
            boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;

			
            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) //如果拿到的任务不为空，则直接返回给 worker 进行处理
                    return r;
                timedOut = true;// 如果 r==null，说明已经超时了,队列中仍然没有任务，此时设置timedOut=true，在下次自旋的时候进行回收
                
            } catch (InterruptedException retry) {
            // 如果获取任务时当前线程发生了中断，则设置 timedOut 为false 并返回循环重试
                timedOut = false;
            }
        }
    }

线程池中的线程是如何监控达到keepAliveTime时间_Emine-CSDN博客_线程池keepalivetime实现原理