当前位置： 首页 > news >正文

【Tomcat与网络6】 Tomcat是如何扩展Java线程池的？

news 来源：原创 2024/5/10 17:39:51

目录

1.Java 的线程池

2.Tomcat 的线程池

学习Tomcat的时候，有很多绚丽的技术值得我们学习，但是个人认为Tomcat的线程池扩展是最值得研究的一个部分，线程池的应用太广了，也重要了，Java原生线程池的特征我相信很多人都背过，那Tomcat为什么要扩展以及如何拓展的呢？这个问题理解了面试的时候就可以提升一下逼格。

在开发中我们经常会碰到“池”的概念，比如数据库连接池、内存池、线程池、常量池等。为什么需要“池”呢？程序运行的本质，就是通过使用系统资源（CPU、内存、网络、磁盘等）来完成信息的处理，比如在 JVM 中创建一个对象实例需要消耗 CPU 和内存资源，如果你的程序需要频繁创建大量的对象，并且这些对象的存活时间短，就意味着需要进行频繁销毁，那么很有可能这部分代码会成为性能的瓶颈。

而“池”就是用来解决这个问题的，简单来说，对象池就是把用过的对象保存起来，等下一次需要这种对象的时候，直接从对象池中拿出来重复使用，避免频繁地创建和销毁。在 Java 中万物皆对象，线程也是一个对象，Java 线程是对操作系统线程的封装，创建 Java 线程也需要消耗系统资源，因此就有了线程池。JDK 中提供了线程池的默认实现，我们也可以通过扩展 Java 原生线程池来实现自己的线程池。

同样，为了提高处理能力和并发度，Web 容器一般会把处理请求的工作放到线程池里来执行，Tomcat 扩展了原生的 Java 线程池，来满足 Web 容器高并发的需求，下面我们就来学习一下 Java 线程池的原理，以及 Tomcat 是如何扩展 Java 线程池的。

1.Java 的线程池

简单的说，Java 线程池里内部维护一个线程数组和一个任务队列，当任务处理不过来的时，就把任务放到队列里慢慢处理。

ThreadPoolExecutor

我们先来看看 Java 线程池核心类 ThreadPoolExecutor 的构造函数，你需要知道 ThreadPoolExecutor 是如何使用这些参数的，这是理解 Java 线程工作原理的关键。

public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler)

不要小看这几个参数，其完整的工作过程如下：

每次提交任务时，如果线程数还没达到核心线程数corePoolSize，线程池就创建新线程来执行。当线程数达到corePoolSize后，新增的任务就放到工作队列workQueue里，而线程池中的线程则努力地从workQueue里拉活来干，也就是调用 poll 方法来获取任务。

如果任务很多，并且workQueue是个有界队列，队列可能会满，此时线程池就会紧急创建新的临时线程来救场，如果总的线程数达到了最大线程数maximumPoolSize，则不能再创建新的临时线程了，转而执行拒绝策略handler，比如抛出异常或者由调用者线程来执行任务等。

如果高峰过去了，线程池比较闲了怎么办？临时线程使用 poll（keepAliveTime, unit）方法从工作队列中拉活干，请注意 poll 方法设置了超时时间，如果超时了仍然两手空空没拉到活，表明它太闲了，这个线程会被销毁回收。

那还有一个参数threadFactory是用来做什么的呢？通过它你可以扩展原生的线程工厂，比如给创建出来的线程取个有意义的名字。

FixedThreadPool/CachedThreadPool

Java 提供了一些默认的线程池实现，比如 FixedThreadPool 和 CachedThreadPool，它们的本质就是给 ThreadPoolExecutor 设置了不同的参数，是定制版的 ThreadPoolExecutor。

public static ExecutorService newFixedThreadPool(int nThreads) {return new ThreadPoolExecutor(nThreads, nThreads,0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>());
}public static ExecutorService newCachedThreadPool() {return new ThreadPoolExecutor(0, Integer.MAX_VALUE,60L, TimeUnit.SECONDS,new SynchronousQueue<Runnable>());
}

