线程池 ThreadPoolExecutor解析

野性酷女 2022-03-11 09:22 533阅读 0赞

`ThreadPoolExecutor`中的几个比较重要的成员变量：

private final BlockingQueue<Runnable> workQueue; //任务缓存队列，用来保存等待中的任务，等待worker线程空闲时执行任务
    private final ReentrantLock mainLock = new ReentrantLock(); //更新 poolSize, corePoolSize,maximumPoolSize, runState, and workers set 时需要持有这个锁
    private final HashSet<Worker> workers = new HashSet<Worker>(); //用来保存工作中的执行线程
    private volatile long  keepAliveTime; //超过corePoolSize外的线程空闲存活之间
    private volatile boolean allowCoreThreadTimeOut; //是否对corePoolSize内的线程设置空闲存活时间
    private volatile int   corePoolSize; //核心线程数
    private volatile int   maximumPoolSize; //最大线程数（即线程池中的线程数目大于这个参数时，提交的任务会被放进任务缓存队列）
    private volatile int   poolSize; //线程池中的当前线程数
    private volatile RejectedExecutionHandler handler; //任务拒绝策略
    private volatile ThreadFactory threadFactory; //线程工厂，用来新建线程
    private int largestPoolSize; //记录线程池中出现过的最大线程数大小
    private long completedTaskCount; //已经执行完的线程数

这边重点解释下 `corePoolSize`、`maximumPoolSize`、`workQueue`两个变量，这两个变量涉及到线程池中创建线程个数的一个策略。  
`corePoolSize`： 这个变量我们可以理解为线程池的核心大小，举个例子来说明（corePoolSize假设等于10，maximumPoolSize等于20）：

1.  有一个部门，其中有10（corePoolSize）名工人，当有新任务来了后，领导就分配任务给工人去做，每个工人只能做一个任务。
2.  当10个工人都在忙时，新来的任务就要放到队列（workQueue）中等待。
3.  当任务越积累越多，远远超过工人做任务的速度时，领导就想了一个办法：从其他部门借10个工人来，借的数量有一个公式（maximumPoolSize - corePoolSize）来计算。然后把新来的任务分配给借来的工人来做。
4.  但是如果完成任务的速度还是还不够快的话，可能就要采取措施来放弃一些任务了（RejectedExecutionHandler）。  
    等到一定时间后，任务都完成了，工人比较闲的情况下，就考虑把借来的10个工人还回去（根据keepAliveTime判断）
5.  也就是说corePoolSize就是线程池大小，maximumPoolSize在我看来是线程池的一种补救措施，即任务量突然过大时的一种补救措施。

任务提交给线程池之后到被执行的整个过程

*  如果当前线程池中的线程数目小于corePoolSize，则每来一个任务，就会创建一个线程去执行这个任务；
 *  如果当前线程池中的线程数目>=corePoolSize，则每来一个任务，会尝试将其添加到任务缓存队列当中，若添加成功，则该任务会等待空闲线程将其取出去执行；若添加失败（一般来说是任务缓存队列已满），则会尝试创建新的线程去执行这个任务；
 *  如果当前线程池中的线程数目达到maximumPoolSize，则会采取任务拒绝策略进行处理；
 *  如果线程池中的线程数量大于 corePoolSize时，如果某线程空闲时间超过keepAliveTime，线程将被终止，直至线程池中的线程数目不大于 corePoolSize；如果允许为核心池中的线程设置存活时间，那么核心池中的线程空闲时间超过keepAliveTime，线程也会被终止。

构造方法主要包含7个参数

int corePoolSize, //核心线程数
    int maximumPoolSize, //最大线程数（即线程池中的线程数目大于这个参数时，提交的任务会被放进任务缓存队列）
    long keepAliveTime,  //超过corePoolSize外的线程空闲存活之间
    TimeUnit unit,  //keepAliveTime 的时间单位
    BlockingQueue<Runnable> workQueue,   //任务缓存队列，用来保存等待中的任务，等待worker线程空闲时执行任务
    ThreadFactory threadFactory, //线程工厂，用来新建线程
    RejectedExecutionHandler handler   //任务拒绝策略