java定时线程池_java 定时器线程池(ScheduledThreadPoolExecutor)的实现
前言
定时器线程池提供了定时执行任务的能力,即可以延迟执行,可以周期性执行。但定时器线程池也还是线程池,最底层实现还是ThreadPoolExecutor,可以参考我的另外一篇文章多线程–精通ThreadPoolExecutor。
特点说明
1.构造函数
public ScheduledThreadPoolExecutor(int corePoolSize) {
// 对于其他几个参数在ThreadPoolExecutor中都已经详细分析过了,所以这里,将不再展开
// 这里我们可以看到调用基类中的方法时有个特殊的入参DelayedWorkQueue。
// 同时我们也可以发现这里并没有设置延迟时间、周期等参数入口。
// 所以定时执行的实现必然在DelayedWorkQueue这个对象中了。
super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
new DelayedWorkQueue());
}
2.DelayedWorkQueue
DelayedWorkQueue是在ScheduledThreadPoolExecutor的一个内部类,实现了BlockingQueue接口
里面存放任务队列的数组如下:
private RunnableScheduledFuture>[] queue =
new RunnableScheduledFuture>[INITIAL_CAPACITY];
我们分析过ThreadPoolExecutor,它从任务队列中获取任务的方式为poll和take两种,所以看一下poll和take两个方法的源码,回顾一下,ThreadPoolExecutor它会调用poll或take方法,先poll,再take,只要其中一个接口有返回就行
public RunnableScheduledFuture> poll() {
final ReentrantLock lock = this.lock;
lock.lock();
try {
RunnableScheduledFuture> first = queue[0];
// 这里有个getDelay,这是关键点,获取执行延时时间
// 但是如果我们有延时设置的话,这就返回空了,然后就会调用take方法
if (first == null || first.getDelay(NANOSECONDS) > 0)
return null;
else
return finishPoll(first);
} finally {
lock.unlock();
}
}
public RunnableScheduledFuture> take() throws InterruptedException {
final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
try {
for (;;) {
RunnableScheduledFuture> first = queue[0];
if (first == null)
available.await();
else {
// 获取延时时间
long delay = first.getDelay(NANOSECONDS);
if (delay <= 0)
return finishPoll(first);
first = null; // don't retain ref while waiting
if (leader != null)
available.await();
else {
Thread thisThread = Thread.currentThread();
leader = thisThread;
try {
// 使用锁,执行延时等待。
// 使用锁,执行延时等待。
// 使用锁,执行延时等待。
available.awaitNanos(delay);
} finally {
if (leader == thisThread)
leader = null;
}
}
}
}
} finally {
if (leader == null && queue[0] != null)
available.signal();
lock.unlock();
}
}
3.RunnableScheduledFuture
在ScheduledThreadPoolExecutor内部有一个ScheduledFutureTask类实现了RunnableScheduledFuture,ScheduledFutureTask这个类采用了装饰者设计模式,在执行Runnable的方法基础上还执行了一些额外的功能。
我们需要特别注意几个参数period、time。
(1)time
首先看一下time的作用,可以发现time是用于获取执行延时时间的,也就是delay是根据time生成的
public long getDelay(TimeUnit unit) {
return unit.convert(time - now(), NANOSECONDS);
}
(2)period
这个参数不是说设置执行几个周期,而是用于判断是否需要按周期执行,以及执行周期,也就是本次执行与下次执行间隔的时间
// 判断是否需要按周期执行,如果周期设置成0,不是无间隔执行,而是只执行一次,这个需要特别注意
public boolean isPeriodic() {
return period != 0;
}
private void setNextRunTime() {
long p = period;
if (p > 0)
// 这里将周期加给time,这样获取的延迟时间就是周期时间了。
time += p;
else
time = triggerTime(-p);
}
(3)执行
public void run() {
// 先判断是否为周期性的任务
boolean periodic = isPeriodic();
if (!canRunInCurrentRunState(periodic))
cancel(false);
else if (!periodic)
// 如果不是周期性的,就执行调用父类的run方法,也就是构造函数中传入的Runnable对象的run方法。
ScheduledFutureTask.super.run();
// 在if的括号中先执行了任务
else if (ScheduledFutureTask.super.runAndReset()) {
// 如果是周期性的,就需要设置下次执行的时间,然后利用reExecutePeriodic方法,将任务再次丢入任务队列中。
// 这里尤其需要注意的是if中的逻辑执行失败,如果没有捕捉异常,那么后面的逻辑就不会再执行了,也就是说中间有一次执行失败,后面这个周期性的任务就失效了。
setNextRunTime();
reExecutePeriodic(outerTask);
}
}
总结
ScheduledThreadPoolExecutor通过time参数,设置当前任务执行的等待时间,再通过period设置任务下次执行需要等待的时间。这两个参数都不是设置在线程池中的,而是携带在任务中的,这就可以把线程池和任务进行完全解耦。
注意点:
(1)任务的执行等待时间是在队列的take方法中的。
(2)period参数设置成0,任务将只会执行一次,而不会执行多次
(3)如果要自己实现周期性Task,周期性任务在执行过程中,一定要注意捕捉异常,否则某一次执行失败,将导致后续的任务周期失效,任务将不再继续执行。
到此这篇关于java 定时器线程池(ScheduledThreadPoolExecutor)的实现的文章就介绍到这了,更多相关java 定时器线程池内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
java定时线程池_java 定时器线程池(ScheduledThreadPoolExecutor)的实现相关推荐
- java 异步线程池_Java - 异步线程池
一.异步线程启动: new Thread newThread(newRunnable() { @Overridepublic voidrun() {//-- 这里是异步线程内的逻辑 } } ).sta ...
- java 多线程池_Java ThreadPoolExecutor线程池 同时执行50个线程
最近项目上有个需求,需要从FTP服务器中下载大批量的数据文件,然后解析该数据文件进行入库,数据库为oracle,最后在通过web工程,以报表和图表的形式进行展现. 这些批量的数据文件为纯文本文件,每天 ...
- java多线程线程池_Java多线程——线程池(ThreadPool)
我们使用线程的时候就去创建一个线程,这样实现起来非常简便,但是就会有一个问题: 如果并发的线程数量很多,并且每个线程都是执行一个时间很短的任务就结束了,这样频繁创建线程就会大大降低系统的效率,因为频繁 ...
- java同步与死锁_Java多线程 - 线程同步与死锁
一.线程同步 1)模拟多个用户同时从银行账户里面取钱 ● Account 类:银行账户类,里面有一些账户的基本信息,以及操作账户信息的方法 //模拟银行账户 classAccount {private ...
- java线程安全性_Java并发-线程安全性
1.什么是线程安全性? 在线程安全性的定义中,最核心的就是正确性.当多线程访问调用某个类时,线程之间不会出现错误的交互,不管运行时线程如何交替执行,并且在主调代码不需要任何同步或协同,这个类都能表现出 ...
- java 线程管理_Java平台线程管理
简介 在计算机领域中,我们说的并发(concurrency)是指一些列任务的同时运行.如果一台电脑有多个处理器或者有一个多核处理器,这个同时性是真正意义上的并发:但是一台电脑只有一个单核处理器,这个同 ...
- java 线程百科_Java并发——线程介绍
前言: 互联网时代已经发展到了现在.从以前只考虑小流量到现在不得不去考虑高并发的问题.扯到了高并发的问题就要扯到线程的问题.你是否问过自己,你真正了解线程吗?还是你只知道一些其他博客里写的使用方法.下 ...
- java 后台线程作用_Java 后台线程介绍
packagecom.aaa.threaddemo;/** 一 Java后台线程? * 守护线程--也称"服务线程",他是后台线程, * 它有一个特性,即为用户线程 提供 公共服务 ...
- java线程属性_Java 并发 线程属性
Java 并发 线程属性 @author ixenos 线程优先级 1.每当线程调度器有机会选择新线程时,首先选择具有较高优先级的线程 2.默认情况下,一个线程继承它的父线程的优先级 当在一个运行的线 ...
最新文章
- 如何结合因果与强化学习?看最新《因果强化学习:动机,概念,挑战与应用》报告,85页ppt...
- HBase scan 时 异常 ScannerTimeoutException 解决
- NR 5G L1物理层
- CSS3 2D Transform
- dot2谜团png_一个类加载的谜团解决了
- 测试用例 集成测试增删改查_springBoot集成mongoDb并增删改查
- 利用过滤器(Filter)统一处理请与响应乱码
- 人工智能降噪插件Topaz DeNoise AI
- 如何查看自己电脑使用第几代内存条?
- 巴特勒船长-百年一遇的男人
- 考计算机854的学校,2020年哈尔滨工业大学854计算机基础硕士研究生入学考试科目大纲...
- 2022危险化学品经营单位安全管理人员特种作业证考试题库模拟考试平台操作
- NPP++去除文本中的重复行
- 没有人能比快递员更懂通信协议(sig mesh协议栈之网络架构)
- 【肥朝】从JDK中,我们能学到哪些设计模式?
- 学习理论_斯坦福CS229_学习笔记
- C++求数组中和为定值的组合
- 音量增强器和均衡器Boom 3D mac中文版
- 联想笔记本无法下载 Lenovo Vantage
- 铠装跳线与普通光纤跳线的区别
热门文章
- 学习笔记(31):Python网络编程并发编程-定时器
- 计算机网络犯罪和一般犯罪的不同,论计算机网络犯罪题稿.doc
- hao123电脑版主页_hao123浏览器 原生网民的记忆 一代站长的传奇
- MNIST 手写数字识别,我是如何做到886个可训练参数,识别率达到98.2%? (参数、模型压缩), Keras实现,模型优化
- asynchttpclient 超时_DNF:95更新前还能免费获得一件超时空装备?但这个任务一定完成...
- oracle 导入excel时间格式,将.xls或者.excel格式的数据导入到Oracle中
- MySQL源码包编译安装
- 10.27 noip模拟试题
- 第四十五篇、UITableViewCell高度计算
- ubuntu14.04 python2.7 安装配置OpenCV3.0