从上面的代码你可以看到：

  • FixedThreadPool 有固定长度（nThreads）的线程数组，忙不过来时会把任务放到无限长的队列里，这是因为LinkedBlockingQueue 默认是一个无界队列。
  • CachedThreadPool 的 maximumPoolSize 参数值是Integer.MAX_VALUE，因此它对线程个数不做限制，忙不过来时无限创建临时线程，闲下来时再回收。它的任务队列是SynchronousQueue，表明队列长度为 0。

2.Tomcat 的线程池

跟 FixedThreadPool/CachedThreadPool 一样，Tomcat 的线程池也是一个定制版的 ThreadPoolExecutor。

通过比较 FixedThreadPool 和 CachedThreadPool，我们发现它们传给 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 有自己的定制版任务队列和线程工厂，并且可以限制任务队列的长度，它的最大长度是 maxQueueSize。
  • Tomcat 对线程数也有限制，设置了核心线程数（minSpareThreads）和最大线程池数（maxThreads）。

除了资源限制以外，Tomcat 线程池还定制自己的任务处理流程。我们知道 Java 原生线程池的任务处理逻辑比较简单：

  1. 前 corePoolSize 个任务时，来一个任务就创建一个新线程。
  2. 后面再来任务，就把任务添加到任务队列里让所有的线程去抢，如果队列满了就创建临时线程。
  3. 如果总线程数达到 maximumPoolSize，执行拒绝策略。

Tomcat 线程池扩展了原生的 ThreadPoolExecutor，通过重写 execute 方法实现了自己的任务处理逻辑：

  1. 前 corePoolSize 个任务时，来一个任务就创建一个新线程。
  2. 再来任务的话，就把任务添加到任务队列里让所有的线程去抢，如果队列满了就创建临时线程。
  3. 如果总线程数达到 maximumPoolSize，则继续尝试把任务添加到任务队列中去。
  4. 如果缓冲队列也满了，插入失败，执行拒绝策略。

观察 Tomcat 线程池和 Java 原生线程池的区别，其实就是在第 3 步，Tomcat 在线程总数达到最大数时，不是立即执行拒绝策略，而是再尝试向任务队列添加任务，添加失败后再执行拒绝策略。那具体如何实现呢，其实很简单，我们来看一下 Tomcat 线程池的 execute 方法的核心代码。

public class ThreadPoolExecutor extends java.util.concurrent.ThreadPoolExecutor {...public void execute(Runnable command, long timeout, TimeUnit unit) {submittedCount.incrementAndGet();try {// 调用 Java 原生线程池的 execute 去执行任务super.execute(command);} catch (RejectedExecutionException rx) {// 如果总线程数达到 maximumPoolSize，Java 原生线程池执行拒绝策略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 方法会调用 Java 原生线程池的 execute 去执行任务，如果总线程数达到 maximumPoolSize，Java 原生线程池的 execute 方法会抛出 RejectedExecutionException 异常，但是这个异常会被 Tomcat 线程池的 execute 方法捕获到，并继续尝试把这个任务放到任务队列中去；如果任务队列也满了，再执行拒绝策略。

定制版的任务队列

细心的你有没有发现，在 Tomcat 线程池的 execute 方法最开始有这么一行：

submittedCount.incrementAndGet();

这行代码的意思把 submittedCount 这个原子变量加一，并且在任务执行失败，抛出拒绝异常时，将这个原子变量减一：

submittedCount.decrementAndGet();

其实 Tomcat 线程池是用这个变量 submittedCount 来维护已经提交到了线程池，但是还没有执行完的任务个数。Tomcat 为什么要维护这个变量呢？这跟 Tomcat 的定制版的任务队列有关。Tomcat 的任务队列 TaskQueue 扩展了 Java 中的 LinkedBlockingQueue，我们知道 LinkedBlockingQueue 默认情况下长度是没有限制的，除非给它一个 capacity。因此 Tomcat 给了它一个 capacity，TaskQueue 的构造函数中有个整型的参数 capacity，TaskQueue 将 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，返回 false 表示任务添加失败，这时线程池会创建新的线程。那什么是合适的时机呢？请看下面 offer 方法的核心源码：

public class TaskQueue extends LinkedBlockingQueue<Runnable> {...@Override// 线程池调用任务队列的方法时，当前线程数肯定已经大于核心线程数了public boolean offer(Runnable o) {// 如果线程数已经到了最大值，不能创建新线程了，只能把任务添加到任务队列。if (parent.getPoolSize() == parent.getMaximumPoolSize()) return super.offer(o);// 执行到这里，表明当前线程数大于核心线程数，并且小于最大线程数。// 表明是可以创建新线程的，那到底要不要创建呢？分两种情况：//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 的任务队列是没有限制的，你可以通过设置 maxQueueSize 参数来限制任务队列的长度。

参考：

本文很多内容参考了李号双老师的相关文章

相关文章：

