Java学习笔记:定时任务调度工具之 Timer

简介: Java学习笔记:定时任务调度工具之 Timer

定时任务调度

定义:

基于给定的时间点,给定的时间间隔或者给定的执行次数自动执行的任务

Timer 和 Quartz

Timer: 有且仅有一个后台线程对多个业务线程进行定时定频率的调度

主要构件

Timer -定时调用-> TimerTask

timer.jpg

定时函数的用法

// 延时执行一次

public void schedule(TimerTask task, long delay)

// 定时执行一次
public void schedule(TimerTask task, Date time)

// 延时间隔执行
public void schedule(TimerTask task, long delay, long period)

// 定时间隔执行
public void schedule(TimerTask task, Date firstTime, long period)

// 延时间隔执行
public void scheduleAtFixedRate(TimerTask task, long delay, long period)

// 定时间隔执行
public void scheduleAtFixedRate(TimerTask task, Date firstTime, long period)

代码实例

package timer;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Timer;
import java.util.TimerTask;

class Util {
public static String getCurrentDateTime() {
Calendar calendar = Calendar.getInstance();
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
return dateFormat.format(calendar.getTime());
}
}

class MyTimerTask extends TimerTask {
@Override
public void run() {
System.out.println("MyTimerTask is Running " + Util.getCurrentDateTime());
}
}


public class TimerDemo {
public static void main(String[] args) {
Timer timer = new Timer();

// 延时0s之后,每隔1s执行一次
timer.schedule(new MyTimerTask(), 0L, 1000L);
}
}

执行结果

MyTimerTask is Running 2020-06-22 22:49:45
MyTimerTask is Running 2020-06-22 22:49:46
MyTimerTask is Running 2020-06-22 22:49:47
...

其他函数

TimerTask.cancel() 取消【当前】 TimerTask 里的任务
TimerTask.scheduledExecutionTime() 返回此任务最近实际执行的已安排执行的时间

Timer.cancel()终止此计时器,丢弃【所有】当前已安排的任务
Timer.purge() 从此计时器的任务队列中移除所有已取消的任务,返回移除数量

区别

schedule 和 scheduleAtFixedRate

1、首次计划执行的时间早于当前的时间

schedule fixed-delay

如果第一次执行时间被 delay 了,随后的执行时间按照上一次实际执行【完成的时间点】进行计算


scheduleAtFixedRate fixed-rate


如果第一次执行时间被 delay 了,随后的执行时间按照上一次【开始的时间点】进行计算,并且为了赶上进度会多次执行任务,因此 TimerTask 中的执行体需要考虑同步


代码示例

package timer;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;


public class TimerDemo {
public static void main(String[] args) {
Timer timer = new Timer();

SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

Calendar calendar = Calendar.getInstance();
calendar.add(Calendar.SECOND, -10);

timer.schedule(new TimerTask() {
@Override
public void run() {
System.out.println(dateFormat.format(new Date()));
}
}, calendar.getTime(), 2000L);
}
}

执行结果

timer.schedule

2020-06-22 23:16:56
2020-06-22 23:16:58
2020-06-22 23:17:00


timer.scheduleAtFixedRate
2020-06-22 23:18:19
2020-06-22 23:18:19
2020-06-22 23:18:19

2、任务执行所需时间超出任务的执行周期间隔

schedule

下次执行时间相对于上一次实际执行【完成的时间点】,因此执行时间会不断延后

scheduleAtFixedRate

下一次执行时间相对于上一次【开始的时间点】,因此执行时间一般不会延后,因此存在并发性

package timer;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;


public class TimerDemo {
public static void main(String[] args) {
Timer timer = new Timer();

SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

timer.scheduleAtFixedRate(new TimerTask() {
@Override
public void run() {
try {
Thread.sleep(3000L);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(dateFormat.format(new Date()));
}
}, 0L, 1000L);


}
}
timer.schedule

2020-06-22 23:24:08
2020-06-22 23:24:11
2020-06-22 23:24:14


timer.scheduleAtFixedRate
2020-06-22 23:25:18
2020-06-22 23:25:21
2020-06-22 23:25:24

Timer 综合应用

执行 5 次任务,就停止定时器,并退出程序

package timer;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;

// 自定义任务
class MyTimerTask extends TimerTask {

private SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

private int count = 0;

private Timer timer;

public MyTimerTask(Timer timer) {
this.timer = timer;
}

@Override
public void run() {
System.out.println(dateFormat.format(new Date()));

// 判断执行满5次就停止
this.count++;

if (this.count >= 5) {
// 停止当前任务
this.cancel();

// 停止定时器,并退出程序
this.timer.cancel();
}
}
}

public class TimerDemo {
public static void main(String[] args) {
Timer timer = new Timer();
timer.schedule(new MyTimerTask(timer), 0L, 1000L);
}
}

打印结果

2020-06-23 20:46:11
2020-06-23 20:46:12
2020-06-23 20:46:13
2020-06-23 20:46:14
2020-06-23 20:46:15

Timer 缺陷

1、管理并发任务的缺陷

Timer 有且仅有一个线程去执行定时任务,如果存在多个任务,且任务时间过长,会导致执行效果与预期不符


2、当任务抛出异常时的缺陷

如果 TimerTask 抛出 RuntimeException,Timer 会停止所有任务的运行


3、以下场景不建议使用


1.对时效性要求较高的多任务并发作业

2.对复杂的任务的调度


            </div>
目录
相关文章
|
5天前
|
数据采集 人工智能 安全
|
14天前
|
云安全 监控 安全
|
6天前
|
自然语言处理 API
万相 Wan2.6 全新升级发布!人人都能当导演的时代来了
通义万相2.6全新升级,支持文生图、图生视频、文生视频,打造电影级创作体验。智能分镜、角色扮演、音画同步,让创意一键成片,大众也能轻松制作高质量短视频。
1197 152
|
19天前
|
机器学习/深度学习 人工智能 自然语言处理
Z-Image:冲击体验上限的下一代图像生成模型
通义实验室推出全新文生图模型Z-Image,以6B参数实现“快、稳、轻、准”突破。Turbo版本仅需8步亚秒级生成,支持16GB显存设备,中英双语理解与文字渲染尤为出色,真实感和美学表现媲美国际顶尖模型,被誉为“最值得关注的开源生图模型之一”。
1851 9
|
11天前
|
人工智能 自然语言处理 API
一句话生成拓扑图!AI+Draw.io 封神开源组合,工具让你的效率爆炸
一句话生成拓扑图!next-ai-draw-io 结合 AI 与 Draw.io,通过自然语言秒出架构图,支持私有部署、免费大模型接口,彻底解放生产力,绘图效率直接爆炸。
756 152
|
8天前
|
SQL 自然语言处理 调度
Agent Skills 的一次工程实践
**本文采用 Agent Skills 实现整体智能体**,开发框架采用 AgentScope,模型使用 **qwen3-max**。Agent Skills 是 Anthropic 新推出的一种有别于mcp server的一种开发方式,用于为 AI **引入可共享的专业技能**。经验封装到**可发现、可复用的能力单元**中,每个技能以文件夹形式存在,包含特定任务的指导性说明(SKILL.md 文件)、脚本代码和资源等 。大模型可以根据需要动态加载这些技能,从而扩展自身的功能。目前不少国内外的一些框架也开始支持此种的开发方式,详细介绍如下。
574 5
|
13天前
|
人工智能 安全 前端开发
AgentScope Java v1.0 发布,让 Java 开发者轻松构建企业级 Agentic 应用
AgentScope 重磅发布 Java 版本,拥抱企业开发主流技术栈。
704 14