0 0 0 * * ?：每天的零點(diǎn)整執(zhí)行任務(wù)。
0 0 */2 * * ?：每隔2小時(shí)執(zhí)行一次任務(wù)。
0 0 12 * * ?：每天中午12點(diǎn)執(zhí)行任務(wù)。
 
0 15 10 * * ?：每天上午10點(diǎn)15分執(zhí)行任務(wù)。
 
0 0 6,18 * * ?：每天的早上6點(diǎn)和晚上6點(diǎn)執(zhí)行任務(wù)。
 
0 0/30 8-18 * * ?：每天的上午8點(diǎn)到下午6點(diǎn)之間，每隔30分鐘執(zhí)行一次任務(wù)。
 
0 0 0 1 1 ?：每年的1月1日零點(diǎn)整執(zhí)行任務(wù)。
 
0 0 0 * * 2：每周的星期二零點(diǎn)整執(zhí)行任務(wù)。
0 0 0 ? * 6#3：每月的第三個(gè)星期六零點(diǎn)整執(zhí)行任務(wù)。
 
0 0 0 L * ?：每個(gè)月的最后一天零點(diǎn)整執(zhí)行任務(wù)。
 
————————————————

@Scheduled(cron ="*/6 * * * * ?") 
public void sayHello() { 
System.out.println("hello"); }

drop table if exists scheduled;
create table scheduled (
cron_id varchar(30) NOT NULL primary key,
cron_name varchar(30) NULL,
cron varchar(30) NOT NULL
);
insert into scheduled values ('1','定時(shí)器任務(wù)一','0/6 * * * * ?');

@Select("select cron from cron_demo where cron_id=#{id}")
public String getCronById(int id);

public class TaskDemo implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.addTriggerTask();//or: addCronTask...
    }
 
    private void process(){
        System.out.println("cron執(zhí)行");
    }//要執(zhí)行的邏輯
}

public class TaskDemo implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.addCronTask(this::process,cronMapper.getCronByid(1)))
    }//要執(zhí)行的邏輯
    private void process(){
        System.out.println("cron執(zhí)行");
    }
}

private class TaskRunnable implements Runnable{
    private final Cron cron;
 
    public TaskRunnable(Cron cron) {
        this.cron = cron;
    }
 
    @Override
    public void run() {
        //定義任務(wù)要做的事，即把visibility字段設(shè)為0表示可見(jiàn)，
        // 同時(shí)把時(shí)間設(shè)為設(shè)定的發(fā)送時(shí)間
        // (如果設(shè)為當(dāng)前時(shí)間由于定時(shí)任務(wù)管理器CronManageTask掃面時(shí)間間隔問(wèn)題會(huì)導(dǎo)致實(shí)際執(zhí)行時(shí)間與預(yù)期發(fā)送時(shí)間不一致)
        mailboxService.lambdaUpdate()
                .set(Email::getVisibility,(short)0)
                .set(Email::getSendTime,cron.getExecuteTime())
                .eq(Email::getId,cron.getEmailId())
                .update();
 
    }
}

@RequiredArgsConstructor
public class TaskDemo implements SchedulingConfigurer {
    private final CronMapper cronMapper;
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        Runnable task =this::process;
        CronTask cronTask = new CronTask(task,cronMapper.getCronById(1));
        taskRegistrar.addTriggerTask(cronTask);
      
    }
 
    private void process(){
        System.out.println("cron執(zhí)行");
    }//要執(zhí)行的邏輯
    
} 

@Autowired
protected CronMapper cronMapper;
 
@Override
public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
    scheduledTaskRegistrar.addTriggerTask(() -> process(),
            triggerContext -> {
                String cron = cronMapper.getCron(1);
                if (cron.isEmpty()) {
                    System.out.println("cron is null");
                }
                return new CronTrigger(cron).nextExecutionTime(triggerContext);
            });
}
 
private void process() {
    System.out.println("基于接口定時(shí)任務(wù)");
}

 @Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("thread_cron")
