ThreadPoolExecutor部分方法解读

2024-06-06 05:18
文章标签 方法 解读 部分 threadpoolexecutor

本文主要是介绍ThreadPoolExecutor部分方法解读，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

文章目录

  • 状态与位移运算、或与非
    • field分析:
    • 方法分析:
  • execute(Runnable command)分析
  • addWorker(Runnable firstTask, boolean core)
  • 使用技巧
  • 代码疑问

状态与位移运算、或与非

    private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));private static final int COUNT_BITS = Integer.SIZE - 3;private static final int CAPACITY   = (1 << COUNT_BITS) - 1;// runState is stored in the high-order bitsprivate static final int RUNNING    = -1 << COUNT_BITS;private static final int SHUTDOWN   =  0 << COUNT_BITS;private static final int STOP       =  1 << COUNT_BITS;private static final int TIDYING    =  2 << COUNT_BITS;private static final int TERMINATED =  3 << COUNT_BITS;// Packing and unpacking ctlprivate static int runStateOf(int c)     { return c & ~CAPACITY; }private static int workerCountOf(int c)  { return c & CAPACITY; }private static int ctlOf(int rs, int wc) { return rs | wc; }

ctl:
使用AtomicInteger,目前够用,如果未来会有问题,可以改成AtomicLong,现在来说执行效率更高.
c = ctl.get() < SHUTDOWN 表示在运行中的状态

field分析:

COUNT_BITS是29， 各常量的二进制字节码如下：
CAPACITY: 00011111111111111111111111111111（前3位是0，后29位是1，共32位,约5亿）
RUNNING: 11100000000000000000000000000000（负数，前3位是1，后29位是0，共32位）
SHUTDOWN: 00000000000000000000000000000000（正数）
STOP: 00100000000000000000000000000000（正数）
TIDYING: 01000000000000000000000000000000（正数）
TERMINATED: 01100000000000000000000000000000（正数）
以上可知:

  • 1.CAPACITY和RUNNING是相互取反的关系
  • 2.ctl：是runState和workerCounter的结合体,初始值等于RUNNING和0的或运算的拼接结果
    ctlOf(RUNNING, 0)
  • 3.ctl#get的值,调用workerCountOf方法获取线程数,调用runStateOf方法得到线程池状态.

方法分析:

// 与运算后只有c的后29位有效
private static int workerCountOf(int c)  { return c & CAPACITY; }

中的入参c,即为ctl的值.该方法含义是：获取工作线程数(取后29位),初始值是0

// 取前三位,~表示非运算
private static int runStateOf(int c)     { return c & ~CAPACITY; }

先对CAPACITY进行非运算,变为11100000000000000000000000000000,再进行与运算,取前三位,表示线程的状态

private static int ctlOf(int rs, int wc) { return rs | wc; }

运行状态runState和工作线程数workerCount取或,即二者拼接起来.

execute(Runnable command)分析

  • 1.比较工作线程数与核心线程数corePoolSize,如果小于,则创建线程 并执行任务
        if (workerCountOf(c) < corePoolSize) {if (addWorker(command, true))return;c = ctl.get();}
  • 2.当核心线程都已经创建完成,仍然有任务加入,就丢到队列里面
        if (isRunning(c) && workQueue.offer(command)) {int recheck = ctl.get();if (! isRunning(recheck) && remove(command))reject(command);else if (workerCountOf(recheck) == 0)addWorker(null, false);}

这一步的前提是: 线程池在运行中,队列未满.
如果线程池已经关闭,要移除任务,执行拒绝策略.
如果工作线程已经死了(workerCountOf(recheck) == 0),需要重新创建线程.(这里要怎么理解呢?不是已经创建了核心线程吗,怎么会有工作线程为0的情况?)

addWorker(null, false)这里false表示是非核心线程,加的任务是null,是因为任务在前面已经放到队列里面了:workQueue.offer(command)

addWorker(Runnable firstTask, boolean core)

            if (rs >= SHUTDOWN &&! (rs == SHUTDOWN &&firstTask == null &&! workQueue.isEmpty()))return false;

