5.Timer
Timer 类负责计划任务
可以使用抽象类 TimerTask的子类进行业务编写。
设置定时任务
Run.java
public class Run {
public static Timer timer = new Timer();
public static class MyTask extends TimerTask{
@Override
public void run() {
System.out.println("定时任务时间到");
}
}
public static void main(String[] args) {
try{
MyTask task = new MyTask();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = sdf.parse("2021-09-30 09:14:00");
timer.schedule(task, date);
}catch (ParseException e){
}
}
}
运行结果:在设定的时间打印了“定时任务时间到”。
其中 timer 新启动了一个线程,主线程结束时,子线程仍然继续运行。为了使得子程序伴随主程序的结束而结束,可以将子线程设置为守护线程👇
public static Timer timer = new Timer(true);
当任务 task 有多个的时候,它们是按照与 schedule 的绑定顺序来进入计划队列的。
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
public class Run {
public static Timer timer = new Timer();
public static class MyTask extends TimerTask{
@Override
public void run() {
System.out.println("定时任务1时间到 " + System.currentTimeMillis());
try {
Thread.sleep(6000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public static class MyTask2 extends TimerTask{
@Override
public void run() {
System.out.println("定时任务2时间到 " + System.currentTimeMillis());
}
}
public static void main(String[] args) {
try{
MyTask task = new MyTask();
MyTask2 task2 = new MyTask2();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = sdf.parse("2021-09-30 09:37:00");
Date date2 = sdf.parse("2021-09-30 09:37:05");
timer.schedule(task, date);
timer.schedule(task2, date2);
}catch (ParseException e){
}
}
}
运行结果
定时任务1时间到 1632966052416
定时任务2时间到 1632966058433
其中,任务 1 执行耗时 6000ms,任务的优先级别是以加入 schedule 的早晚为标准的(task 加入 schedule 队列),而 timer 是单个线程,所以任务 2 需要等待任务 1 执行完毕才开始判断上一次任务的开始时间与当前任务设定的时间之间的关系,设定时间已到或者过期就执行,设定时间未到就等待。
『定时循环任务』
一旦时间到达 time,则按照 period 间隔循环执行 task。
timer.schedule(task,time,period);
『cancel』
-
task.cancel() 取消任务本身。
-
timer.cancel() 取消 timer 所绑定的所有任务,并且 timer 线程结束。
有时 cancel 方法没有抢到 queue 锁,则定时器取消不成功,各个任务照常执行。
以当前系统时间为基准,延时 delay 时间执行 task。
以当前系统时间为基准,延时 delay 时间执行 task,且往后每隔 period 的时间间隔都会执行 task。
- schedule 当前任务时间是否抵达是以上一次任务的开始时间为基准。
- scheduleAtFixedRate 当前任务时间是否抵达是以上一次任务的结束时间为基准。
scheduleAtFixedRate(TimerTask task, long time, long period)
当周期性执行时,设定的 time 提前当前一段时间(向上取整 n 个周期),scheduleAtFixedRate() 会根据周期来决定补全执行 n 次。
schedule() 不具有追赶性。
scheduleAtFixedRate() 具有追赶性。
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;
public class Run {
public static Timer timer = new Timer();
public static int runCount = 0;
public static class MyTask extends TimerTask{
@Override
public void run() {
System.out.println("定时任务1时间到 " + System.currentTimeMillis());
}
}
public static void main(String[] args) {
try{
MyTask task = new MyTask();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Date date = sdf.parse("2021-09-30 17:07:00");
System.out.println("Current time:" + System.currentTimeMillis());
timer.scheduleAtFixedRate(task, date,4000);
}catch (ParseException e){
}
}
}