1. pom檔案

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.3.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <groupId>com.demo</groupId>
    <artifactId>springboot-scheduler-demo</artifactId>
    <version>1.0.0</version>

    <properties>
        <lombok.version>1.18.12</lombok.version>
    </properties>

    <dependencies>
        <!--web 模組-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!--  lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
            <scope>provided</scope>
            <version>${lombok.version}</version>
        </dependency>
    </dependencies>

</project>
 

2. SchedulerApplication.java

啟動類

@SpringBootApplication
@EnableScheduling
public class SchedulerApplication {
    public static void main(String[] args) {
        SpringApplication.run(SchedulerApplication.class, args);
    }
}

新增@EnableScheduling註解，啟用定時任務。

3. SchedulerConfig.java

定時任務配置類

@Configuration
@EnableAsync
public class SchedulerConfig {

    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 設定執行緒名稱字首，預設為方法名（此處為taskExecutor）
        //executor.setThreadNamePrefix("task-");
        // 核心執行緒數
        executor.setCorePoolSize(10);
        // 最大執行緒數
        executor.setMaxPoolSize(100);
        // 等待佇列容量
        executor.setQueueCapacity(50);
        // 空閒執行緒存活時間（單位：s）
        executor.setKeepAliveSeconds(300);
        executor.initialize();
        return executor;
    }
 

新增@EnableAsync註解，啟用多執行緒。

執行緒池不同情況說明：

• 若執行緒數 < corePoolSize，即使執行緒池中的執行緒都處於空閒狀態，也要建立新的執行緒來處理被新增的任務。
• 若執行緒數 = corePoolSize，但是緩衝佇列workQueue未滿，那麼任務被放入緩衝佇列。
• 若執行緒數 > corePoolSize，緩衝佇列workQueue滿，並且執行緒數 < maxPoolSize，建立新的執行緒來處理被新增的任務。
• 若執行緒數 > corePoolSize，緩衝佇列workQueue滿，並且執行緒數 = maxPoolSize，那麼通過handler所指定的策略來處理此任務。
  處理任務的優先順序為：核心執行緒corePoolSize、任務佇列workQueue、最大執行緒maximumPoolSize。如果三者都滿了，使用handler處理被拒絕的任務。
• 若執行緒數 > corePoolSize時，如果某執行緒空閒時間超過keepAliveTime，執行緒將被終止。

4. TestScheduler.java

具體定時任務執行類

@Slf4j
@Component
@Async
public class TestScheduler {

    @Scheduled(cron = "0/3 * * * * *")
    public void test() {
        log.info("執行定時任務test1");
    }

    @Scheduled(cron = "0/6 * * * * *")
    public void test2() {
        log.info("執行定時任務test2");
    }
}

在類上新增@Async註解，類中的所有方法都會使用多執行緒執行任務。
類上不新增，方法上新增@Async，僅新增過@Async的方法會使用多執行緒執行任務。

5. cron表示式

@Scheduled cron表示式