addWorker前先做判断:
如果线程池为RUNNING状态或者为SHUTDOWN状态且此时任务队列仍有任务未执行完时，可以继续调用addWorker添加工作线程，但不能新建任务，即firstTask参数必须为null.否则这里将返回false,即新建工作线程失败。
简单地说,就是如果是shutdown状态,就不能再往队列里面加任务了.但是如果shutdown状态下任务队列还有任务,就还可以创建线程去执行任务.

            for (;;) {int wc = workerCountOf(c);if (wc >= CAPACITY ||wc >= (core ? corePoolSize : maximumPoolSize))return false;if (compareAndIncrementWorkerCount(c))break retry;c = ctl.get();  // Re-read ctlif (runStateOf(c) != rs)continue retry;// else CAS failed due to workerCount change; retry inner loop}

如果 工作线程数大于CAPACITY 或者大于corePoolSize或maximumPoolSize(视入参core而定),则返回false.

compareAndIncrementWorkerCount将ctl的值+1, 成功就跳出循环往下执行.否则就重新获取ctl的值,判断是否已经更新,以确定继续进行内部循环(未更新)或者外部循环(已更新)
随后使用可重入锁同步创建worker对象,并启动线程.

如果addWorker返回成功，那么这时候线程已经开始执行相应的任务了；

使用技巧

性质不同的任务可以用不同规模的线程池分开处理。CPU密集型任务配置尽可能少的线程数量，如配置Ncpu+1个线程的线程池，以减少线程切换带来的性能开销。IO密集型任务则由于需要等待IO操作，线程并不是一直在执行任务，则配置尽可能多的线程，如2*Ncpu。混合型的任务，如果可以拆分，则将其拆分成一个CPU密集型任务和一个IO密集型任务，只要这两个任务执行的时间相差不是太大，那么分解后执行的吞吐率要高于串行执行的吞吐率，如果这两个任务执行时间相差太大，则没必要进行分解。我们可以通过Runtime.getRuntime().availableProcessors()方法获得当前设备的CPU个数。
优先级不同的任务可以使用优先级队列PriorityBlockingQueue来处理。它可以让优先级高的任务先得到执行，需要注意的是如果一直有优先级高的任务提交到队列里，那么优先级低的任务可能永远不能执行。

代码疑问

对于runWorker方法,一开始对代码

        try {while (task != null || (task = getTask()) != null) {w.lock();// If pool is stopping, ensure thread is interrupted;// if not, ensure thread is not interrupted.  This// requires a recheck in second case to deal with// shutdownNow race while clearing interruptif ((runStateAtLeast(ctl.get(), STOP) ||(Thread.interrupted() &&runStateAtLeast(ctl.get(), STOP))) &&!wt.isInterrupted())wt.interrupt();// 此处省略部分代码...}completedAbruptly = false;} finally {processWorkerExit(w, completedAbruptly);}

中的processWorkerExit部分不解,以为走到这里不就是销毁worker对象了吗?那么岂不是每个任务都要创建worker对象,即创建新线程?
其实不是这样的.里面的while (task != null || (task = getTask()) != null)部分会一直执行下去,如果没有task,代码会阻塞在这里,直到从队列里面获取到task为止.

        try {while (count == 0)notEmpty.await();return dequeue();} finally {lock.unlock();}

而processWorkerExit方法的执行的条件是上面的while循环结束了.while循环结束的原因是:
线程池SHUTDOWN,或者工作线程数 > corePoolSize,且队列为空,没有task.
这就好理解了:
线程池关闭 --> 销毁全部worker对象,
线程数 > corePoolSize,且队列为空 --> 销毁大于核心线程数的worker对象!



细节代码区分:

在这里插入图片描述
runWorker方法
这2处需要区分一下.
t.start()的t是worker里面的Thread对象,该对象封装的Runnable对象正是worker.所以start方法启动线程后就是执行worker#run方法,即worker#runWorker方法.
task.run()的task就是传入的用户写的任务.

这篇关于ThreadPoolExecutor部分方法解读的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1035187。

相关文章

Nginx安全防护的多种方法

Nginx安全防护的多种方法

《Nginx安全防护的多种方法》在生产环境中,需要隐藏Nginx的版本号,以避免泄漏Nginx的版本,使攻击者不能针对特定版本进行攻击,下面就来介绍一下Nginx安全防护的方法,感兴趣的可以了解一下... 目录核心安全配置1.编译安装 Nginx2.隐藏版本号3.限制危险请求方法4.请求限制（CC攻击防御）
阅读更多...
python生成随机唯一id的几种实现方法

python生成随机唯一id的几种实现方法

《python生成随机唯一id的几种实现方法》在Python中生成随机唯一ID有多种方法,根据不同的需求场景可以选择最适合的方案,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习... 目录方法 1：使用 UUID 模块（推荐）方法 2：使用 Secrets 模块（安全敏感场景）方法
阅读更多...
MyBatis-Plus通用中等、大量数据分批查询和处理方法

MyBatis-Plus通用中等、大量数据分批查询和处理方法

《MyBatis-Plus通用中等、大量数据分批查询和处理方法》文章介绍MyBatis-Plus分页查询处理,通过函数式接口与Lambda表达式实现通用逻辑,方法抽象但功能强大,建议扩展分批处理及流式... 目录函数式接口获取分页数据接口数据处理接口通用逻辑工具类使用方法简单查询自定义查询方法总结函数式接口
阅读更多...
MySQL深分页进行性能优化的常见方法

MySQL深分页进行性能优化的常见方法

《MySQL深分页进行性能优化的常见方法》在Web应用中,分页查询是数据库操作中的常见需求,然而,在面对大型数据集时,深分页（deeppagination）却成为了性能优化的一个挑战,在本文中,我们将... 目录引言：深分页，真的只是“翻页慢”那么简单吗？一、背景介绍二、深分页的性能问题三、业务场景分析四、
阅读更多...
JAVA中安装多个JDK的方法

JAVA中安装多个JDK的方法

《JAVA中安装多个JDK的方法》文章介绍了在Windows系统上安装多个JDK版本的方法,包括下载、安装路径修改、环境变量配置（JAVA_HOME和Path）,并说明如何通过调整JAVA_HOME在... 首先去oracle官网下载好两个版本不同的jdk（需要登录Oracle账号，没有可以免费注册）下载完
阅读更多...
Java中读取YAML文件配置信息常见问题及解决方法

Java中读取YAML文件配置信息常见问题及解决方法

《Java中读取YAML文件配置信息常见问题及解决方法》：本文主要介绍Java中读取YAML文件配置信息常见问题及解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录1 使用Spring Boot的@ConfigurationProperties2. 使用@Valu
阅读更多...
Java 方法重载Overload常见误区及注意事项

Java 方法重载Overload常见误区及注意事项

《Java方法重载Overload常见误区及注意事项》Java方法重载允许同一类中同名方法通过参数类型、数量、顺序差异实现功能扩展,提升代码灵活性,核心条件为参数列表不同,不涉及返回类型、访问修饰符... 目录Java 方法重载（Overload）详解一、方法重载的核心条件二、构成方法重载的具体情况三、不构
阅读更多...
SQL中如何添加数据(常见方法及示例)

SQL中如何添加数据(常见方法及示例)

《SQL中如何添加数据(常见方法及示例)》SQL全称为StructuredQueryLanguage,是一种用于管理关系数据库的标准编程语言,下面给大家介绍SQL中如何添加数据,感兴趣的朋友一起看看吧... 目录在mysql中，有多种方法可以添加数据。以下是一些常见的方法及其示例。1. 使用INSERT I
阅读更多...
Python中反转字符串的常见方法小结

Python中反转字符串的常见方法小结

《Python中反转字符串的常见方法小结》在Python中,字符串对象没有内置的反转方法,然而,在实际开发中,我们经常会遇到需要反转字符串的场景,比如处理回文字符串、文本加密等,因此,掌握如何在Pyt... 目录python中反转字符串的方法技术背景实现步骤1. 使用切片2. 使用 reversed() 函
阅读更多...
Python中将嵌套列表扁平化的多种实现方法

Python中将嵌套列表扁平化的多种实现方法

《Python中将嵌套列表扁平化的多种实现方法》在Python编程中,我们常常会遇到需要将嵌套列表（即列表中包含列表）转换为一个一维的扁平列表的需求,本文将给大家介绍了多种实现这一目标的方法,需要的朋... 目录python中将嵌套列表扁平化的方法技术背景实现步骤1. 使用嵌套列表推导式2. 使用itert
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2