Spring boot如何通過@Scheduled實現定時任務及多執行緒配置
阿新 • • 發佈：2020-01-07
這篇文章主要介紹了Spring boot如何通過@Scheduled實現定時任務及多執行緒配置,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
使用@Scheduled 可以很容易實現定時任務
spring boot的版本 2.1.6.RELEASE
package com.abc.demo.common;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.concurrent.TimeUnit;
@EnableScheduling
@Component
public class ScheduleSetting {
private final Logger logger = LoggerFactory.getLogger(Tasks.class);
@Scheduled(fixedRate = 10000,initialDelay = 2000)
public void scheduleRead() {
try {
long timeStamp = System.currentTimeMillis();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Thread thread = Thread.currentThread();
System.out.println("cron1任務開始,start=" + simpleDateFormat.format(timeStamp) + ",threadId=" + thread.getId() + ",threadName=" + thread.getName());
long endStamp = System.currentTimeMillis();
try {
TimeUnit.SECONDS.sleep(20);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("cron1任務正在執行的執行緒名稱：" + thread.getName() + " 結束,end=" + simpleDateFormat.format(endStamp));
System.out.println("++++++++++++++++++++++++");
} catch (Exception e) {
logger.error(e.getMessage());
}
}
@Scheduled(fixedRate = 5000,initialDelay = 1000)
public void scheduleConvert() {
try {
long timeStamp = System.currentTimeMillis();
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
Thread thread = Thread.currentThread();
System.out.println("cron2任務開始,threadName=" + thread.getName());
try {
TimeUnit.SECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
long endStamp = System.currentTimeMillis();
System.out.println("cron2任務正在執行的執行緒名稱：" + thread.getName() + " 結束,end=" + simpleDateFormat.format(endStamp));
System.out.println("====================");
} catch (Exception e) {
logger.error(e.getMessage());
}
}
}執行輸出內容為
cron2任務開始,start=2019-10-11 17:31:52,threadId=34,threadName=scheduling-1 cron2任務正在執行的執行緒名稱：scheduling-1 結束,end=2019-10-11 17:32:02 ==================== cron1任務開始,start=2019-10-11 17:32:02,threadName=scheduling-1 cron1任務正在執行的執行緒名稱：scheduling-1 結束,end=2019-10-11 17:32:02 ++++++++++++++++++++++++ cron2任務開始,start=2019-10-11 17:32:22,end=2019-10-11 17:32:32 ……
注：
cron2執行完後才會執行cron1
原因：
spring預設是以單執行緒執行任務排程
spring的定時任務預設最大執行執行緒數為1，多個任務執行起來時間會有問題
1.配置執行緒池
在配置檔案application.properties中新增
# 執行緒池大小 spring.task.scheduling.pool.size=5 # 執行緒名字首 spring.task.scheduling.thread-name-prefix=myScheduling-
輸出內容變為
cron2任務開始,start=2019-10-11 17:34:48,threadName=myScheduling-1 cron1任務開始,start=2019-10-11 17:34:49,threadId=35,threadName=myScheduling-2 cron2任務正在執行的執行緒名稱：myScheduling-1 結束,end=2019-10-11 17:34:58 ==================== cron2任務開始,start=2019-10-11 17:34:58,threadName=myScheduling-1 cron2任務正在執行的執行緒名稱：myScheduling-1 結束,end=2019-10-11 17:35:08 ==================== cron2任務開始,start=2019-10-11 17:35:08,threadId=57,threadName=myScheduling-3 cron1任務正在執行的執行緒名稱：myScheduling-2 結束,end=2019-10-11 17:34:49 ……
注：
多執行緒下，cron1和cron2不用互相等待了，但是同一個任務還是需要等待的
2.併發
修改程式碼
package com.abc.demo.common;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.concurrent.TimeUnit;
@EnableScheduling
@Component
@EnableAsync
public class ScheduleSetting {
private final Logger logger = LoggerFactory.getLogger(Tasks.class);
@Async
@Scheduled(fixedRate = 10000,end=" + simpleDateFormat.format(endStamp));
System.out.println("++++++++++++++++++++++++");
} catch (Exception e) {
logger.error(e.getMessage());
}
}
@Async
@Scheduled(fixedRate = 5000,end=" + simpleDateFormat.format(endStamp));
System.out.println("====================");
} catch (Exception e) {
logger.error(e.getMessage());
}
}
}
輸出的內容
cron2任務開始,start=2019-10-11 17:39:53,threadName=task-1 cron1任務開始,start=2019-10-11 17:39:54,threadId=59,threadName=task-2 cron2任務開始,start=2019-10-11 17:39:58,threadId=61,threadName=task-3 cron2任務開始,start=2019-10-11 17:40:03,threadId=63,threadName=task-4 cron2任務正在執行的執行緒名稱：task-1 結束,end=2019-10-11 17:40:03 ==================== cron1任務開始,start=2019-10-11 17:40:04,threadId=64,threadName=task-5 cron2任務開始,start=2019-10-11 17:40:08,threadId=65,threadName=task-6 cron2任務正在執行的執行緒名稱：task-3 結束,end=2019-10-11 17:40:08 ==================== cron2任務開始,start=2019-10-11 17:40:13,threadId=66,threadName=task-7 cron2任務正在執行的執行緒名稱：task-4 結束,end=2019-10-11 17:40:13 ==================== cron1任務正在執行的執行緒名稱：task-2 結束,end=2019-10-11 17:39:54
說明：
- @EnableAsync開啟多執行緒
- @Async標記其為一個非同步任務
- 每個定時任務都是在通過不同的執行緒來處理，執行緒名的字首成了task-
- 執行緒預設為10個
修改配置
spring.task.execution.thread-name-prefix=mytask- spring.task.execution.pool.core-size=5
重新執行的輸出
cron2任務開始,start=2019-10-11 17:44:00,threadId=56,threadName=mytask-1 cron1任務開始,start=2019-10-11 17:44:01,threadName=mytask-2 cron2任務開始,start=2019-10-11 17:44:05,threadId=58,threadName=mytask-3 cron2任務開始,start=2019-10-11 17:44:10,threadName=mytask-4 cron2任務正在執行的執行緒名稱：mytask-1 結束,end=2019-10-11 17:44:10 ==================== cron1任務開始,start=2019-10-11 17:44:11,threadId=60,threadName=mytask-5 cron2任務正在執行的執行緒名稱：mytask-3 結束,end=2019-10-11 17:44:15 ==================== cron2任務開始,start=2019-10-11 17:44:15,start=2019-10-11 17:44:20,threadName=mytask-1 cron2任務正在執行的執行緒名稱：mytask-4 結束,end=2019-10-11 17:44:20 ==================== cron1任務正在執行的執行緒名稱：mytask-2 結束,end=2019-10-11 17:44:01
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。