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;
}
}