ThreadPoolExecutor的execute方法

绝地灬酷狼 2023-10-12 21:06 52阅读 0赞

### 方法介绍 ###

> execute方法是将任务提交到线程池中的核心方法。线程池的执行流程可以通过execute内部进行的逻辑判断得知。

### 代码展示与分析 ###

*  Runnable command。方法体中的参数代表着提交过来的任务。
 *  任务不能为null的非空判断。不然就会抛出空指针异常。
 *  int c = ctl.get();获取ctl的核心属性，就是获取线程的数量。用于后续的逻辑判断。
 *  if (workerCountOf© < corePoolSize) 。懒加载的体现。workerCountOf拿到低29位的值，工作线程数量小于核心工作线程的条件下：if (addWorker(command, true))执行里面的方法，方法中的true代表着是添加核心工作线程。添加核心线程成功返回true，直接交给添加进去的线程处理任务就可以，直接return返回。要是失败了就false。逻辑进不来。执行下面的c = ctl.get();执行下面的方法说明线程池状态或者数量发生了变化，那就重新执行一次ctl。
 *  要是上述添加核心工作线程失败之后执行后面的逻辑判断和代码。
 *  if (isRunning© && workQueue.offer(command))。首先线程池必须是Running状态。然后基于阻塞队列的offer方法将任务添加到阻塞队列之中。
 *  int recheck = ctl.get();重新获取ctl的值。
 *  if (! isRunning(recheck) && remove(command))。要是线程池的状态不是Running并且remove成功。那就执行拒绝策略。
 *  否则要是else if (workerCountOf(recheck) == 0)。判断要是核心工作线程数是0.那就添加一个没有任务的非核心工作线程进去。防止阻塞队列中的任务饥饿问题。这里就是有两种情况：1.构建线程池的时候，核心工作线程数是0。2.存在核心工作线程，但是核心工作线程允许超时，设置allowCoreThreadTimeOut为true。
 *  else if (!addWorker(command, false))。执行到这里是上述添加到阻塞队列失败了。构建一个非核心工作线程，要是构建一个非核心工作线程成功那就结束。要是构建非核心工作线程也是失败的，那就执行拒绝策略。

![在这里插入图片描述][4c8ff57cb9d04c82bab9e722c9cbc35f.png]

[4c8ff57cb9d04c82bab9e722c9cbc35f.png]: https://img-blog.csdnimg.cn/4c8ff57cb9d04c82bab9e722c9cbc35f.png