Java spring定時(shí)任務(wù)詳解

更新時(shí)間：2021年10月04日 14:05:36 作者：會(huì)飛的小蝸

這篇文章主要為大家詳細(xì)介紹了Spring定時(shí)任務(wù)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下,希望能夠給你帶來幫助

一、定時(shí)任務(wù)

1、cron表達(dá)式

語法：秒分時(shí) 日月周年

（其中“年”Spring不支持，也就是說在spring定時(shí)任務(wù)中只能設(shè)置：秒分時(shí) 日月周）

在這里插入圖片描述

2、cron示例

在這里插入圖片描述

3、SpringBoot整合

@EnableScheduling

@Scheduled

實(shí)例：

package com.xunqi.gulimall.seckill.scheduled;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
/**
 * @Description:
 * @Created: with IntelliJ IDEA.
 * @author: 夏沫止水
 * @createTime: 2020-07-09 18:49
 **/
/**
 * 定時(shí)任務(wù)
 *      1、@EnableScheduling 開啟定時(shí)任務(wù)
 *      2、@Scheduled開啟一個(gè)定時(shí)任務(wù)
 *
 * 異步任務(wù)
 *      1、@EnableAsync:開啟異步任務(wù)
 *      2、@Async：給希望異步執(zhí)行的方法標(biāo)注
 */
@Slf4j
@Component
@EnableScheduling
public class HelloScheduled {
    /**
     * 1、在Spring中表達(dá)式是6位組成，不允許第七位的年份
     * 2、在周幾的的位置,1-7代表周一到周日
     * 3、定時(shí)任務(wù)不該阻塞。默認(rèn)是阻塞的
     *      1）、可以讓業(yè)務(wù)以異步的方式，自己提交到線程池
     *              CompletableFuture.runAsync(() -> {
     *         },execute);
     *
     *      2）、支持定時(shí)任務(wù)線程池；設(shè)置 TaskSchedulingProperties
     *        spring.task.scheduling.pool.size: 5
     *
     *      3）、讓定時(shí)任務(wù)異步執(zhí)行
     *          異步任務(wù)
     *
     *      解決：使用異步任務(wù) + 定時(shí)任務(wù)來完成定時(shí)任務(wù)不阻塞的功能
     *
     */
     @Scheduled(cron = "*/1 * * * * ?")
     public void hello() {
         log.info("hello...");
         try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }
     }
}

定時(shí)任務(wù)默認(rèn)是阻塞的線程，也就是說即使你設(shè)置成每一秒執(zhí)行一次，但是方法內(nèi)部的業(yè)務(wù)時(shí)間需要5秒才能執(zhí)行完，也會(huì)造成定時(shí)任務(wù)每6秒才能執(zhí)行一次。

當(dāng)然我們可以開啟異步線程：

@EnableAsync

@Async

實(shí)例：

package com.xunqi.gulimall.seckill.scheduled;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
/**
 * @Description:
 * @Created: with IntelliJ IDEA.
 * @author: 夏沫止水
 * @createTime: 2020-07-09 18:49
 **/
/**
 * 定時(shí)任務(wù)
 *      1、@EnableScheduling 開啟定時(shí)任務(wù)
 *      2、@Scheduled開啟一個(gè)定時(shí)任務(wù)
 *
 * 異步任務(wù)
 *      1、@EnableAsync:開啟異步任務(wù)
 *      2、@Async：給希望異步執(zhí)行的方法標(biāo)注
 */
@Slf4j
@Component
@EnableAsync
@EnableScheduling
public class HelloScheduled {
    /**
     * 1、在Spring中表達(dá)式是6位組成，不允許第七位的年份
     * 2、在周幾的的位置,1-7代表周一到周日
     * 3、定時(shí)任務(wù)不該阻塞。默認(rèn)是阻塞的
     *      1）、可以讓業(yè)務(wù)以異步的方式，自己提交到線程池
     *              CompletableFuture.runAsync(() -> {
     *         },execute);
     *
     *      2）、支持定時(shí)任務(wù)線程池；設(shè)置 TaskSchedulingProperties
     *        spring.task.scheduling.pool.size: 5
     *
     *      3）、讓定時(shí)任務(wù)異步執(zhí)行
     *          異步任務(wù)
     *
     *      解決：使用異步任務(wù) + 定時(shí)任務(wù)來完成定時(shí)任務(wù)不阻塞的功能
     *
     */
     @Async
     @Scheduled(cron = "*/1 * * * * ?")
     public void hello() {
         log.info("hello...");
         try { TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { e.printStackTrace(); }
     }
}

這樣就會(huì)開啟異步線程，并且是非阻塞線程，因?yàn)槊看味紩?huì)開啟一個(gè)線程來執(zhí)行，我們可以看一下源碼配置的截圖，這個(gè)就是異步執(zhí)行的默認(rèn)配置，核心線程數(shù)是8，最大線程數(shù)是無限大，這時(shí)如果一直每秒執(zhí)行一次，則會(huì)造成服務(wù)器資源耗盡。

在這里插入圖片描述