  • Python flask 模板详解
  • 物流平台架构设计与实践
  • Node.js的安装
  • 理解React中的setState()方法
  • R语言基础学习-02 （此语言用途小众 用于数学 生物领域 基因分析）
  • 【如何快速上手Vue.js框架——详细介绍】
  • 《Lua程序设计》-- 学习9
  • Shell脚本是一种用来自动化执行一系列命令的文本文件
  • 公共用例库计划--个人版（六）典型Bug页面设计与开发
  • cesium-水平测距
  • 基于flask的个人博客项目从0到1
  • 微信小程序实现吸顶、网格、瀑布流布局
  • Excel计算表达式的值
  • 16- OpenCV：轮廓的发现和轮廓绘制、凸包
  • 学习MySQL的CSV存储引擎
  • ----------
  • css的样式优先级
  • JavaScript 一些 DOM 的知识点
  • JDK 6和JDK 7中的substring（）方法
  • Joomla 2.x, 3.x useful code cheatsheet
  • Linux编程学习笔记 | Linux多线程学习[2] - 线程的同步
  • MQ框架的比较
  • MySQL数据库运维之数据恢复
  • Theano - 导数
  • 阿里研究院入选中国企业智库系统影响力榜
  • 从tcpdump抓包看TCP/IP协议
  • 仿天猫超市收藏抛物线动画工具库
  • 坑！为什么View.startAnimation不起作用？
  • 漫谈开发设计中的一些“原则”及“设计哲学”
  • 如何将自己的网站分享到QQ空间，微信，微博等等
  • 入口文件开始，分析Vue源码实现
  • 实现简单的正则表达式引擎
  • 世界编程语言排行榜2008年06月（ActionScript 挺进20强）
  • 协程
  • 字符串匹配基础上
  • k8s使用glusterfs实现动态持久化存储
  • ​iOS实时查看App运行日志
  • #{}和${}的区别？
  • #pragma预处理命令
  • $redis-setphp_redis Set命令，php操作Redis Set函数介绍
  • (arch)linux 转换文件编码格式
  • （C语言）逆序输出字符串
  • (js)循环条件满足时终止循环
  • （附源码）springboot车辆管理系统 毕业设计 031034
  • （南京观海微电子）——COF介绍
  • (四) 虚拟摄像头vivi体验
  • （万字长文）Spring的核心知识尽揽其中
  • .NET CF命令行调试器MDbg入门（二） 设备模拟器
  • .NET Framework 和 .NET Core 在默认情况下垃圾回收（GC）机制的不同（局部变量部分）
  • .NET 事件模型教程（二）
  • .NET 依赖注入和配置系统
  • .NET成年了，然后呢？
  • .NET开源项目介绍及资源推荐：数据持久层
  • @EventListener注解使用说明
  • [ Linux ] git工具的基本使用（仓库的构建，提交）