Java 线程池之Jetty 线程池学习总结

Java 线程池之Jetty 线程池学习总结

前提

Jetty 11.0.x

为什么是Jetty?

Java提供4中创建线程池的快捷方式

Executors.newFixedThreadPool();
Executors.newCachedThreadPool();
Executors.newSingleThreadExecutor();
Executors.newScheduledThreadPool();

但通常我们很少用这4个工厂方法去创建线程池，而是直接使用​​ThreadPoolExecutor​​类构造线程池，因为这些工厂方法最终也是调用这个类来创建线程池的。

众所周知，虽然​​ThreadPoolExecutor​​​提供了​​corePoolSize​​​和​​maximumPoolSize​​​两个参数来控制线程池的基本大小和最大大小，但是这两个参数并不是那么好用：当任务队列采用​​SynchronousQueue​​​时，通常需要无界的​​maximumPoolSize​​​；当任务队列采用无界队列时，​​maximumPoolSize​​​的值又相当于不起作用；当任务队列采用有界队列时，仅在任务队列已满，且未达到​​maximumPoolSize​​时才会扩充线程池大小。

既然如此，那有没有一种更简单的实现方案呢？使用该方案，使用者只需要简单的配置下线程池的基本大小和最大大小，程序就可以根据任务的繁忙程度自动调整当前线程数量。答案是有的：Jetty--一个基于Java的web容器，和Tomcat齐名

Jetty线程池介绍

任务处理流程

初始化线程池

程序初始化运行时，会先创建线程池，线程池大小默认为​​minThreads​​​，也就是说会预先创建​​minThreads​​个线程，线程名称格式形如“qtp1076496284-13”

创建线程池时：

• 如果未指定最大线程数(​​maxThreads​​)，则默认为 200;
• 如果未指定最小线程数(​​minThreads​​)，则默认为 8
• 如果未指定线程空闲超时时间(​​idleTimeout​​)，则默认为 60000，即60秒
• 保留线程数(​​reservedThreads​​)默认为 -1
• 如果未指定任务队列，则默认创建​​BlockingArrayQueue​​任务队列，容量大小为 8 x 1024
• 如果指定的最大线程数小于最小线程数，则抛出异常

线程池扩缩容

• 当前线程数比最小线程数小，或者没有空闲的线程，且当前线程数(​​threads​​ )小于最大线程数，则创建线程；
• ​​idleTimout​​​大于0且当前线程数大于最小线程数，且线程空闲时间超过​​idleTimeout​​，则停止线程

注意：程序判断是否存在空闲线程的逻辑是这样的：Net空闲线程数 = 空闲线程数 - 任务队列大小，如果“Net空闲线程数”为负数，则表示不存在空闲线程，即需要更多的线程来处理任务。

任务队列及线程相关定义

​​queueSize​​​ 任务队列大小，即队列中等待被线程执行的任务数。可通过​​getQueueSize()​​函数获取。

​​threads​​​ 当前线程池中的线程数，包括已租给内部组件的线程、空闲线程、保留线程，以及正在执行临时作业的线程。​​threads​​​ = ​​readyThreads​​​ + ​​leasedThreads​​​ + ​​utilizedThreads​​​。 可通过​​getThreads()​​ 函数获取。

​​readyThreads​​​ 准备执行临时任务的线程数。​​readyThreads​​​ = ​​idleThreads​​​ + ​​availableReservedThreads​​​。可通过​​getReadyThreads()​​函数获取。

​​idleThreads​​​ 未被保留的空闲线程数。​​idleThreads​​​ = ​​readyThreads​​​ - ​​availableReservedThreads​​​。可通过​​getIdleThreads()​​函数获取。

​​reservedThreads​​​ 保留的线程数，默认值为-1。可通过​​getReservedThreads()​​函数获取。

​​availableReservedThreads​​​ 可用的保留线程。可通过​​getAvailableReservedThreads()​​函数获取。

​​leasedThreads​​​ 供内部组件使用，用于执行内部任务的线程。需要线程的Jetty组件(比如网络​​acceptors​​​和​​selector​​​)可能会使用​​ThreadPoolBudget​​​从线程池中租用线程。站在线程池的角度来看，这些被租用的线程是活跃的，但是不能用于执行临时任务，比如一个HTTP请求，或者一个WebSocket帧。​​QueuedThreadPool​​​有一个​​ReservedThreadExecutor​​​，该组件会从线程池租用线程，但会让这些线程可用，就像它们是“idle”线程一样。线程池启动后，该值一般是恒定的。可通过​​getLeasedThreads()​​函数获取。

​​minThreads​​​ 线程池中的最小线程数。可通过​​getMinThreads() ​​函数获取。

​​maxThreads​​​ 线程池中的最大线程数。可通过​​getMaxThreads() ​​函数获取。

​​maxAvailableThreads​​​ 可用于执行临时任务的最大线程数。​​maxAvailableThreads​​​ = ​​maxThreads​​​ - ​​leasedThreads​​​ 可通过​​getMaxAvailableThreads()​​函数获取。

​​utilizedThreads​​​执行临时任务的线程数，可通过​​getUtilizedThreads()​​​函数获取。​​utilizedThreads​​​ = ​​threads​​​ - ​​leasedThreads​​​ - ​​readyThreads​​

​​utilizationRate​​​ = ​​utilizedThreads​​​ / ​​maxAvailableThreads​​​ 执行临时任务的线程利用率。该值为​​0.0D​​​则表示线程池未被利用，如果为​​1.0D​​​则表示线程池被充分利用于执行临时任务。可通过​​getUtilizationRate() ​​函数获取。

​​busyThreads ​​​ 正在执行内部任务和临时任务的线程数。 ​​busyThreads​​​ = ​​utilizedThreads​​​ + ​​leasedThreads​​​。可通过​​getBusyThreads()​​函数获取。

参考链接

​​https://www.eclipse.org/jetty/javadoc/jetty-11/org/eclipse/jetty/util/thread/QueuedThreadPool.html​​

​​https://gitee.com/Tedgar156/jetty.project/blob/jetty-11.0.x/jetty-util/src/main/java/org/eclipse/jetty/util/thread/QueuedThreadPool.java​​

作者：​​授客​

全国软件测试QQ交流群：​​7156436​

Git地址：​​https://gitee.com/ishouke​​

友情提示：限于时间仓促，文中可能存在错误，欢迎指正、评论！