java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > Scheduled会在上次任务执行完才会执行下次任务

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("测试调度执行完成");
    }


}

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文