当前位置: 首页 > news >正文

java timer和timertask_java定时器Timer和TimerTask详解

目录结构:

Timer和TimerTask

一个Timer调度的例子

如何终止Timer线程

关于cancle方式终止线程

反复执行一个任务

schedule VS. scheduleAtFixedRate

一些注意点

1. Timer和TimerTask

Timer是jdk中提供的一个定时器工具,使用的时候会在主线程之外起一个单独的线程执行指定的计划任务,可以指定执行一次或者反复执行多次。

TimerTask是一个实现了Runnable接口的抽象类,代表一个可以被Timer执行的任务。

2. 一个Timer调度的例子

69c5a8ac3fa60e0848d784a6dd461da6.png

1 importjava.util.Timer;2 importjava.util.TimerTask;3

4 public classTestTimer {5

6 public static voidmain(String args[]){7 System.out.println("About to schedule task.");8 new Reminder(3);9 System.out.println("Task scheduled.");10 }11

12 public static classReminder{13 Timer timer;14

15 public Reminder(intsec){16 timer = newTimer();17 timer.schedule(newTimerTask(){18 public voidrun(){19 System.out.println("Time's up!");20 timer.cancel();21 }22 }, sec*1000);23 }24 }

25 }

69c5a8ac3fa60e0848d784a6dd461da6.png

运行之后,在console会首先看到:

About to schedule task.Task scheduled.

然后3秒钟后,看到

Time's up!

从这个例子可以看出一个典型的利用timer执行计划任务的过程如下:

new一个TimerTask的子类,重写run方法来指定具体的任务,在这个例子里,我用匿名内部类的方式来实现了一个TimerTask的子类

new一个Timer类,Timer的构造函数里会起一个单独的线程来执行计划任务。jdk的实现代码如下:

69c5a8ac3fa60e0848d784a6dd461da6.png

1 publicTimer() {2 this("Timer-" +serialNumber());3 }4

5 publicTimer(String name) {6 thread.setName(name);7 thread.start();8 }

69c5a8ac3fa60e0848d784a6dd461da6.png

调用相关调度方法执行计划。这个例子调用的是schedule方法。

任务完成,结束线程。这个例子是调用cancel方法结束线程。

3. 如何终止Timer线程

默认情况下,创建的timer线程会一直执行,主要有下面四种方式来终止timer线程:

调用timer的cancle方法

把timer线程设置成daemon线程,(new Timer(true)创建daemon线程),在jvm里,如果所有用户线程结束,那么守护线程也会被终止,不过这种方法一般不用。

当所有任务执行结束后,删除对应timer对象的引用,线程也会被终止。

调用System.exit方法终止程序

4. 关于cancle方式终止线程

这种方式终止timer线程,jdk的实现比较巧妙,稍微说一下。

首先看cancle方法的源码:

69c5a8ac3fa60e0848d784a6dd461da6.png

1 public voidcancel() {2 synchronized(queue) {3 thread.newTasksMayBeScheduled = false;4 queue.clear();5 queue.notify(); //In case queue was already empty.

6 }7 }

69c5a8ac3fa60e0848d784a6dd461da6.png

没有显式的线程stop方法,而是调用了queue的clear方法和queue的notify方法,clear是个自定义方法,notify是Objec自带的方法,很明显是去唤醒wait方法的。

再看clear方法:

69c5a8ac3fa60e0848d784a6dd461da6.png

1 voidclear() {2 //Null out task references to prevent memory leak

3 for (int i=1; i<=size; i++)4 queue[i] = null;5

6 size = 0;7 }

69c5a8ac3fa60e0848d784a6dd461da6.png

clear方法很简单,就是去清空queue,queue是一个TimerTask的数组,然后把queue的size重置成0,变成empty.还是没有看到显式的停止线程方法,回到最开始new Timer的时候,看看new Timer代码:

69c5a8ac3fa60e0848d784a6dd461da6.png

1 publicTimer() {2 this("Timer-" +serialNumber());3 }4

5 publicTimer(String name) {6 thread.setName(name);7 thread.start();8 }

69c5a8ac3fa60e0848d784a6dd461da6.png

看看这个内部变量thread:

1 /**

2 * The timer thread.3 */

4 private TimerThread thread = new TimerThread(queue);

不是原生的Thread,是自定义的类TimerThread.这个类实现了Thread类,重写了run方法,如下:

69c5a8ac3fa60e0848d784a6dd461da6.png

1 public voidrun() {2 try{3 mainLoop();4 } finally{5 //Someone killed this Thread, behave as if Timer cancelled

6 synchronized(queue) {7 newTasksMayBeScheduled = false;8 queue.clear(); //Eliminate obsolete references

9 }10 }11 }

69c5a8ac3fa60e0848d784a6dd461da6.png

最后是这个mainLoop方法,这方法比较长,截取开头一段:

69c5a8ac3fa60e0848d784a6dd461da6.png

