SpringBoot ThreadPoolTaskScheduler 定時任務 多線程執行 demo

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表達式

// Update 2021年1月12日 增加Demo
Demo