天天看點

java定時器Scheduled,可動态設定定時器執行時間

java定時器任務,可動态設定定時器執行時間,無延時

@Component
@EnableScheduling
public class DayTimerTask implements SchedulingConfigurer {

    private final static Logger logger = LoggerFactory.getLogger(DayTimerTask.class);

	//動态設定定時器執行時間
    @Autowired
    private TimerConfigureService timerConfigureService;

    private static String cron;
    private static ScheduledTaskRegistrar scheduledtaskRegistrar;
    private static ScheduledFuture<?> future;

    public DayTimerTask() {
        cron = "0 50 23 * * ?";
    }

    /**
     * 輪詢查詢日期設定 30分鐘
     */
    @Scheduled(cron = "0 0/30 * * * ?")
    public void test(){
    	//查詢動态設定的定時器執行時間
        TimerConfigure timerConfigure = timerConfigureService.getOne(
                Wrappers.<TimerConfigure>lambdaQuery()
                        .eq(TimerConfigure::getType, 0));

        if(!cron.equals(timerConfigure.getCron())){
            if(Objects.nonNull(future)){
                future.cancel(true);
            }
            timer(timerConfigure.getCron());
        }else {
            if(Objects.isNull(future)){
                timer(cron);
            }
        }
        //修改每天更新時間
        cron = timerConfigure.getCron();
       
    }

    public void timer(String nextCron){

        TaskScheduler scheduler = scheduledtaskRegistrar.getScheduler();
        Runnable runnable = () -> {
            // 任務邏輯
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            logger.info("開始執行定時任務(每天),開始時間:" + sf.format(new Date()));
            //執行具體的業務
            logger.info("定時任務執行完成(每天),更新完成時間:" + sf.format(new Date()));
        };
        Trigger trigger = triggerContext -> {
            // 任務觸發,可修改任務的執行周期
            CronTrigger trigger1 = new CronTrigger(nextCron);
            Date nextExec = trigger1.nextExecutionTime(triggerContext);
            return nextExec;
        };
        future = scheduler.schedule(runnable, trigger);
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        scheduledtaskRegistrar = taskRegistrar;
    }
}