ThreadPoolExecutor线程池
线程的创建和销毁都会消耗大量资源,就好像公司每天上午9点工作时就招进一批员工,晚上6点干完活就辞退一批员工,这都会销毁公司大量资源。所以合理利用 “池” 中固定、稳定的线程是非常有必要的。
扩展关系
ThreadPoolExecutor 构造方法
ThreadPoolExecutor 共有四个构造方法:
ThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>)ThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, ThreadFactory)ThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, RejectedExecutionHandler)ThreadPoolExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, ThreadFactory, RejectedExecutionHandler)
以最多参数的构造方法为例进行分析:
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler) { // 核心线程池不能小于0 if (corePoolSize < 0 || // 最大池大小不能小于等于0 maximumPoolSize <= 0 || // 最大池大小不能小于核心池大小 maximumPoolSize < corePoolSize || // 存活时间不能小于0 keepAliveTime < 0) // 否则将会抛出 IllegalArgumentException 非法参数异常 throw new IllegalArgumentException(); // 工作队列、线程工厂、拒绝执行的处理策略都不能为空,否则将会排除NPE空指针异常 if (workQueue == null || threadFactory == null || handler == null) throw new NullPointerException(); this.acc = System.getSecurityManager() == null ? null : AccessController.getContext(); this.corePoolSize = corePoolSize; this.maximumPoolSize = maximumPoolSize; this.workQueue = workQueue; this.keepAliveTime = unit.toNanos(keepAliveTime); this.threadFactory = threadFactory; this.handler = handler;}
1. 参数 corePoolSize 核心线程池大小:
线程池中一直会存活该大小的线程数,即使是没有工作(任务)需要执行。除非设置 allowCoreThreadTimeOut 为 true ,线程池中的核心线程会超时关闭。
2. 参数 maximumPoolSize 线程池最大大小:
线程池最大允许同时存活的线程的大小。
3. 参数 keepAliveTime 线程空闲时间:
当线程池中的线程空闲时间达到 keepAliveTime 时,线程会被销毁,仅保留 corePoolSize 大小线程,如果allowCoreThreadTimeOut 为 true ,则线程池中包含核心线程在内空闲线程都会被销毁。
4. 参数 unit 时间单位:
keepAliveTime 的时间单位(枚举类型)TimeUnit ,其可选单位有 TimeUnit.DAYS 天、TimeUnit.HOURS 小时、TimeUnit.MINUTES 分钟、TimeUnit.SECONDS秒、TimeUnitMILLISECONDS.毫秒、TimeUnit.MICROSECONDS微秒、TimeUnit.NANOSECONDS纳秒,常用的是秒。
5. 参数 workQueue 任务队列(工作队列、缓存队列):
当任务所需的线程数达到核心线程数 corePoolSize 时,新任务会放在工作队列中排队(缓存)等待执行。如果任务所需的线程数达到核心线程数 corePoolSize 时,并且工作队列已满时,并且线程池最大大小 maximumPoolSize 大于 核心线程池大小 corePoolSize 时,才会创建新的线程去处理任务。
经常有个错觉,认为当任务所需的线程数达到线程池最大线程数 maximumPoolSize 时,新任务才会进入工作队列,这是不对的。
6. 参数 threadFactory 线程工厂:
用于创建线程池中线程的工厂。创建线程时,经常会给这一批具有处理相同类型任务的线程命名和线程工厂命名(*线程工厂命名是指给poolName线程池命名,作为线程名称的前缀prefix),以此来标识线程的用处,在分析程序执行信息或排查程序异常问题时,非常有帮助。
7. 参数 handler 拒绝处理策略:
线程池拒绝处理任务有一下两者情况:
①. 当线程池中的线程数达到核心池大小时,并且任务队列已满,会使用拒绝处理策略;(此种情况就像工作台上的工作量积累已满,又没有足够的人员去处理,那么我们就可以拒绝处理新任务。)
②. 当调用shutdown() 方法后,会等待线程池中正在执行的任务执行完毕,然后再关闭线程池,如果在调用 shutdown() 方法后(还未真正关闭时),紧接着又有新的任务提交时,会使用拒绝处理策略。(此种情况就像工作到了下班时间,工作人员还在忙着手头上剩余的工作,如果此时又新任务提交,那么我们就可以拒绝处理新任务。)
(当然也可以不拒绝)
拒绝处理策略:
免责声明:
① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。
② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
软考中级精品资料免费领
- 历年真题答案解析
- 备考技巧名师总结
- 高频考点精准押题
- 资料下载
- 历年真题
193.9 KB下载数265
191.63 KB下载数245
143.91 KB下载数1148
183.71 KB下载数642
644.84 KB下载数2756
相关文章
发现更多好内容- 如何在 Java 中实现对正方形的缩放操作?(如何在Java中对正方形进行缩放操作)
- 如何正确使用 Java 的 join 方法?(java join方法怎么使用)
- Java 中 DecimalFormat 在哪些场景下使用较为合适?(Java DecimalFormat在哪里使用合适)
- 如何确保Redis客户端的安全性:实用技巧与最佳实践
- 在 JavaScript 中如何使用 parentNode?(javascript中的parentNode怎么用)
- 如何高效编码 Java Supplier 接口?(java supplier接口的高效编码技巧)
- 如何进行 Java NoSQL 查询优化?(java nosql查询优化怎样进行)
- Java 中 `equals()` 的核心究竟是什么?(java eques的核心是什么)
- Java代理模式的优缺点分别有哪些?(Java代理模式有哪些优缺点)
- 2024下半年北京软考成绩复查时间及流程