线程池代码

代码的注释都写在了
这里

1. 线程的生命周期

ExecutorService主要功能

/**
  * 履行Ruannable类型的任务
  * @param command
  */
 void execute(Runnable command);
 
  /**
  * 可用来提交Callable或Runnable任务，并返回代表此任务的Future
  * 对象
  * @param task
  * @param <T>
  * @return
  */
 <T> Future<T> submit(Callable<T> task);
 
 /**
  * 在完成已提交的任务后封闭办事，不再接管新任务
  */
 void shutdown();
 
  /**
  * 停止所有正在履行的任务并封闭办事。
  * @return
  */
 List<Runnable> shutdownNow();
 
  /**
  * 测试是否所有任务都履行完毕了。
  * @return
  */
 boolean isTerminated();
 
  /**
  * 测试是否该ExecutorService已被关闭。
  * @return
  */
 boolean isShutdown();

2. 线程池的重点属性：

/**
     * ctl 是对线程池的运行状态和线程池中有效数量进行控制的一个字段，它包含两部分的信息：
     * 线程池的运行状态（runState）
     * 线程池内线程有效的线程数量（workerCount）
     * 使用Integer类型来保存，高三位来保存runState，低29位来保存workerCount。
     *
     * COUNT_BITS 就是29
     *
     * COUNT_MASK 1左移29位-1，这个常量表示workerCount的上限值，大概是5亿左右
     */
    private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));
    private static final int COUNT_BITS = Integer.SIZE - 3;
    private static final int COUNT_MASK = (1 << COUNT_BITS) - 1;
    
    // Packing and unpacking ctl

    /**
     * 这是是关于ctl的一些方法
     * runStateOf 获取运行状态
     * workerCountOf 获取活动线程数
     * ctlOf 获取运行状态和活动线程数的值。
     *
     */
    private static int runStateOf(int c)     { return c & ~COUNT_MASK; }
    private static int workerCountOf(int c)  { return c & COUNT_MASK; }
    private static int ctlOf(int rs, int wc) { return rs | wc; }
    
     // 线程池的5种状态
    /**
     * 高三位为111
     * 1) 状态说明：线程池处在RUNNING状态时，能够接收新任务，以及对已添加的任务进行
     * 处理。
     * 2) 状态切换：线程池的初始化状态是RUNNING。换句话说，线程池被一旦被创建，就处
     * 于RUNNING状态，并且线程池中的任务数为0！
     */
    private static final int RUNNING    = -1 << COUNT_BITS;
    /**
     *高三位为000
     *1) 状态说明：线程池处在SHUTDOWN状态时，不接收新任务，但能处理已添加的任务。
     *2) 状态切换：调用线程池的shutdown()接口时，线程池由RUNNING -> SHUTDOWN。
     */
    private static final int SHUTDOWN   =  0 << COUNT_BITS;
    /**
     * 高三位为001
     * 1) 状态说明：线程池处在STOP状态时，不接收新任务，不处理已添加的任务，并且会中
     * 断正在处理的任务。
     * 2) 状态切换：调用线程池的shutdownNow()接口时，线程池由(RUNNING or
     * SHUTDOWN ) -> STOP。
     */
    private static final int STOP       =  1 << COUNT_BITS;
    /**
     * 高三位为010
     * 1) 状态说明：当所有的任务已终止，ctl记录的”任务数量”为0，线程池会变为TIDYING
     * 状态。当线程池变为TIDYING状态时，会执行钩子函数terminated()。terminated()在
     * ThreadPoolExecutor类中是空的，若用户想在线程池变为TIDYING时，进行相应的处理；
     * 可以通过重载terminated()函数来实现。
     * 2) 状态切换：当线程池在SHUTDOWN状态下，阻塞队列为空并且线程池中执行的任务也
     * 为空时，就会由 SHUTDOWN -> TIDYING。 当线程池在STOP状态下，线程池中执行的
     * 任务为空时，就会由STOP -> TIDYING。
     */
    private static final int TIDYING    =  2 << COUNT_BITS;
    /**
     * 高三位为011
     * 1) 状态说明：线程池彻底终止，就变成TERMINATED状态。
     * 2) 状态切换：线程池处在TIDYING状态时，执行完terminated()之后，就会由 TIDYING -
     * > TERMINATED。
     * 进入TERMINATED的条件如下：
     * 线程池不是RUNNING状态；
     * 线程池状态不是TIDYING状态或TERMINATED状态；
     * 如果线程池状态是SHUTDOWN并且workerQueue为空；
     * workerCount为0；
     * 设置TIDYING状态成功。
     */
    private static final int TERMINATED =  3 << COUNT_BITS;

3. 线程池的具体实现

ThreadPoolExecutor 默认的线程池
ScheduledThreadPoolExecutor 定时线程池

线程池代码

代码的注释都写在了这里

1. 线程的生命周期

2. 线程池的重点属性：

3. 线程池的具体实现

代码的注释都写在了
这里