基础理论

小顶堆

堆是一个完全二叉树（出过最后都是满二叉，最后一排叶子节点靠左边），且
子节点都比叶子节点大或者小。

按照这个特性，我们将任务放入后最小的会跑到顶部，我们取走即可。（小顶堆）

我们使用一个数组，数组中某一元素的父节点位置处于该节点位置除以二的位置，将插入的任务至于尾部，一直找父节点，找到它对应的位置即可。

时间轮

1.链表或者数组实现时间轮：while-true-sleep

遍历数组，每个下标放置一个链表，链表节点放置任务，遍历到了就取出执行。

2.round型时间轮

任务上记录一个round，遍历到了就round减一，为0时取出执行。

缺点：需要遍历所有的任务，效率较低。

3.分层时间轮（常用的方式）

使用多个不同时间维度的轮：天轮：记录几点执行；月轮记录几号执行。

月轮遍历到了，将任务取出放到天轮里面，即可实现几号几点执行。

quartz用法

在这里插入图片描述

Job 任务
Job就是你想要实现的任务类，每一个Job必须实现org.quartz.job接口，且只需要实现接口定义的execute()方法。
Trigger触发器
通过触发器来触发任务
调度器Scheduler
传入任务和触发器执行

job和trigger通过建造者模式来创建。

demo

@DisallowConcurrentExecution
@PersistJobDataAfterExecution
public class MyJob  implements Job {

    private String name;

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
        JobDataMap jobDataMapT = context.getTrigger().getJobDataMap();
        System.out.println("我是"+name+"GAME"+jobDataMap.getString("game")+jobDataMapT.getString("sport")+new Date());
        jobDataMap.put("i",jobDataMap.getInt("i")+1);
        System.out.println("执行的第"+jobDataMap.get("i"));
    }
}

public class TestJob {
    public static void main(String[] args) {
        //jobdetail
        JobDetail jobDetail = JobBuilder
                .newJob(MyJob.class).withIdentity("myjob","jobTest")
                .usingJobData("name", "fengqiao")
                .usingJobData("game","lol")
                .usingJobData("i",1)
                .build();
        //trigger
        SimpleTrigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("mytrigger", "triggerTest")
                .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(2).repeatForever())
                .usingJobData("sport","bike")
                .build();
        try {
            //调度器
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
            scheduler.scheduleJob(jobDetail, trigger);
            scheduler.start();
        } catch (SchedulerException e) {
            throw new RuntimeException(e);
        }
    }
}