Java实现定时器的几种方法

分手后的思念是犯贱 2021-06-24 16:11 419阅读 0赞

# 1.quartz #

quartz使用的是可配置的方式，将所有的定时器都配置在一个xml文件里面。一般步骤如下：  
1.创建一个spring的配置文件：spring-quartz.xml。  
2.定义工作任务的job。  
3.定义触发器Trigger并与job绑定。  
4.定义调度器，并将Trigger注册到scheduler。

# 2.@Scheduled注解 #

@Scheduled注解是最简单的方式，只需要启用定时器，在方法上添加注解即可。在spring配置中加入如下注解开启注解定时器。

<task:annotation-driven />

在要具体的方法上加入注解@Scheduled。

@Scheduled(cron = "0 0 * * * ? ")
        public void myTask(){
               //定时任务......
    }

# 3.Timer #

使用Timer的schedule，schedule有3个参数：

schedule(TimerTask task, long delay, long period)

task为定时任务，根据业务需要重写TimerTask的run方法即可。  
delay为延时启动，单位毫秒。  
period为多久运行一次，单位毫秒。  
示例代码如下：

new Timer().schedule(new TimerTask() {
                @Override
                public void run() {
                    try {
                        //do Something
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            },0,5L * 60 * 1000);

# 4.使用线程控制 #

使用线程来控制相对更灵活些，可以根据自己的需要判断什么时候运行，什么时候停止，这需要对java的线程有一定的了解。  
示例代码如下：

public class TaskTest {
        private static final ExecutorService pool = Executors.newFixedThreadPool(5);// 线程池
        public static final TaskTest me = new TaskTest();
        public final int[] arr = new int[]{1, 2, 3, 4, 5, 6, 7, 8, 9};
     
        public static void main(String[] args) {
            me.start();
        }
     
        private void start() {
            pool.execute(new Runnable() {
                @Override
                public void run() {
                    while (true) {
                        try {
                            for (int i = 0; i < arr.length; i++) {
                                if (1 == arr[i]) {
                                    System.out.println("start!");
                                    Thread.sleep(1*1000L);
                                } 
                                if (9 == arr[i]) {
                                    System.out.println("end!");
                                    Thread.sleep(5*1000L);
                                }
                            }
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            });
        }
    }