tomcat优化jvm(Tomcat修正JDK原生线程池bug的实现原理)
tomcat优化jvm
Tomcat修正JDK原生线程池bug的实现原理为提高处理能力和并发度,Web容器一般会把处理请求的任务放到线程池,而JDK的原生线程池先天适合CPU密集型任务,于是Tomcat改造之。
Tomcat 线程池原理其实ThreadPoolExecutor的参数主要有如下关键点:
限制线程个数
限制队列长度
而Tomcat对这俩资源都需要限制,否则高并发下CPU、内存都有被耗尽可能。
因此Tomcat的线程池传参:
// 定制的任务队列 taskqueue = new TaskQueue(maxQueueSize); // 定制的线程工厂 TaskThreadFactory tf = new TaskThreadFactory(namePrefix, daemon, getThreadPriority() ); // 定制线程池 executor = new ThreadPoolExecutor(getMinSpareThreads(), getMaxThreads(), maxIdleTime, TimeUnit.MILLISECONDS, taskqueue, tf);
Tomcat对线程数也有限制,设置:
- 核心线程数(minSpareThreads)
- 最大线程池数(maxThreads)
Tomcat线程池还有自己的特色任务处理流程,通过重写execute方法实现了自己的特色任务处理逻辑:
- 前corePoolSize个任务时,来一个任务就创建一个新线程
- 再有任务,就把任务放入任务队列,让所有线程去抢。若队列满,就创建临时线程
- 总线程数达到maximumPoolSize,则继续尝试把任务放入任务队列
- 若缓冲队列也满了,插入失败,执行拒绝策略
和 JDK 线程池的区别就在step3,Tomcat在线程总数达到最大数时,不是立即执行拒绝策略,而是再尝试向任务队列添加任务,添加失败后再执行拒绝策略。
具体又是如何实现的呢?
public void execute(Runnable command, long timeout, TimeUnit unit) { submittedCount.incrementAndGet(); try { // 调用JDK原生线程池的execute执行任务 super.execute(command); } catch (RejectedExecutionException rx) { // 总线程数达到maximumPoolSize后,JDK原生线程池会执行默认拒绝策略 if (super.getQueue() instanceof TaskQueue) { final TaskQueue queue = (TaskQueue)super.getQueue(); try { // 继续尝试把任务放入任务队列 if (!queue.force(command, timeout, unit)) { submittedCount.decrementAndGet(); // 若缓冲队列还是满了,插入失败,执行拒绝策略。 throw new RejectedExecutionException("..."); } } } } }
Tomcat线程池的execute方法第一行:
submittedCount.incrementAndGet();
任务执行失败,抛异常时,将该计数器减一:
submittedCount.decrementAndGet();
Tomcat线程池使用 submittedCount 变量维护已提交到线程池,但未执行完的任务数量。
为何要维护这样一个变量呢?
Tomcat的任务队列TaskQueue扩展了JDK的LinkedBlockingQueue,Tomcat给了它一个capacity,传给父类LinkedBlockingQueue的构造器。
public class TaskQueue extends LinkedBlockingQueue<Runnable> { public TaskQueue(int capacity) { super(capacity); } ... }
capacity参数通过Tomcat的maxQueueSize参数设置,但maxQueueSize默认值Integer.MAX_VALUE:当前线程数达到核心线程数后,再来任务的话线程池会把任务添加到任务队列,并且总会成功,就永远无机会创建新线程了。
为解决该问题,TaskQueue重写了LinkedBlockingQueue#offer,在合适时机返回false,表示任务添加失败,这时线程池就会创建新线程。
什么叫合适时机?
public class TaskQueue extends LinkedBlockingQueue<Runnable> { ... @Override // 线程池调用任务队列的方法时,当前线程数 > core线程数 public boolean offer(Runnable o) { // 若线程数已达max,则不能创建新线程,只能放入任务队列 if (parent.getPoolSize() == parent.getMaximumPoolSize()) return super.offer(o); // 至此,表明 max线程数 > 当前线程数 > core线程数 // 说明可创建新线程: // 1. 若已提交任务数 < 当前线程数 // 表明还有空闲线程,无需创建新线程 if (parent.getSubmittedCount()<=(parent.getPoolSize())) return super.offer(o); // 2. 若已提交任务数 > 当前线程数 // 线程不够用了,返回false去创建新线程 if (parent.getPoolSize()<parent.getMaximumPoolSize()) return false; // 默认情况下总是把任务放入任务队列 return super.offer(o); } }
所以Tomcat维护 已提交任务数 是为了在任务队列长度无限时,让线程池还能有机会创建新线程。
到此这篇关于Tomcat是如何修正JDK原生线程池bug的的文章就介绍到这了,更多相关Tomcat JDK原生线程池内容请搜索开心学习网以前的文章或继续浏览下面的相关文章希望大家以后多多支持开心学习网!
- tomcat部署web项目操作(Tomcat首次部署web项目流程图解)
- springboot内置tomcat启动过程(Tomcat启动springboot项目war包报错:启动子级时出错的问题)
- tomcat服务如何在eclipse中配置(HBuilderX配置tomcat外部服务器查看编辑jsp界面的方法详解)
- centos6tomcat安装(Tomcat CentOS安装实现过程图解)
- nginx tomcat docker 负载均衡(Nginx+Tomcat实现负载均衡、动静分离的原理解析)
- 多个tomcat实例配置文件(tomcat单机多实例的实现)
- 如何让tomcat启动更快(快速解决Tomcat启动慢的问题,超简单)
- apache服务部署tomcat(详解Apache 和 Tomcat 整合原理、配置方案)
- tomcat架构解析(浅谈Tomcat多层容器的设计)
- nginx tomcat集群(Nginx+tomcat负载均衡集群的实现方法)
- tomcat启动闪退拒绝访问(详解Tomcat双击startup.bat闪退的解决方法)
- docker运行tomcat服务(使用 docker部署tomcat并接入skywalking的使用)
- tomcat优化jvm(Tomcat修正JDK原生线程池bug的实现原理)
- tomcatweb 管理(Tomcat源码解析之Web请求与处理)
- tomcat怎么知道访问servlet(详解从源码分析tomcat如何调用Servlet的初始化)
- linux下启动tomcat服务(Linux系统安装Tomcat并配置Service启动关闭)
- 富士胶片集团将向土耳其东南部地震灾民捐赠5000万日元 | 美通社(富士胶片集团将向土耳其东南部地震灾民捐赠5000万日元)
- 二次创业 的富士胶片,在进博会上首次展示完成转型后的全线医疗产品(二次创业的富士胶片)
- 富士胶片 中国 我们对上海的信心没有任何改变(富士胶片中国)
- 赢麻了 富士公布2021年度财报 营利同比增长240(富士公布2021年度财报)
- 医事文化谈屑 | 古人的名 字 号(医事文化谈屑古人的名)
- ()
热门推荐
- mysql哪个版本可以下载msi(新手必备之MySQL msi版本下载安装图文详细教程)
- try中finally与return
- mysql拆分成多行(mysql单字段多值分割和合并的处理方法)
- dedecms文章顺序(dedecms 分页标题提取方法)
- docker 查看目录映射(docker 文件存放路径, 修改端口映射操作方式)
- sql语句中leftjoin的作用(sql中的left join及on、where条件关键字的区别详解)
- sql server查看之前的代码(SQL Server简单实现数据的日报和月报功能)
- linuxsamba怎么连接(Linux Samba服务器超详细安装配置附问题解决)
- sqlserver数据库同步复制(SqlServer将数据库中的表复制到另一个数据库)
- dedecms系统怎么查看(DedeCMS V5.3/V5.5/V5.7 安全设置指南 图文推荐)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9