好好的Timer居然有坑?
在做定时任务时,可能会使用到Timer+TimerTask类,但是这两个小小的类,却有大坑。
先来复现一下问题,如下,可能预期的是第一个PrintTask从1一直往后打印,直到为5时抛出异常,第二个PrintTask从100往后不间断打印。
public class Main12 {
public static void main(String[] args) {
Timer timer =new Timer();
timer.schedule(new PrintTask(1),0,1000);
timer.schedule(new PrintTask(100),0,1000);
}
static class PrintTask extends java.util.TimerTask{
private int mStart;
public PrintTask(int start) {
mStart = start;
}
@Override
public void run() {
if (mStart==5){
throw new RuntimeException();
}
System.out.println("mStart=="+mStart++);
}
}
}
mStart==1
mStart==100
mStart==101
mStart==2
mStart==3
mStart==102
mStart==4
mStart==103
Exception in thread "Timer-0" java.lang.RuntimeException
at main.Main12$PrintTask.run(Main12.java:21)
at java.util.TimerThread.mainLoop(Timer.java:555)
at java.util.TimerThread.run(Timer.java:505)
Process finished with exit code 0
但是结果却是,在第一个PrintTask到5抛出异常后,第二个PrintTask却奇迹般的终止了。
这里是不是说明某个TimerTask中的run方法向外抛出异常后,其他TimerTask会自动终止呢?
那就得看Timer的实现原理了。
Timer实现原理
Timer中维护这一个TaskQueue和一个TimerThread,TaskQueue是一个由平衡二叉树实现的优先级队列,在调用Timer的schedule方法时,也就是把TimerTask放入TaskQueue中。TimerThread则是具体执行任务的线程,它从TaskQueue中获取优先级最高的任务去执行,并且只有当前任务执行完后才会从队列中获取下一个任务,不管队列里是否有任务已经到了设置的delay时间。这个模型也就是多生产者---单消费者(只要这个消费者线程挂了,其他任务就没办法执行)。
所以,重中之重在于TimerThread,只需要搞明白TimerThread就可以了。
在TimerThread的mainLoop方法中开始获取任务并执行,当任务抛出InterruptedException以外的异常时,唯一的消费者线程就会因异常而终止,队列里的其他任务就会被清除。
public void run() {
try {
mainLoop();
} finally {
synchronized(queue) {
newTasksMayBeScheduled = false;
queue.clear();
}
}
}
private void mainLoop() {
while (true) {
try {
TimerTask task;
boolean taskFired;
//从队列里面获取任务时加锁。
synchronized(queue) {
......
}
if (taskFired)
task.run(); //执行任务
} catch(InterruptedException e) {
}
}
所以在TimerTask的run方法中,最好使用try-catch结构捕捉异常,不要向上抛。
还可以使用ScheduledThreadPoolExecutor,ScheduledThreadPoolExecutor中的一个任务抛出异常,其他任务也不受影响。
原文地址:https://www.cnblogs.com/HouXinLin/p/12560054.html
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 超赞,压缩20M文件从30秒到1秒的优化过程
- 超赞,给你推荐20个使用 Java CompletableFuture的例子!
- Java入门编程练习题
- Spark UDF加载外部资源
- Flink SQL FileSystem Connector 分区提交与自定义小文件合并策略
- Facebook面试题: 用递归和迭代手写Array.prototype.flat()
- Kubernetes插件之ip-masq-agent
- 抽丝剥茧Kotlin - 协程
- 使用Java8中的Optional类来消除代码中的null检查
- 通俗讲解从Transformer到BERT模型!
- 「R」使用有限混合模型
- Kaggle经典数据分析项目:泰坦尼克号生存预测!
- 零基础学习梯度下降算法
- Spring JPA 依赖配置
- Spring JPA 核心概念