SpringBoot實(shí)現(xiàn)定時(shí)任務(wù)的三種方式小結(jié)

更新時(shí)間：2021年11月01日 11:12:19 作者：程序員阿九不喝酒

這篇文章主要介紹了SpringBoot實(shí)現(xiàn)定時(shí)任務(wù)的三種方式小結(jié)，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

定時(shí)任務(wù)實(shí)現(xiàn)的三種方式

Timer：這是java自帶的java.util.Timer類，這個(gè)類允許你調(diào)度一個(gè)java.util.TimerTask任務(wù)。使用這種方式可以讓你的程序按照某一個(gè)頻度執(zhí)行，但不能在指定時(shí)間運(yùn)行。一般用的較少。
ScheduledExecutorService：也jdk自帶的一個(gè)類；是基于線程池設(shè)計(jì)的定時(shí)任務(wù)類,每個(gè)調(diào)度任務(wù)都會(huì)分配到線程池中的一個(gè)線程去執(zhí)行,也就是說,任務(wù)是并發(fā)執(zhí)行,互不影響。
Spring Task：Spring3.0以后自帶的task，可以將它看成一個(gè)輕量級(jí)的Quartz，而且使用起來比Quartz簡單許多。

使用Timer

這個(gè)目前在項(xiàng)目中用的較少，直接貼demo代碼。具體的介紹可以查看api

public class TestTimer {
    public static void main(String[] args) {
        TimerTask timerTask = new TimerTask() {
            @Override
            public void run() {
                System.out.println("task  run:"+ new Date());
            }
        };
        Timer timer = new Timer();
        //安排指定的任務(wù)在指定的時(shí)間開始進(jìn)行重復(fù)的固定延遲執(zhí)行。這里是每3秒執(zhí)行一次
        timer.schedule(timerTask,10,3000);
    }
}

使用ScheduledExecutorService

該方法跟Timer類似，直接看demo：

public class TestScheduledExecutorService {
    public static void main(String[] args) {
        ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
        // 參數(shù)：1、任務(wù)體 2、首次執(zhí)行的延時(shí)時(shí)間
        //      3、任務(wù)執(zhí)行間隔 4、間隔時(shí)間單位
        service.scheduleAtFixedRate(()->System.out.println("task ScheduledExecutorService "+new Date()), 0, 3, TimeUnit.SECONDS);
    }
}

使用Spring Task

1.簡單的定時(shí)任務(wù)

在SpringBoot項(xiàng)目中，我們可以很優(yōu)雅的使用注解來實(shí)現(xiàn)定時(shí)任務(wù)，首先創(chuàng)建項(xiàng)目，導(dǎo)入依賴：

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
  </dependency>
  <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
  </dependency>
</dependencies>

創(chuàng)建任務(wù)類：

@Slf4j
@Component
public class ScheduledService {
    @Scheduled(cron = "0/5 * * * * *")
    public void scheduled(){
        log.info("=====>>>>>使用cron  {}",System.currentTimeMillis());
    }
    @Scheduled(fixedRate = 5000)
    public void scheduled1() {
        log.info("=====>>>>>使用fixedRate{}", System.currentTimeMillis());
    }
    @Scheduled(fixedDelay = 5000)
    public void scheduled2() {
        log.info("=====>>>>>fixedDelay{}",System.currentTimeMillis());
    }
}

在主類上使用@EnableScheduling注解開啟對(duì)定時(shí)任務(wù)的支持，然后啟動(dòng)項(xiàng)目

可以看到三個(gè)定時(shí)任務(wù)都已經(jīng)執(zhí)行，并且使同一個(gè)線程中串行執(zhí)行，如果只有一個(gè)定時(shí)任務(wù)，這樣做肯定沒問題，當(dāng)定時(shí)任務(wù)增多，如果一個(gè)任務(wù)卡死，會(huì)導(dǎo)致其他任務(wù)也無法執(zhí)行。

2.多線程執(zhí)行

在傳統(tǒng)的Spring項(xiàng)目中，我們可以在xml配置文件添加task的配置，而在SpringBoot項(xiàng)目中一般使用config配置類的方式添加配置，所以新建一個(gè)AsyncConfig類

@Configuration
@EnableAsync
public class AsyncConfig {
     /*
    此處成員變量應(yīng)該使用@Value從配置中讀取
     */
    private int corePoolSize = 10;
    private int maxPoolSize = 200;
    private int queueCapacity = 10;
    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(corePoolSize);
        executor.setMaxPoolSize(maxPoolSize);
        executor.setQueueCapacity(queueCapacity);
        executor.initialize();
        return executor;
    }
}