溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Spring task中怎么使用定時(shí)任務(wù)

發(fā)布時(shí)間:2021-08-05 17:02:43 來(lái)源:億速云 閱讀:197 作者:Leah 欄目:大數(shù)據(jù)

Spring task中怎么使用定時(shí)任務(wù),針對(duì)這個(gè)問(wèn)題,這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答,希望可以幫助更多想解決這個(gè)問(wèn)題的小伙伴找到更簡(jiǎn)單易行的方法。

使用

現(xiàn)在開(kāi)發(fā)都是基于 springboot,而在 springboot 中配置 spring task 尤為簡(jiǎn)單。

步驟如下:

  1. 準(zhǔn)備一個(gè) springboot 工程

  2. 在啟動(dòng)類上添加 @EnableScheduling 注解

    @SpringBootApplication
    @EnableScheduling
    public class DemoApplication {
    }


  3. 在定時(shí)執(zhí)行的方法上添加 @Scheduled(fixedDelay = 3 * 1000) 注解

    @Scheduled(fixedDelay = 3 *1 000)
    public void p1(){
    	System.out.println(Thread.currentThread().getName() + "  p1");
    }


注意: 第三步注解的屬性會(huì)在后面細(xì)講

@Scheduled 注解

在說(shuō)注解屬性之前, 需要了解下 Spring 定時(shí)器的三種工作模式。

1. fixedDelay

當(dāng)上一次的任務(wù)執(zhí)行完成之后, 再等 3 秒鐘, 執(zhí)行下一次任務(wù)。

示意圖如下:

Spring task中怎么使用定時(shí)任務(wù)

配置如下:

@Scheduled(fixedDelay = 3 * 1000)

2. fixedRate

會(huì)根據(jù)設(shè)置的值, 來(lái)預(yù)計(jì)每次任務(wù)應(yīng)該在什么時(shí)候執(zhí)行。

假定設(shè)置的值是 3 秒。那么每個(gè)任務(wù)預(yù)計(jì)執(zhí)行的時(shí)間就是 3 秒鐘, 定時(shí)任務(wù)在 7點(diǎn) 0分 0秒 開(kāi)始執(zhí)行。

示意圖如下:

Spring task中怎么使用定時(shí)任務(wù)

配置如下:

@Scheduled(fixedRate = 3 * 1000)

3. cron

假定設(shè)置的每 5 秒 執(zhí)行一次,會(huì)每隔 5 秒來(lái)看一下,上一個(gè)任務(wù)是否執(zhí)行完成。

示意圖如下:

Spring task中怎么使用定時(shí)任務(wù)

配置如下:

	@Scheduled(cron = "0/3 * * * * ? ")

思考

問(wèn)題

了解了 Spring 定時(shí)器的三種工作模式后,來(lái)思考一個(gè)問(wèn)題,如下面時(shí)序圖的定時(shí)功能?

Spring task中怎么使用定時(shí)任務(wù)

答案

默認(rèn)情況下,定時(shí)任務(wù)是由一個(gè)單線程執(zhí)行的。所以我們需要定義一個(gè)線程池去異步執(zhí)行定時(shí)任務(wù)。

具體步驟:

  1. 定義一個(gè)線程池

     @Configuration
     @EnableAsync
     public class SchedulerAsyncConfig {
    
     	@Bean
     	public Executor taskExecutor(){
     		ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
     		executor.setMaxPoolSize(200);
     		executor.setCorePoolSize(10);
     		executor.setQueueCapacity(10);
     		executor.initialize();
     		return executor;
     	}
    
     }


  2. 在定時(shí)任務(wù)上加上 @Async 注解。

     @Scheduled(fixedDelay = 10)
     @Async
     public void p1(){
     	System.out.println(Thread.currentThread().getName() + "  p1");
     }


關(guān)于 Spring task中怎么使用定時(shí)任務(wù)問(wèn)題的解答就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,如果你還有很多疑惑沒(méi)有解開(kāi),可以關(guān)注億速云行業(yè)資訊頻道了解更多相關(guān)知識(shí)。

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI