java定时任务调度工具之Timer

小咪咪 2024-02-17 23:50 73阅读 0赞

一、定义：（祥见JDK文档）有且仅有一个后台线程对多个业务线程进行定时定频率的调度。

二、构件：Timer定时调用，TimerTask任务。

三、timer的schedule函数的四种用法：

1.schdule(task,time)

task：所要安排的任务。

time：执行任务的时间。

作用：在时间等于或者超过time的时候执行且仅执行一次task(当time晚于当前时间，后台线程等待，当time早于当前时间，启动后立即执行）。

2.schdule(task,time，period)

task：所要安排的任务。

time：执行任务的时间。

period：执行一次任务的时间间隔，单位是毫秒。

作用：在时间等于或者超过time的时候首次执行task，之后每隔period毫秒重复执行一次task。

3.schdule(task,delay)

task：所要安排的任务。

time：执行任务前的延迟时间，单位毫秒。

作用：等待delay毫秒后执行且仅执行一次task。

4.schdule(task,delay，period)

task：所要安排的任务。

delay：执行任务前的延迟时间，单位毫秒。

period：执行一次任务的时间间隔，单位是毫秒。

作用：等待delay毫秒后首次执行task，之后每隔period毫秒重复执行一次task。

5.schduleAtFixedRate(task,time，period)

task：所要安排的任务。

time：执行任务的时间。

period：执行一次任务的时间间隔，单位是毫秒。

作用：在时间等于或者超过time的时候首次执行task，之后每隔period毫秒重复执行一次task。

6.schduleAtFixedRate(task,time，period)

task：所要安排的任务。

time：执行任务的时间。

period：执行一次任务的时间间隔，单位是毫秒。

作用：等待delay毫秒后首次执行task，之后每隔period毫秒重复执行一次task。

import java.text.SimpleDateFormat;
    import java.util.Calendar;
    import java.util.TimerTask;
    import java.util.concurrent.atomic.AtomicInteger;
    
    
    
    
    public class MytimerTask extends TimerTask{
        private String name;//任务名称
        private AtomicInteger count = new AtomicInteger(0);//执行次数,线程安全
    	public MytimerTask(String name){
    		this.name = name;
    	}
    	public void run() {
    		Calendar calendar = Calendar.getInstance();
    		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");
    		String time = format.format(calendar.getTime());
    		
    		//已安排的任务最近执行时间
    		long nexttime = scheduledExecutionTime();
    		System.out.println(name+"最近执行时间时间："+ format.format(nexttime));
    		//获取当前的值并自增
    		count.getAndIncrement();
    		System.out.println("执行"+count+"次"+name+"任务："+ time);
    		
    		
    		
    		if(count.get()>=5){
    			System.out.println("----"+name+"执行任务满五次取消任务----");
    			//取消当前timerTask里面的任务
    			cancel();
    		}
    		
    	}
    
    }

import java.text.SimpleDateFormat;
    import java.util.Calendar;
    import java.util.Timer;
    import java.util.TimerTask;
    
    public class Mytimer{
    	
         public static void main(String[] args) throws InterruptedException {
    		Timer timer = new Timer();
    		TimerTask myTask1 = new MytimerTask("myTask1");
    		
    		SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");
    		
    		//获取当前时间
    		Calendar calendar = Calendar.getInstance();
    		System.out.println("启动定时器时间："+dateFormat.format(calendar.getTime()));
    		//当前时间的三秒钟后
    		calendar.add(Calendar.SECOND, 3);
    		//在时间等于或超过time的时候执行且仅执行一次任务
    		timer.schedule(myTask1, calendar.getTime());
    		
    		TimerTask myTask2 = new MytimerTask("myTask2");
    		
    		Thread.sleep(5000);//休眠5s
    		//在时间等于或在超过time时，首次执行task，之后每隔period毫秒，重复执行一次task
    		timer.schedule(myTask2, calendar.getTime(), 3000);
    		
    		TimerTask myTask3 = new MytimerTask("myTask3");
    		//等待delay毫秒后，执行且仅执行一次task
    		timer.schedule(myTask3, 2000);
    		
    		//在等待delay毫秒后，首次执行task，之后每隔period毫秒，重复执行一次task
    		TimerTask myTask4 = new MytimerTask("myTask4");
    		timer.schedule(myTask4, 3000, 2000);
    		
    		Thread.sleep(5000);//休眠5s
    		
    		//在时间等于或在超过time时，首次执行task，之后每隔period毫秒，重复执行一次task
    		TimerTask myTask5 = new MytimerTask("myTask5");
    		timer.scheduleAtFixedRate(myTask5, calendar.getTime(), 2000);
    		
    		//在延迟delay毫秒后，首次执行task,之后每隔period毫秒执行一次task
    		TimerTask myTask6 = new MytimerTask("myTask6");
    		timer.scheduleAtFixedRate(myTask6, 2000, 3000);
    		
    		//从此计时器的任务队列中移除所有已取消的任务
    		timer.purge();
    		
    		//丢弃当前所有已安排的任务
    		timer.cancel();
    		
    		System.out.println("所有任务取消");
    		
         }
    
    }

scheduleAtFixedRate与schedule的区别：

1.首次计划执行时间早于任务启动时间

schedule方法：如果第一次执行时间被延迟了，随后的执行时间按照上一次实际执行完成的时间点进行计算

scheduleAtFixedRate方法：如果第一次执行时间被延迟了，随后执行时间按照上一次开始时间点进行计算，并且为了赶上进度，会多次执行任务，因此TimerTask中的执行体需要考虑同步。

2.执行任务时间超出执行周期的间隔

schedule 方法：下一次执行时间相对于上一次实际完成的时间点，因此执行时间会不断延后

scheduleAtFixedRate方法：下一次执行时间相对于上一次开始的时间点，因此执行时间一般不会延后，因此存在并发性

import java.text.SimpleDateFormat;
    import java.util.Calendar;
    import java.util.Timer;
    import java.util.TimerTask;
    
    public class Mytimer{
    	
         public static void main(String[] args) throws InterruptedException {
    		Timer timer = new Timer();
    		
    		
    		SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS");
    		
    		//获取当前时间
    		Calendar calendar = Calendar.getInstance();
    		System.out.println("启动定时器时间："+dateFormat.format(calendar.getTime()));
    		//当前时间的四秒钟之前
    		calendar.add(Calendar.SECOND, -4);
    		
    		TimerTask myTask1 = new MytimerTask("myTask1");
    		timer.schedule(myTask1, calendar.getTime(), 2000);
    		
    		TimerTask myTask2 = new MytimerTask("myTask2");
    		timer.scheduleAtFixedRate(myTask2, calendar.getTime(), 2000);
    	    
    		
         }
    
    }

timer的缺陷：

1. 管理并发任务的缺陷： timer有且仅有一个后台线程去执行定时任务，如果存在多个任务，且任务时间过长会导致执行效果与预期不符。

2.当任务抛出异常时的缺陷：如果TimerTask抛出RuntimeException，timer会停止所有任务的运行

Timer的使用禁区：

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

2.对复杂任务的调度