17站长网 › 首页 ›网站› 服务器 › 查看内容

Tomcat修正JDK原生线程池bug的实现原理

2022-12-4 12:21| 查看: 1836 |来源: 互联网

大家好，现在小编来为大家解答以上问题。Tomcat修正JDK原生线程池bug的实现原理相信很多人还不知道，现在让我们一起来看看吧！为提高处理能力和并发度，Web容器一般会把处理请求的任务放到线程池，而JDK的原生线程池

大家好，现在小编来为大家解答以上问题。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 {

  public TaskQueue(int capacity) {
      super(capacity);
  }
  ...
}

capacity参数通过Tomcat的maxQueueSize参数设置，但maxQueueSize默认值Integer.MAX_VALUE：当前线程数达到核心线程数后，再来任务的话线程池会把任务添加到任务队列，并且总会成功，就永远无机会创建新线程了。

为解决该问题，TaskQueue重写了LinkedBlockingQueue#offer，在合适时机返回false，表示任务添加失败，这时线程池就会创建新线程。

什么叫合适时机？


public class TaskQueue extends LinkedBlockingQueue {

  ...
   @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()

所以Tomcat维护 已提交任务数 是为了在任务队列长度无限时，让线程池还能有机会创建新线程。
以上Tomcat修正JDK原生线程池bug的实现原理就是小编为大家收集整理的全部内容了，希望对大家有所帮助。如果您喜欢这篇文章，可以收藏或分享给您的小伙伴们吧！欢迎持续关注我们的后续更新。

本文最后更新于 2022-12-4 12:21，某些文章具有时效性，若有错误或已失效，请在网站留言或联系站长：17tui@17tui.com

·END·

站长网微信号：w17tui，关注站长、创业、关注互联网人 - 互联网创业者营销服务中心

免责声明：本站部分文章和图片均来自用户投稿和网络收集，旨在传播知识，文章和图片版权归原作者及原出处所有，仅供学习与参考，请勿用于商业用途，如果损害了您的权利，请联系我们及时修正或删除。谢谢！

下一篇：浅谈Tomcat多层容器的设计上一篇：Tomcat中catalina.bat设置为UTF-8控制台出现乱码

17站长网微信二维码

始终以前瞻性的眼光聚焦站长、创业、互联网等领域，为您提供最新最全的互联网资讯，帮助站长转型升级，为互联网创业者提供更加优质的创业信息和品牌营销服务，与站长一起进步！让互联网创业者不再孤独！

扫一扫，关注站长网微信

Tomcat修正JDK原生线程池bug的实现原理

Tomcat 线程池原理

定制任务队列

大家都在看

相关分类

热门排行

最近更新