java多线程编程核心技术5-Timer定时器

时间:2022-08-09 00:10:55
一。如何实现指定时间执行任务。
1.定时计划任务功能在Java中主要使用的就是Timer对象,它在内部使用多线程的方式进行处理,所以它和线程技术有非常大的关联。
2.jdk的Timer定时类使用示例如下(指定时间点执行TimerTask):
   public class Run { 
private static Timer timer = new Timer(); 
static public class MyTask extends TimerTask {
@Override
public void run() {
System.out.println("运行了!时间为:" + new Date());
}

public static void main(String[] args) {
try {
MyTask task = new MyTask();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateString = "2017-03-31 14:56:00";
Date dateRef = sdf.parse(dateString);
System.out.println("字符串时间:" + dateRef.toLocaleString() + " 当前时间:"
+ new Date().toLocaleString());
timer.schedule(task, dateRef);
} catch (ParseException e) {
e.printStackTrace();
}
}
}
   结果虽然正常运行,但是进程还未销毁呈红色,这是因为创建Timer对象时,相当于启动了一个线程,这个新启动的线程并不是守护线程,它一直运行


3.如果执行时间早于当前时间,则Timer会立刻执行当前任务。
   
4.多个TimerTask任务
   1.TimerTask是以队列的方式一个一个被顺序执行的,所以执行的时间有可能和预期的时间不一致,因为前面的任务可能消耗的时间较长,从而导致
     后面的任务运行的时间也会被延迟。


5.schedule(TimerTask task,Date firstTime,long period)
  1.作用:在指定的日期之后,按指定的间隔周期性的无限循环地执行某一任务。  
  2.实例代码(计划时间早于当前时间则立刻运行):
    public class Run { 
static public class MyTask extends TimerTask {
@Override
public void run() {
System.out.println("运行了!时间为:" + new Date());
}

public static void main(String[] args) {
try {
MyTask task = new MyTask();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateString = "2017-04-01 08:49:15";
Timer timer = new Timer();
Date dateRef = sdf.parse(dateString);
System.out.println("字符串时间:" + dateRef.toLocaleString() + " 当前时间:"
+ new Date().toLocaleString());
timer.schedule(task, dateRef, 4000);
} catch (ParseException e) {
e.printStackTrace();
}
}
}
   3.任务执行时间(按照启动时间和间隔时间确定的任务执行时间点,如整点启动,每隔4秒运行一次,但是任务本身需耗时5秒,这样则每次等到任务执行完毕后才继续
     执行下一次任务,而不是停止当前任务,此时实际变成了以任务本身执行时间为间隔去定时执行)被延时。
  实例代码:
     public class Run2_1 {
static public class MyTaskA extends TimerTask {
@Override
public void run() {
try {
System.out.println("A运行了!时间为:" + new Date());
Thread.sleep(5000);
System.out.println("A结束了!时间为:" + new Date());
} catch (InterruptedException e) {
e.printStackTrace();
}
}

public static void main(String[] args) {
try {
MyTaskA taskA = new MyTaskA();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateString = "2015-3-19 14:14:00";
Timer timer = new Timer();
Date dateRef = sdf.parse(dateString);
System.out.println("字符串时间:" + dateRef.toLocaleString() + " 当前时间:"
+ new Date().toLocaleString());
timer.schedule(taskA, dateRef, 4000);
} catch (ParseException e) {
e.printStackTrace();
}
}
}
运行结果:
A运行了 14:14:00
     A结束了 14:14:05
A运行了 14:14:05
     A结束了 14:14:10
A运行了 14:14:10
     A结束了 14:14:15


6.TimerTask类的cancel()方法:将自身从任务列表中清除。
  实例代码(MyTaskA只执行一次就取消了):
    public class Run { 
static public class MyTaskA extends TimerTask {
@Override
public void run() {
System.out.println("A运行了!时间为:" + new Date());
this.cancel();
}

static public class MyTaskB extends TimerTask {
@Override
public void run() {
System.out.println("B运行了!时间为:" + new Date());
}

public static void main(String[] args) {
try {
MyTaskA taskA = new MyTaskA();
MyTaskB taskB = new MyTaskB();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateString = "2014-10-12 09:12:00";
Timer timer = new Timer();
Date dateRef = sdf.parse(dateString);
System.out.println("字符串时间:" + dateRef.toLocaleString() + " 当前时间:"
+ new Date().toLocaleString());
timer.schedule(taskA, dateRef, 4000);
timer.schedule(taskB, dateRef, 4000);
} catch (ParseException e) {
e.printStackTrace();
}
}
}



7.Timer类的cancel()方法: 将任务队列中的全部任务都清空,并且销毁进程(按钮由红色变成灰色)。
  实例代码:
    public class Run { 
private static Timer timer = new Timer(); 
static public class MyTaskA extends TimerTask {
@Override
public void run() {
System.out.println("A运行了!时间为:" + new Date());
timer.cancel();
}

static public class MyTaskB extends TimerTask {
@Override
public void run() {
System.out.println("B运行了!时间为:" + new Date());
}

public static void main(String[] args) {
try {
MyTaskA taskA = new MyTaskA();
MyTaskB taskB = new MyTaskB();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateString = "2014-10-12 09:12:00";
Date dateRef = sdf.parse(dateString);
System.out.println("字符串时间:" + dateRef.toLocaleString() + " 当前时间:"
+ new Date().toLocaleString());
timer.schedule(taskA, dateRef, 4000);
timer.schedule(taskB, dateRef, 4000);
} catch (ParseException e) {
e.printStackTrace();
}
}
}

注意:Timer.cancle()有时并不一定会停止执行计划任务,而是正常执行,有时并没有争抢到queue锁。 
    public class Run { 
static int i = 0; 
static public class MyTask extends TimerTask {
@Override
public void run() {
System.out.println("正常执行了" + i);
}

public static void main(String[] args) {
   //注意这个一直循环启动任务和停止任务,偶尔几万个任务会发生任务被执行的情况,因为没有争抢到queue锁。
while (true) {
try {
i++;
Timer timer = new Timer();
MyTask task = new MyTask();
SimpleDateFormat sdf = new SimpleDateFormat(
"yyyy-MM-dd HH:mm:ss");
String dateString = "2014-10-12 09:08:00";


Date dateRef = sdf.parse(dateString);
timer.schedule(task, dateRef,1000);
timer.cancel();
} catch (ParseException e) {
e.printStackTrace();
}
}
}

}




8. schedule(TimerTask task,long delay):当前时间延迟delay毫秒数后执行一次TimerTask任务)
   实例代码:
   public class Run { 
static public class MyTask extends TimerTask {
@Override
public void run() {
System.out.println("运行了!时间为:" + new Date());
}
}
public static void main(String[] args) {
MyTask task = new MyTask();
Timer timer = new Timer();
System.out.println("当前时间:" + new Date().toLocaleString());
timer.schedule(task, 7000);

}


9. schedule(TimerTask task,long delay,long period): 当前时间延迟delay毫秒数后执行一次任务后,并间隔period后无限执行任务


10.scheduleAtFixedRate(TimerTask task,Date firstTime,long period)
   如果执行任务的时间没有被延时:
       1.schedule:下一次任务的执行时间参考上一次任务的“开始”时的时间来计算,即等待上次开始时间+period毫秒时开始执行。
       2.scheduleAtFixedRate:下一次任务的执行时间参考上一次任务的“结束”时的时间来计算,即提前执行。
   如果执行任务的时间被延时:   
       1.schedule: 下一次任务的执行时间参考上一次任务的“结束”时的时间来计算,即比预期延后执行。
  2.scheduleAtFixedRate:下一次任务的执行时间参考上一次任务的“结束”时的时间来计算,即比预期延后执行。


11.schedule方法不具有追赶执行性。
   即如果定时周期性执行的时间在以前,则启动后只会从当前时间开始执行,预定时间和当前时间之间的任务不会再追加执行。
   
12.scheduleAtFixedRate方法具有追赶执行性:
   即如果定时周期性执行的时间在以前,则启动后会对预定时间和当前时间之间的任务进行“补充执行”,然后再继续执行周期性任务。
   
 
 
















二。如何实现按指定周期执行任务。