Scheduled如何会在上次任务执行完才会执行下次任务
作者:hashdog
这篇文章主要介绍了Scheduled如何会在上次任务执行完才会执行下次任务问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
Scheduled会在上次任务执行完才会执行下次任务
在使用spring的Scheduled定时任务
担心同一任务,
第一次开始未执行完就执行第二次任务,所以给加了synchronized,
但是后面经过测试Scheduled定时任务会在上次任务结束时再执行第二次任务,
如果第二次任务堵在哪里了,时间会顺延
package xyz.hashdog.job; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; /** * @author th * @description: 定时任务测试 * @projectName hashdog-ds * @date 2020/2/1223:07 */ @Component @Slf4j @AllArgsConstructor public class TestCrontab { private static final Object KEY = new Object(); private static boolean taskFlag = false; @Scheduled(cron = "*/5 * * * * ?") public void pushCancel() { System.out.println("进来了"); synchronized (KEY) { if (TestCrontab.taskFlag) { System.out.println("测试调度已经启动"); log.warn("测试调度已经启动"); return; } TestCrontab.taskFlag = true; } try { for (int i =0;i<=10;i++){ System.out.println("执行:"+i); Thread.sleep(2000); } } catch (Exception e) { log.error("测试调度执行出错", e); } TestCrontab.taskFlag = false; log.warn("测试调度执行完成"); } }
注释掉synchronized
执行效果一样,并没有线程安全问题
package xyz.hashdog.job; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; /** * @author th * @description: 定时任务测试 * @projectName hashdog-ds * @date 2020/2/1223:07 */ @Component @Slf4j @AllArgsConstructor public class TestCrontab { private static final Object KEY = new Object(); private static boolean taskFlag = false; @Scheduled(cron = "*/5 * * * * ?") public void pushCancel() throws InterruptedException { System.out.println("进来了"); // synchronized (KEY) { // if (TestCrontab.taskFlag) { // System.out.println("测试调度已经启动"); // log.warn("测试调度已经启动"); // return; // } // TestCrontab.taskFlag = true; // } // // try { for (int i =0;i<=10;i++){ System.out.println("执行:"+i); Thread.sleep(2000); } // } catch (Exception e) { // log.error("测试调度执行出错", e); // } // // TestCrontab.taskFlag = false; log.warn("测试调度执行完成"); } }
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。