标签:nbsp bsp 其他 size 业务逻辑 ... abort sim into
1. Timer简介
Timer是jdk中提供的一个定时器工具,使用的时候会在主线程之外起一个单独的线程执行指定的计划任务,可以指定执行一次或者反复执行多次。
通过创建Timer对象,然后调用Timer的schedule方法,将TimerTask实例作为参数,从而实现定时调度TimerTask(其中TimerTask对象要继承TimerTask对象,复写run方法)。
Timer工具类
2.Timer函数的使用
2.1 Timer定时函数
看参数应该很好理解
结合demo进行展示(第四个方法)
step1:new一个TimerTask的子类,重写run方法来指定具体的任务
package com.zang.timer; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.TimerTask; public class MyTimerTask extends TimerTask{ private String name; //构造器 public MyTimerTask(String inputName){ name = inputName; } //重写run方法,打印当前时间。 @Override public void run() { Calendar calendar = Calendar.getInstance(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //打印当前文件的内容 System.out.println("Current exec name is " + sdf.format(calendar.getTime())); } public String getName() { return name; } public void setName(String name) { this.name = name; } }
step2:new一个Timer类,Timer的构造函数里会起一个单独的线程来执行计划任务。
package com.zang.timer; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import java.util.Timer; public class MyTimer { public static void main(String[] args) { //1.创建一个Timer实例 Timer timer = new Timer(); //2.创建一个MyTimerTask实例 MyTimerTask myTimerTask = new MyTimerTask("My First Timer..."); //日期格式化和输出当前时间 Calendar calendar = Calendar.getInstance(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); System.out.println("current time is " + sdf.format(calendar.getTime())); //3.通过timer定时定频率调用MyTimerTask的业务逻辑 //两秒之后第一次执行,之后每隔一秒执行一次 timer.schedule(myTimerTask, 2000L, 1000L); } }
jdk中的代码实现如下:
public Timer() { this("Timer-" + serialNumber()); } public Timer(String name) { thread.setName(name); thread.start(); }
输出如下:
2.2 Timer其他函数(此处不作详解)
TimerTask的cancel()函数的作用:取消当前TimerTask里的任务。
TimerTask的scheduleExecutionTime()作用:返回此任务最近实际执行的已安排执行的时间,返回值:最近发生此任务执行安排的时间,为long型。
Timer对象的cancel()函数的作用:终止此计时器,丢弃所有当前已安排的任务。
Timer的purge()函数的作用:从此计时器的任务队列中移除所有已取消的任务。返回值:从队列中移除的任务数。
2.3 schedule 和 scheduleAtFixedRate的区别
这两个方法都是任务调度方法,他们之间区别是,schedule会保证任务的间隔是按照定义的period参数严格执行的,如果某一次调度时间比较长,那么后面的时间会顺延,保证调度间隔都是period,而scheduleAtFixedRate是严格按照调度时间来的,如果某次调度时间太长了,那么会通过缩短间隔的方式保证下一次调度在预定时间执行。举个栗子:你每个3秒调度一次,那么正常就是0,3,6,9s这样的时间,如果第二次调度花了2s的时间,如果是schedule,就会变成0,3+2,8,11这样的时间,保证间隔,而scheduleAtFixedRate就会变成0,3+2,6,9,压缩间隔,保证调度时间。即schedule的执行基于上一次的完成时间, scheduleAtFixedRate的执行基于上一次的开始时间。
3. 综合使用demo
利用Timer控制两个机器人——灌水机器人负责灌水,水满即停止工作;跳舞机器人不负责灌水,水满之后跳舞两秒,停止工作。
创建两个TimerTask的子类,重写run方法来指定具体的任务。
package com.zang.timer; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.TimerTask; public class DancingRobot extends TimerTask{ @Override public void run() { //获取最近一次任务执行时间,并将其格式化 SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); System.out.println("Schedule exec name is " + sdf.format(scheduledExecutionTime())); System.out.println("I am dacing.... "); } }
package com.zang.timer; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Timer; import java.util.TimerTask; public class WaterRobot extends TimerTask { private Timer timer; //水桶的容量,最大容量为5L private Integer bucketCapacity = 0; public WaterRobot(Timer inputTimer) { timer = inputTimer; } @Override public void run() { //注水直到水满为止 if(bucketCapacity < 5){ System.out.println("Add 1L water into the bucket."); bucketCapacity++; }else{ //水满之后停止 System.out.println("The number of canceled task in timer is(BEFORE) " + timer.purge()); cancel(); System.out.println("The bucket is fulling and the waterRobot has been aborted."); System.out.println("Current water is "+ bucketCapacity +"L"); //输出被取消的任务数 System.out.println("The number of canceled task in timer is(AFTER) " + timer.purge()); //等待两秒,终止timer里的所有内容 try { Thread.sleep(2000); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } timer.cancel(); } } }
Timer对象执行任务
package com.zang.timer; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Timer; public class RobotExecutor { public static void main(String[] args) { Timer timer = new Timer(); //获取当前时间 Calendar calendar = Calendar.getInstance(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); System.out.println("Current time is " + sdf.format(calendar.getTime())); DancingRobot dr = new DancingRobot(); WaterRobot wr = new WaterRobot(timer); /* * 灌水机器人负责灌水,水满即停止工作 * 跳舞机器人不负责灌水,水满之后跳舞两秒,停止工作 */ timer.schedule(dr, calendar.getTime(), 2000); timer.schedule(wr, calendar.getTime(), 1000); } }
控制台输出:
标签:nbsp bsp 其他 size 业务逻辑 ... abort sim into
原文地址:http://www.cnblogs.com/zjfjava/p/7955344.html