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運算式
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/247487.html
標籤：Java
上一篇：C++面向物件：C++ 多型
下一篇：【對線面試官】Java NIO