ThreadPoolExecutor简介

ThreadPoolExecutor是线程池类。对于线程池，可以通俗的将它理解为"存放一定数量线程的一个线程集合。线程池允许若个线程同时允许，允许同时运行的线程数量就是线程池的容量；当添加的到线程池中的线程超过它的容量时，会有一部分线程阻塞等待。线程池会通过相应的调度策略和拒绝策略，对添加到线程池中的线程进行管理。" 

ThreadPoolExecutor数据结构

ThreadPoolExecutor的数据结构如下图所示：

各个数据在ThreadPoolExecutor.java中的定义如下：

// 阻塞队列。
private final BlockingQueue<Runnable> workQueue;
// 互斥锁
private final ReentrantLock mainLock = new ReentrantLock();
// 线程集合。一个Worker对应一个线程。
private final HashSet<Worker> workers = new HashSet<Worker>();
// “终止条件”，与“mainLock”绑定。
private final Condition termination = mainLock.newCondition();
// 线程池中线程数量曾经达到过的最大值。
private int largestPoolSize;
// 已完成任务数量
private long completedTaskCount;
// ThreadFactory对象，用于创建线程。
private volatile ThreadFactory threadFactory;
// 拒绝策略的处理句柄。
private volatile RejectedExecutionHandler handler;
// 保持线程存活时间。
private volatile long keepAliveTime;

private volatile boolean allowCoreThreadTimeOut;
// 核心池大小
private volatile int corePoolSize;
// 最大池大小
private volatile int maximumPoolSize;

1. workers

    workers是HashSet<Work>类型，即它是一个Worker集合。而一个Worker对应一个线程，也就是说线程池通过workers包含了"一个线程集合"。当Worker对应的线程池启动时，它会执行线程池中的任务；当执行完一个任务后，它会从线程池的阻塞队列中取出一个阻塞的任务来继续运行。
    wokers的作用是，线程池通过它实现了"允许多个线程同时运行"。

2. workQueue

    workQueue是BlockingQueue类型，即它是一个阻塞队列。当线程池中的线程数超过它的容量的时候，线程会进入阻塞队列进行阻塞等待。
    通过workQueue，线程池实现了阻塞功能。

3. mainLock

    mainLock是互斥锁，通过mainLock实现了对线程池的互斥访问。

4. corePoolSize和maximumPoolSize

    corePoolSize是"核心池大小"，maximumPoolSize是"最大池大小"。它们的作用是调整"线程池中实际运行的线程的数量"。
    例如，当新任务提交给线程池时(通过execute方法)。
          -- 如果此时，线程池中运行的线程数量< corePoolSize，则创建新线程来处理请求。
          -- 如果此时，线程池中运行的线程数量> corePoolSize，但是却< maximumPoolSize；则仅当阻塞队列满时才创建新线程。
          如果设置的 corePoolSize 和 maximumPoolSize 相同，则创建了固定大小的线程池。如果将 maximumPoolSize 设置为基本的无界值（如 Integer.MAX_VALUE），则允许池适应任意数量的并发任务。在大多数情况下，核心池大小和最大池大小的值是在创建线程池设置的；但是，也可以使用 setCorePoolSize(int) 和 setMaximumPoolSize(int) 进行动态更改。

5. poolSize

    poolSize是当前线程池的实际大小，即线程池中任务的数量。

6. allowCoreThreadTimeOut和keepAliveTime

    allowCoreThreadTimeOut表示是否允许"线程在空闲状态时，仍然能够存活"；而keepAliveTime是当线程池处于空闲状态的时候，超过keepAliveTime时间之后，空闲的线程会被终止。

7. threadFactory

    threadFactory是ThreadFactory对象。它是一个线程工厂类，"线程池通过ThreadFactory创建线程"。

8. handler

    handler是RejectedExecutionHandler类型。它是"线程池拒绝策略"的句柄，也就是说"当某任务添加到线程池中，而线程池拒绝该任务时，线程池会通过handler进行相应的处理"。

综上所说，线程池通过workers来管理"线程集合"，每个线程在启动后，会执行线程池中的任务；当一个任务执行完后，它会从线程池的阻塞队列中取出任务来继续运行。阻塞队列是管理线程池任务的队列，当添加到线程池中的任务超过线程池的容量时，该任务就会进入阻塞队列进行等待。 

线程池调度

