1. 程式人生 > >Springboot定時任務Scheduled重複執行

Springboot定時任務Scheduled重複執行

今天用scheduled寫定時任務的時候發現定時任務一秒重複執行一次,而我的cron表示式為 * 0/2 * * * * 。

在原始碼除錯的過程中,發現是我的定時任務執行過程太短導致的。

於是我另外寫了個簡單的定時任務

@Component
public class TestJob {
	@Scheduled(cron = "* 0/2 * * * *")
	public void test() {
		System.out.println("測試開始");
		System.out.println("測試結束");
	}
}

上述任務在啟動之後一直執行。

然後我在任務後面加入執行緒睡眠1分鐘。

@Component
public class TestJob {
	@Scheduled(cron = "* 0/2 * * * *")
	public void test() {
		System.out.println("測試開始");
		System.out.println("測試結束");
		try {
			Thread.sleep(60000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("睡眠結束");
	}
}

上述任務執行一次就沒有再執行了。

所以我繼續深入檢視原始碼,發現問題在於CronSequenceGenerator.class的next方法。

public Date next(Date date) {
        Calendar calendar = new GregorianCalendar();
        calendar.setTimeZone(this.timeZone);
        calendar.setTime(date);
	    //1.設定下次執行時間的毫秒為0,如上次任務執行過程不足1秒,則calendar的時間會被設定成上次任務的執行時間
        calendar.set(14, 0);
        long originalTimestamp = calendar.getTimeInMillis();
        this.doNext(calendar, calendar.get(1));
	    //2.由於有上面一步,執行時間太短,會導致下述條件為true
        if(calendar.getTimeInMillis() == originalTimestamp) {
	    //3.calendar在原來的時間上增加1秒
            calendar.add(13, 1);
	    //CronSequenceGenerator的doNext演算法從指定時間開始(包括指定時間)查詢符合cron表示式規則下一個匹配的時間
	    //注意第一個匹配符是*,由於增加了1秒,依然符合cron="* 0/2 * * * *",所以下一個執行時間就是在原來的基礎上增加了一秒
            this.doNext(calendar, calendar.get(1));
        }
        return calendar.getTime();
    }

請檢視程式碼中的註釋,由於任務執行時間太短了,程式碼會進入if語句,並設定執行時間在原來的基礎上增加一秒。

但由於增加一秒後的時間戳依然符合cron表示式,於是在執行完程式碼後一秒,任務又開始執行了。

解決辦法:

    程式執行時間太短沒有關係,只要cron表示式秒的匹配符不設定為*就可以了。

    cron表示式可以設定為"0 0/2 * * * *",這樣在執行到next方法中的doNext方法時就會發現時間增加1秒不符合cron表示式了,從而去尋找下一個合適的執行時間。

CronSequenceGenerator類參考:https://blog.csdn.net/ukulelepku/article/details/54310035