Spring boot如何通過@Scheduled實現(xiàn)定時任務(wù)及多線程配置
更新時間：2019年12月02日 10:09:09 作者：慕塵
這篇文章主要介紹了Spring boot如何通過@Scheduled實現(xiàn)定時任務(wù)及多線程配置,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
這篇文章主要介紹了Spring boot如何通過@Scheduled實現(xiàn)定時任務(wù)及多線程配置,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
使用@Scheduled 可以很容易實現(xiàn)定時任務(wù)
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任務(wù)開始,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任務(wù)正在運行的線程名稱：" + thread.getName() + " 結(jié)束,start=" + simpleDateFormat.format(timeStamp) + ",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任務(wù)開始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
try {
TimeUnit.SECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
long endStamp = System.currentTimeMillis();
System.out.println("cron2任務(wù)正在運行的線程名稱：" + thread.getName() + " 結(jié)束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
System.out.println("====================");
} catch (Exception e) {
logger.error(e.getMessage());
}
}
}
運行輸出內(nèi)容為
cron2任務(wù)開始,start=2019-10-11 17:31:52, threadId=34, threadName=scheduling-1 cron2任務(wù)正在運行的線程名稱：scheduling-1 結(jié)束,start=2019-10-11 17:31:52,end=2019-10-11 17:32:02 ==================== cron1任務(wù)開始,start=2019-10-11 17:32:02, threadId=34, threadName=scheduling-1 cron1任務(wù)正在運行的線程名稱：scheduling-1 結(jié)束,start=2019-10-11 17:32:02,end=2019-10-11 17:32:02 ++++++++++++++++++++++++ cron2任務(wù)開始,start=2019-10-11 17:32:22, threadId=34, threadName=scheduling-1 cron2任務(wù)正在運行的線程名稱：scheduling-1 結(jié)束,start=2019-10-11 17:32:22,end=2019-10-11 17:32:32 ……
注：
cron2執(zhí)行完后才會執(zhí)行cron1
原因：
spring默認(rèn)是以單線程執(zhí)行任務(wù)調(diào)度
spring的定時任務(wù)默認(rèn)最大運行線程數(shù)為1，多個任務(wù)執(zhí)行起來時間會有問題
1.配置線程池
在配置文件application.properties中添加
# 線程池大小 spring.task.scheduling.pool.size=5 # 線程名前綴 spring.task.scheduling.thread-name-prefix=myScheduling-
輸出內(nèi)容變?yōu)?/p>
cron2任務(wù)開始,start=2019-10-11 17:34:48, threadId=34, threadName=myScheduling-1 cron1任務(wù)開始,start=2019-10-11 17:34:49, threadId=35, threadName=myScheduling-2 cron2任務(wù)正在運行的線程名稱：myScheduling-1 結(jié)束,start=2019-10-11 17:34:48,end=2019-10-11 17:34:58 ==================== cron2任務(wù)開始,start=2019-10-11 17:34:58, threadId=34, threadName=myScheduling-1 cron2任務(wù)正在運行的線程名稱：myScheduling-1 結(jié)束,start=2019-10-11 17:34:58,end=2019-10-11 17:35:08 ==================== cron2任務(wù)開始,start=2019-10-11 17:35:08, threadId=57, threadName=myScheduling-3 cron1任務(wù)正在運行的線程名稱：myScheduling-2 結(jié)束,start=2019-10-11 17:34:49,end=2019-10-11 17:34:49 ……
注：
多線程下，cron1和cron2不用互相等待了，但是同一個任務(wù)還是需要等待的
2.并發(fā)
修改代碼
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, 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任務(wù)開始,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任務(wù)正在運行的線程名稱：" + thread.getName() + " 結(jié)束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
System.out.println("++++++++++++++++++++++++");
} catch (Exception e) {
logger.error(e.getMessage());
}
}
@Async
@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任務(wù)開始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
try {
TimeUnit.SECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
long endStamp = System.currentTimeMillis();
System.out.println("cron2任務(wù)正在運行的線程名稱：" + thread.getName() + " 結(jié)束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
System.out.println("====================");
} catch (Exception e) {
logger.error(e.getMessage());
}
}
}
輸出的內(nèi)容
cron2任務(wù)開始,start=2019-10-11 17:39:53, threadId=57, threadName=task-1 cron1任務(wù)開始,start=2019-10-11 17:39:54, threadId=59, threadName=task-2 cron2任務(wù)開始,start=2019-10-11 17:39:58, threadId=61, threadName=task-3 cron2任務(wù)開始,start=2019-10-11 17:40:03, threadId=63, threadName=task-4 cron2任務(wù)正在運行的線程名稱：task-1 結(jié)束,start=2019-10-11 17:39:53,end=2019-10-11 17:40:03 ==================== cron1任務(wù)開始,start=2019-10-11 17:40:04, threadId=64, threadName=task-5 cron2任務(wù)開始,start=2019-10-11 17:40:08, threadId=65, threadName=task-6 cron2任務(wù)正在運行的線程名稱：task-3 結(jié)束,start=2019-10-11 17:39:58,end=2019-10-11 17:40:08 ==================== cron2任務(wù)開始,start=2019-10-11 17:40:13, threadId=66, threadName=task-7 cron2任務(wù)正在運行的線程名稱：task-4 結(jié)束,start=2019-10-11 17:40:03,end=2019-10-11 17:40:13 ==================== cron1任務(wù)正在運行的線程名稱：task-2 結(jié)束,start=2019-10-11 17:39:54,end=2019-10-11 17:39:54
說明：
- @EnableAsync開啟多線程
- @Async標(biāo)記其為一個異步任務(wù)
- 每個定時任務(wù)都是在通過不同的線程來處理，線程名的前綴成了task-
- 線程默認(rèn)為10個
修改配置
spring.task.execution.thread-name-prefix=mytask- spring.task.execution.pool.core-size=5
重新運行的輸出
cron2任務(wù)開始,start=2019-10-11 17:44:00, threadId=56, threadName=mytask-1 cron1任務(wù)開始,start=2019-10-11 17:44:01, threadId=57, threadName=mytask-2 cron2任務(wù)開始,start=2019-10-11 17:44:05, threadId=58, threadName=mytask-3 cron2任務(wù)開始,start=2019-10-11 17:44:10, threadId=59, threadName=mytask-4 cron2任務(wù)正在運行的線程名稱：mytask-1 結(jié)束,start=2019-10-11 17:44:00,end=2019-10-11 17:44:10 ==================== cron1任務(wù)開始,start=2019-10-11 17:44:11, threadId=60, threadName=mytask-5 cron2任務(wù)正在運行的線程名稱：mytask-3 結(jié)束,start=2019-10-11 17:44:05,end=2019-10-11 17:44:15 ==================== cron2任務(wù)開始,start=2019-10-11 17:44:15, threadId=58, threadName=mytask-3 cron2任務(wù)開始,start=2019-10-11 17:44:20, threadId=56, threadName=mytask-1 cron2任務(wù)正在運行的線程名稱：mytask-4 結(jié)束,start=2019-10-11 17:44:10,end=2019-10-11 17:44:20 ==================== cron1任務(wù)正在運行的線程名稱：mytask-2 結(jié)束,start=2019-10-11 17:44:01,end=2019-10-11 17:44:01
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:
- springboot定時任務(wù)@Scheduled執(zhí)行多次的問題
- SpringBoot執(zhí)行定時任務(wù)@Scheduled的方法
- spring-boot通過@Scheduled配置定時任務(wù)及定時任務(wù)@Scheduled注解的方法
- 詳解Spring Boot中使用@Scheduled創(chuàng)建定時任務(wù)
- Spring Boot利用@Async異步調(diào)用：ThreadPoolTaskScheduler線程池的優(yōu)雅關(guān)閉詳解
- spring?boot?使用?@Scheduled?注解和?TaskScheduler?接口實現(xiàn)定時任務(wù)
相關(guān)文章
本文通過實例代碼給大家介紹了java io流文件編碼的方法，非常不錯，具有參考借鑒價值，需要的朋友參考下吧2017-05-05
SpringBoot實現(xiàn)服務(wù)接入nacos注冊中心流程詳解
這篇文章主要介紹了SpringBoot實現(xiàn)服務(wù)接入nacos注冊中心流程，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)吧2023-01-01
這篇文章主要介紹了Java計算兩個時間相差的秒數(shù),通過實例代碼補充介紹了Java 獲取兩個時間的時間差(時、分、秒)問題,感興趣的朋友跟隨小編一起看看吧2024-03-03
這篇文章主要為大家分享了Java五子棋單機版源碼，JavaGUI編寫單機版五子棋，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-03-03
本文介紹了如何在MyBatis-Plus中實現(xiàn)自動填充時間的功能,通過實現(xiàn)MetaObjectHandler接口,重寫insertFill()和updateFill()方法,分別在插入和更新時填充創(chuàng)建時間和更新時間,感興趣的可以了解一下2024-12-12
ZooKeeper官方提供了Java API,可以通過Java代碼來連接zookeeper服務(wù)進行操作,本文就來介紹一下java連接zookeeper的實現(xiàn)示例,具有一定的參考價值,感興趣的可以了解一下2023-11-11
關(guān)于feign.codec.DecodeException異常的解決方案
這篇文章主要介紹了關(guān)于feign.codec.DecodeException異常的解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03
idea使用帶provide修飾依賴導(dǎo)致ClassNotFound
程序打包到Linux上運行時,若Linux上也有這些依賴,為了在Linux上運行時避免依賴沖突,可以使用provide修飾,本文主要介紹了idea使用帶provide修飾依賴導(dǎo)致ClassNotFound,下面就來介紹一下解決方法,感興趣的可以了解一下2024-01-01
這篇文章主要介紹了Java System.exit()退出程序方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-06-06
限流是對某一時間窗口內(nèi)的請求數(shù)進行限制,保持系統(tǒng)的可用性和穩(wěn)定性,防止因流量暴增而導(dǎo)致的系統(tǒng)運行緩慢或宕機,本文主要來和大家聊聊如何使用java實現(xiàn)限流接口,感興趣的可以了解下2023-12-12