我们通过下面的图看看下面线程池中任务的调度策略，加深对线程池的理解。

图-01:

图-02:

说明：

    在"图-01"中，线程池中有N个任务。"任务1", "任务2", "任务3"这3个任务在执行，而"任务3"到"任务N"在阻塞队列中等待。正在执行的任务，在workers集合中，workers集合包含3个Worker，每一个Worker对应一个Thread线程，Thread线程每次处理一个任务。
    当workers集合中处理完某一个任务之后，会从阻塞队列中取出一个任务来继续执行，如图-02所示。图-02表示"任务1"处理完毕之后，线程池将"任务4"从阻塞队列中取出，放到workers中进行处理。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# Java  # concurrency  # 线程池  # Java concurrency线程池之线程池原理(三)_动力节点Java学院整理  # Java concurrency线程池之线程池原理(二)_动力节点Java学院整理  # Java concurrency线程池之线程池原理(四)_动力节点Java学院整理  # 池中  # 它是  # 它会  # 句柄  # 数据结构  # 实现了  # 所示  # 互斥  # 也就是说  # 就会  # 是在  # 会有  # 多个  # 可以使用  # 如图  # 将它  # 设置为  # 时才  # 完成任务  # 完后 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： google浏览器怎么清理缓存_谷歌浏览器清除缓存加速详细步骤  如何选择PHP开源工具快速搭建网站？  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱？  Java垃圾回收器的方法和原理总结  微信小程序 配置文件详细介绍  Laravel如何安装Breeze扩展包_Laravel用户注册登录功能快速实现【流程】  iOS验证手机号的正则表达式  如何快速搭建高效服务器建站系统？  如何制作新型网站程序文件,新型止水鱼鳞网要拆除吗？  Python3.6正式版新特性预览  MySQL查询结果复制到新表的方法(更新、插入)  如何用VPS主机快速搭建个人网站？  Laravel如何集成Inertia.js与Vue/React？（安装配置）  Laravel怎么实现API接口鉴权_Laravel Sanctum令牌生成与请求验证【教程】  Laravel storage目录权限问题_Laravel文件写入权限设置  学生网站制作软件,一个12岁的学生写小说，应该去什么样的网站？  linux top下的 minerd 木马清除方法  HTML透明颜色代码怎么让下拉菜单透明_下拉菜单透明背景指南【技巧】  在线制作视频网站免费,都有哪些好的动漫网站？  教你用AI润色文章，让你的文字表达更专业  Laravel怎么判断请求类型_Laravel Request isMethod用法  敲碗10年！Mac系列传将迎来「触控与联网」双革新  Laravel如何创建自定义Facades？（详细步骤）  DeepSeek是免费使用的吗 DeepSeek收费模式与Pro版本功能详解  高性能网站服务器部署指南：稳定运行与安全配置优化方案  jQuery中的100个技巧汇总  Java遍历集合的三种方式  java获取注册ip实例  Laravel如何从数据库删除数据_Laravel destroy和delete方法区别  JS经典正则表达式笔试题汇总  Laravel Debugbar怎么安装_Laravel调试工具栏配置指南  javascript中数组（Array)对象和字符串（String)对象的常用方法总结  Python企业级消息系统教程_KafkaRabbitMQ高并发应用  三星、SK海力士获美批准：可向中国出口芯片制造设备  如何快速搭建安全的FTP站点？  Laravel辅助函数有哪些_Laravel Helpers常用助手函数大全  如何快速搭建高效香港服务器网站？  原生JS获取元素集合的子元素宽度实例  详解免费开源的DotNet二维码操作组件ThoughtWorks.QRCode（.NET组件介绍之四）  html5怎么画眼睛_HT5用Canvas或SVG画眼球瞳孔加JS控制动态【绘制】  今日头条AI怎样推荐抢票工具_今日头条AI抢票工具推荐算法与筛选【技巧】  Laravel怎么定时执行任务_Laravel任务调度器Schedule配置与Cron设置【教程】  Chrome浏览器标签页分组怎么用_谷歌浏览器整理标签页技巧【效率】  怎样使用JSON进行数据交换_它有什么限制  python中快速进行多个字符替换的方法小结  如何基于云服务器快速搭建个人网站？  如何在万网ECS上快速搭建专属网站？  使用spring连接及操作mongodb3.0实例  5种Android数据存储方式汇总  香港服务器如何优化才能显著提升网站加载速度？