1 private voidmainLoop() {2 while (true) {3 try{4 TimerTask task;5 booleantaskFired;6 synchronized(queue) {7 //Wait for queue to become non-empty

8 while (queue.isEmpty() &&newTasksMayBeScheduled)9 queue.wait();10 if(queue.isEmpty())11 break; //Queue is empty and will forever remain; die

69c5a8ac3fa60e0848d784a6dd461da6.png

可以看到wait方法,之前的notify就是通知到这个wait,然后clear方法在notify之前做了清空数组的操作,所以会break,线程执行结束,退出。

5. 反复执行一个任务

通过调用三个参数的schedule方法实现,最后一个参数是执行间隔,单位毫秒。

6. schedule VS. scheduleAtFixedRate

这两个方法都是任务调度方法,他们之间区别是,schedule会保证任务的间隔是按照定义的period参数严格执行的,如果某一次调度时间比较长,那么后面的时间会顺延,保证调度间隔都是period,而scheduleAtFixedRate是严格按照调度时间来的,如果某次调度时间太长了,那么会通过缩短间隔的方式保证下一次调度在预定时间执行。举个栗子:你每个3秒调度一次,那么正常就是0,3,6,9s这样的时间,如果第二次调度花了2s的时间,如果是schedule,就会变成0,3+2,8,11这样的时间,保证间隔,而scheduleAtFixedRate就会变成0,3+2,6,9,压缩间隔,保证调度时间。

7. 一些注意点

每一个Timer仅对应唯一一个线程。

Timer不保证任务执行的十分精确。

Timer类的线程安全的。

相关文章:

  • java 静态类在内存中只会有一个事例吗_Java 中的设计模式:解决一个类在内存只存在一个对象。...
  • eclipse中java项目泛型报错_Java泛型Eclipse编译器错误?
  • mysql-8.0.13安装教程_win10下mysql8.0.13安装配置方法图文教程
  • java的class对象_java中Class对象详解
  • java 调用 r语言_从Java里调用R – JRI的设置方法
  • java程序解释_编写并解释第一个java程序
  • java 面板作用_Java面板基础:JPanel和JScrollpane的应用区别
  • java错误_java错误
  • centos7网卡编辑_Centos7.4修改网卡为eth0
  • doubb超时_dubbo超时重试
  • java中类是什么的抽象_java 抽象类是 什么
  • java heap和stack区别_java heap和stack有什么区别
  • java字符串和json字符串区别_Json对象和Json字符串的区别
  • java没有这样的元素异常_java – 如何解决,Stale元素异常?如果元素不再附加到DOM?...
  • java测试学习_JAVA开学测试
  • 【前端学习】-粗谈选择器
  • ES6 ...操作符
  • go append函数以及写入
  • HTTP传输编码增加了传输量,只为解决这一个问题 | 实用 HTTP
  • JS专题之继承
  • JWT究竟是什么呢?
  • PermissionScope Swift4 兼容问题
  • Python 使用 Tornado 框架实现 WebHook 自动部署 Git 项目
  • 官方新出的 Kotlin 扩展库 KTX,到底帮你干了什么?
  • 机器学习 vs. 深度学习
  • 技术攻略】php设计模式(一):简介及创建型模式
  • 利用阿里云 OSS 搭建私有 Docker 仓库
  • 区块链分支循环
  • 思维导图—你不知道的JavaScript中卷
  • 线上 python http server profile 实践
  • 智能合约开发环境搭建及Hello World合约
  • ​520就是要宠粉,你的心头书我买单
  • ​LeetCode解法汇总1276. 不浪费原料的汉堡制作方案
  • ​Z时代时尚SUV新宠:起亚赛图斯值不值得年轻人买?
  • # Swust 12th acm 邀请赛# [ A ] A+B problem [题解]
  • #pragma multi_compile #pragma shader_feature
  • $().each和$.each的区别
  • $(selector).each()和$.each()的区别
  • (C#)获取字符编码的类
  • (C)一些题4
  • (Note)C++中的继承方式
  • (编译到47%失败)to be deleted
  • (附源码)计算机毕业设计SSM智慧停车系统
  • (机器学习-深度学习快速入门)第三章机器学习-第二节:机器学习模型之线性回归
  • (机器学习-深度学习快速入门)第一章第一节:Python环境和数据分析
  • (解决办法)ASP.NET导出Excel,打开时提示“您尝试打开文件'XXX.xls'的格式与文件扩展名指定文件不一致
  • (论文阅读31/100)Stacked hourglass networks for human pose estimation
  • (五)Python 垃圾回收机制
  • (转)Google的Objective-C编码规范
  • ..回顾17,展望18
  • /etc/shadow字段详解
  • @angular/cli项目构建--Dynamic.Form
  • @Import注解详解
  • @select 怎么写存储过程_你知道select语句和update语句分别是怎么执行的吗?
  • @staticmethod和@classmethod的作用与区别