public class cron {
    private String title;
    private LocalDate startTime;//起始時(shí)間
    private LocalDate deadTime;//結(jié)束時(shí)間
    private LocalDateTime executeTime;//運(yùn)行時(shí)間
}

public interface ThreadService extends IService<Cron> {
    void startCron(Cron cron);//啟動(dòng)定時(shí)任務(wù)
    void stopCron(Cron cron);//停止定時(shí)任務(wù)
    void changeCron(Cron cron);//更新定時(shí)任務(wù)
}

private final ThreadPoolTaskScheduler threadPoolTaskScheduler;
private final Map<Integer, ScheduledFuture<?>> futureMap = new HashMap<>();
@Bean
public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
    return new ThreadPoolTaskScheduler();
}

public void startCron(Cron cron) {
    //1.判斷cron是否被執(zhí)行過(guò)
    if(futureMap.containsKey(cron.getId())){log.info("定時(shí)任務(wù)存在 id={}",cron.getId());return;}
    //2.判斷是否還沒(méi)過(guò)執(zhí)行時(shí)間
    //在springTask中，cron表達(dá)式無(wú)法對(duì)年進(jìn)行定時(shí)，故使用startTime和deadTime來(lái)限制定時(shí)任務(wù)要執(zhí)行的年份
    if(LocalDate.now().isEqual(cron.getStartTime()) || LocalDate.now().isEqual(cron.getDeadTime()) ||
            (LocalDate.now().isAfter(cron.getStartTime()) && LocalDate.now().isBefore(cron.getDeadTime()))){
        //提取執(zhí)行時(shí)間
        LocalDateTime executeTime = cron.getExecuteTime();
        //組裝cron表達(dá)式
        DateTimeFormatter cronFormatter = DateTimeFormatter.ofPattern("s m H d M");
        String cronExp = cronFormatter.format(executeTime)+" ?";
        //執(zhí)行scheduled任務(wù)
        ScheduledFuture<?> future = threadPoolTaskScheduler.schedule(new TaskRunnable(cron), new CronTrigger(cronExp));
        //將future傳入futureMap集合表示任務(wù)啟動(dòng)，避免任務(wù)重復(fù)啟動(dòng)
        futureMap.put(cron.getId(),future);
        //輸出日志
        log.info("任務(wù)啟動(dòng)，id:{},executeTime:{}",cron.getId(),cron.getExecuteTime());
    }
}

 
public void stopCron(Cron cron) {
    ScheduledFuture<?> future = futureMap.get(cron.getId());
    if (future != null) {
        future.cancel(true);
        futureMap.remove(cron.getId());
        log.info("任務(wù)停止，id:{}",cron.getId());
    }
}

public void changeCron(Cron cron) {
    startCron(cron);
    stopCron(cron);
}

private class TaskRunnable implements Runnable{
    private final Cron cron;
    public TaskRunnable(Cron cron) {
        this.cron = cron;
    }
    @Override
    public void run() {
        //定義任務(wù)要做的事
        System.out.println("定時(shí)任務(wù)執(zhí)行，id:"+cron.getId());
    }
}

public class cronTaskManager {
    @Lazy
    private final ThreadService threadService;
    //每半個(gè)小時(shí)掃描一次
    @Scheduled(cron = "0 0/30 * * * ?")
    public void cronManage() {
        log.info("定時(shí)任務(wù)啟動(dòng)");
        List<Cron> list = threadService.list();
        list.forEach(cron -> {
            if (LocalDate.now().isAfter(cron.getDeadTime())) {
                threadService.stopCron(cron);
                threadService.removeById(cron.getId());
                log.info("任務(wù)過(guò)期刪除，id:{},executeTime:{}",cron.getId(),cron.getExecuteTime());
            } else {
                log.info("嘗試啟動(dòng)任務(wù)，id:{},executeTime:{}",cron.getId(),cron.getExecuteTime());
                threadService.startCron(cron);
            }
        });
    }
}