线程池的处理流程

当提交一个新任务到线程池时，线程池的处理流程如下：

1、线程池判断核心线程池里的线程是否都在执行任务。如果不是，则创建一个新的工作线程来执行任务。如果核心线程池里的线程都在执行任务，则进入下个流程。

2、线程池判断工作队列是否已经满。如果工作队列没有满，则将新提交的任务存储在这个工作队列里。如果工作队列满了，则进入下个流程。

3、线程池判断线程池的线程是否都处于工作状态。如果没有，则创建一个新的工作线程来执行任务。如果已经满了，则交给饱和策略来处理这个任务。

如下图：

Java中线程池的类是ThreadPoolExecutor，里面执行的方法是execute方法，主要的execute的执行流程如下：

---

总结

上述两张图描述的都是一个流程，简洁总结一下就是：

1. 添加任务，首先会判断核心线程池是否已满（假设设置的核心线程数为n个，编译器不会一次性 new n 个线程出来，而是根据任务量来创建）

   • 如果不满，则创建一个 “核心” 线程来执行任务（此操作需要获取全局锁）
   • 如果满了，则将任务添加进阻塞队列 BlockingQueue 中

2. 将任务添加进阻塞队列 BlockingQueue 中后，会判断该队列是否已满

   • 如果不满，则添加进队列中，等待核心线程来取任务，然后执行任务
   • 如果满了，则创建新的线程（这种线程称为 “工作线程”，不能大于 maximumPoolSize ）来执行任务（此操作需要获取全局锁）

3. 如果 BlockingQueue 已满，且线程数已经到达 maximumPoolSize ，此时提交进来的任务会根据拒绝策略来变动