Java中的线程池如何实现线程复用
更新时间：2024年03月27日 09:17:15 作者：IllTamer
这篇文章主要介绍了Java中的线程池如何实现线程复用问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
Java线程池实现线程复用
闲来没事突然想到这个问题，便百度了下想查看具体实现，无果。
便自己翻看了下源码
以下是分析过程
众所周知，Java内部自带了个线程池实现 ExecutorService (虽然一直被人看不起)。
随便找到其中的一个静态方法
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}可知 ExecutorService 也只是一个封装，真正的实现还得看 ThreadPoolExecutor。
根据推断我们可以首先从 `ThreadPoolExecutor#execute` 找起
public void execute(Runnable command) {
if (command == null)
throw new NullPointerException();
int c = ctl.get();
if (workerCountOf(c) < corePoolSize) {
if (addWorker(command, true))
return;
c = ctl.get();
}
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);
}
else if (!addWorker(command, false))
reject(command);
}读题解
传入的 Runnable 实例最终经过一系列安全检验被传入 addWorker 方法中
继续追踪可以看到实例(firstTask) 被传入 `ThreadPoolLocal#Worker#init` 的有参构造器中
而该 Worker 实例被添加进名为 workers 的哈希表中
终于是找到正主了！
让我们看看这个 Worker 到底是何方神圣，究竟是如何实现线程复用！
private final class Worker extends AbstractQueuedSynchronizer implements Runnable {
public void run() {
runWorker(this);
}
}好家伙，原来 Worker 也实现了 Runnable，查看 runWorker 方法可知，当当前任务执行后task置空，Worker 线程调用 getTask 方法从任务队列中获取新任务并执行。
至此便实现了一个 Worker 线程执行多个 Runnable 任务的功能。
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
在系统中经常需要在处理用户请求之前和之后执行一些行为,例如检测用户的权限,或者将请求的信息记录到日志中,即平时所说的"权限检测"及"日志记录",下面这篇文章主要给大家介绍了关于在SpringBoot项目中整合拦截器的相关资料,需要的朋友可以参考下2022-10-10
SpringSecurity是一个强大的可高度定制的认证和授权框架,对于Spring应用来说它是一套Web安全标准,下面这篇文章主要给大家介绍了关于Spring Security+JWT简述的相关资料,需要的朋友可以参考下2023-04-04
springboot 中 thymeleaf 常用的语法完整实例
在 Spring Boot 项目中,Thymeleaf 是一个常用的模板引擎,它提供了丰富的语法来动态渲染 HTML 页面,下面给大家介绍springboot 中 thymeleaf 常用的语法完整实例,感兴趣的朋友一起看看吧2024-03-03
这篇文章主要介绍了RabbitMQ进阶之消息可靠性详解,abbitmq消息的投递过程中，怎么确保消息能不丢失，这是一个很重要的问题,哪怕我们做了Rabbitmq持久化，也不能保证我们的业务消息不会被丢失,需要的朋友可以参考下2023-08-08
socket编程是在不同的进程间进行网络通讯的一种协议,下面这篇文章主要给大家介绍了关于Socket编程简单示例的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下2023-02-02
springboot使用ThreadPoolTaskExecutor多线程批量插入百万级数据的实现方法
这篇文章主要介绍了springboot利用ThreadPoolTaskExecutor多线程批量插入百万级数据,本文通过示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2023-02-02
下面小编就为大家带来一篇java发送http get请求的两种方法(总结)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-05-05
在上文中我介绍了Spring Boot使用EhCache 2.x来作为缓存的实现，本文接着介绍使用单机版的Redis作为缓存的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-08-08
这篇文章主要介绍了关于WeakhashMap与HashMap之间的区别和联系,WeakHashMap从名字可以得知主要和Map有关,不过还有一个Weak,我们就更能自然而然的想到这里面还牵扯到一种弱引用结构,因此想要彻底搞懂,我们还需要知道四种引用,需要的朋友可以参考下2023-09-09
在项目工程迁移过程中,遇到了一个批量更新接口在新工程中报错的问题,通过分析,排除了代码错误的可能,最终发现是由于数据库连接配置不当导致的,在jdbc连接字符串中加入allowMultiQueries=true参数后,问题得以解决,这个参数的作用是允许SQL批量执行2022-12-12
最新评论