java 中里设置定时任务

青旅半醒 2022-10-01 05:47 148阅读 0赞

1.利用Timer来进行定时任务的书写，可以通过编译时间间隔来进行  
**TimerTask**

TimerTask类是一个抽象类，由Timer 安排为一次执行或重复执行的任务。它有一个抽象方法run()方法，该方法用于执行相应计时器任务要执行的操作。因此每一个具体的任务类都必须继承TimerTask，然后重写run()方法。

另外它还有两个非抽象的方法：

boolean cancel()：取消此计时器任务。

long scheduledExecutionTime()：返回此任务最近实际执行的安排执行时间。

import java.util.Timer;
    import java.util.TimerTask;
    
    /**
     * 描述:利用Timer来进行定时任务的书写
     *
     * @outhor 马铭泽
     * @create 2019-06-11 9:44
     */
    public class TimerTest01 {
        Timer timer;
        public TimerTest01(int time){
            timer = new Timer();
            timer.schedule(new TimerTaskTest01(), time * 1000);
        }
    
        public static void main(String[] args) {
            System.out.println("timer begin....");
            new TimerTest01(10);
        }
    }
    
     class TimerTaskTest01 extends TimerTask {
    
        public void run() {
            System.out.println("Time's up!!!!");
        }
    }

但是用Timer中可能遇上两个问题：

1、Timer管理时间延迟缺陷：  
前面Timer在执行定时任务时只会创建一个线程任务，如果存在多个线程，若其中某个线程因为某种原因而导致线程任务执行时间过长，超过了两个任务的间隔时间，会发生一些缺陷：

2、Timer抛出异常缺陷：  
如果TimerTask抛出RuntimeException，Timer会终止所有任务的运行。

解决办法：  
对于Timer的缺陷，我们可以考虑 ScheduledThreadPoolExecutor 来替代。Timer是基于绝对时间的，对系统时间比较敏感，而ScheduledThreadPoolExecutor 则是基于相对时间；Timer是内部是单一线程，而ScheduledThreadPoolExecutor内部是个线程池，所以可以支持多个任务并发执行。

2.用ScheduledExecutorService替代Timer  
1、解决问题一：

public class ScheduledExecutorTest {
        private  ScheduledExecutorService scheduExec;
        
        public long start;
        
        ScheduledExecutorTest(){
            this.scheduExec =  Executors.newScheduledThreadPool(2);  
            this.start = System.currentTimeMillis();
        }
        
        public void timerOne(){
            scheduExec.schedule(new Runnable() {
                public void run() {
                    System.out.println("timerOne,the time:" + (System.currentTimeMillis() - start));
                    try {
                        Thread.sleep(4000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            },1000,TimeUnit.MILLISECONDS);
        }
        
        public void timerTwo(){
            scheduExec.schedule(new Runnable() {
                public void run() {
                    System.out.println("timerTwo,the time:" + (System.currentTimeMillis() - start));
                }
            },2000,TimeUnit.MILLISECONDS);
        }
        
        public static void main(String[] args) {
            ScheduledExecutorTest test = new ScheduledExecutorTest();
            test.timerOne();
            test.timerTwo();
        }
    }

运行结果：

timerOne,the time:1003
    timerTwo,the time:2005

2、解决问题二

public class ScheduledExecutorTest {
        private  ScheduledExecutorService scheduExec;
        
        public long start;
        
        ScheduledExecutorTest(){
            this.scheduExec =  Executors.newScheduledThreadPool(2);  
            this.start = System.currentTimeMillis();
        }
        
        public void timerOne(){
            scheduExec.schedule(new Runnable() {
                public void run() {
                    throw new RuntimeException();
                }
            },1000,TimeUnit.MILLISECONDS);
        }
        
        public void timerTwo(){
            scheduExec.scheduleAtFixedRate(new Runnable() {
                public void run() {
                    System.out.println("timerTwo invoked .....");
                }
            },2000,500,TimeUnit.MILLISECONDS);
        }
        
        public static void main(String[] args) {
            ScheduledExecutorTest test = new ScheduledExecutorTest();
            test.timerOne();
            test.timerTwo();
        }
    }

遇上异常可以抛出，然后可以继续线程  
运行结果：

timerTwo invoked .....
    timerTwo invoked .....
    timerTwo invoked .....
    timerTwo invoked .....
    timerTwo invoked .....
    timerTwo invoked .....
    timerTwo invoked .....
    timerTwo invoked .....
    timerTwo invoked .....
    ........................