源码解析：ThreadPoolExecutor（3）
2.3> 拒绝策略的实现
- 线程池中提供了如下拒绝策略：
- AbortPolicy
丢弃任务并抛出RejectedExecutionException异常。
- DiscardPolicy
丢弃任务，但是不抛出异常。
- DiscardOldestPolicy
丢弃队列中最前面的任务，然后重新尝试执行任务。
- CallerRunsPolicy
由调用线程处理该任务。
2.4> 任务队列BlockingQueue的实现
- 线程池中提供了如下拒绝策略：
- ArrayBlockingQueue
它是一个有界的阻塞队列，其内部实现是将对象放到一个数组里。一但初始化，大小就无法修改。
- LinkedBlockingQueue
它内部以一个链式结构（链接节点）对其元素进行存储。可以指定元素上限，否则，上限则为Integer.MAX_VALUE。
- DelayQueue
它对元素进行持有直到一个特定的延迟到期。注意：进入其中的元素必须实现Delayed接口。
- PriorityBlockingQueue
它是一个无界的并发队列。无法向这个队列中插入null值。所有插入到这个队列中的元素必须实现Comparable接口。因此该队列中元素的排序就取决于你自己的Comparable实现。
- SynchronousQueue
它是一个特殊的队列，它的内部同时只能够容纳单个元素。如果该队列已有一个元素的话，那么试图向队列中插入一个新元素的线程将会阻塞，直到另一个新线程将该元素从队列中抽走。同样的，如果队列为空，试图向队列中抽取一个元素的线程将会被阻塞，直到另一个线程向队列中插入了一条新的元素。因此，它其实不太像是一个队列，而更像是一个汇合点。
三、 源码解析——execute(Runnable command)
- 针对与execute方法可以分为四部分来分析，我们下面就针对这四部分，一一去深入解析
- 第一部分：什么是ctl
- 第二部分：线程池中的线程数量小于核心线程数的代码逻辑
- 第三部分：不满足【第二部分条件】时，任务添加到队列的代码逻辑
- 第四部分：不满足【第三部分条件】时，线程池中的线程数量小于最大线程数代码逻辑以及拒绝策略的代码逻辑
3.1> 流程概述
- execute的整体流程如下所示：
【解释】
在上面的流程图中，我们看到三块绿色的addWorker方法，和两块红色的reject方法，那么这两个方法，也会是我们解析的重点。此处我们先暂且不提。
后面的内容，参见：源码解析：ThreadPoolExecutor（4）
本文参与?腾讯云自媒体分享计划，分享自微信公众号。
原始发表：2021-10-20，如有侵权请联系?cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录