Springboot集成定時(shí)器和多線程異步處理操作
更新時(shí)間：2020年09月30日 10:04:04 作者：PascalLee
這篇文章主要介紹了Springboot集成定時(shí)器和多線程異步處理操作，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
需求:用@schedule標(biāo)簽進(jìn)行定時(shí)處理邏輯,由于業(yè)務(wù)處理速度慢,需要每次執(zhí)行邏輯放在不同的線程里異步執(zhí)行
springboot集成多線程異步,直接上配置:
/**
* 線程池異步配置
*/
@Configuration
@EnableAsync
public class ThreadExecutorConfig
implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 設(shè)置核心線程數(shù)
executor.setCorePoolSize(5);
// 設(shè)置最大線程數(shù)
executor.setMaxPoolSize(7);
// 設(shè)置隊(duì)列容量
executor.setQueueCapacity(20);
// 設(shè)置線程活躍時(shí)間（秒）
executor.setKeepAliveSeconds(60);
// 設(shè)置默認(rèn)線程名稱
executor.setThreadNamePrefix("PASCAL-");
// 設(shè)置拒絕策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 等待所有任務(wù)結(jié)束后再關(guān)閉線程池
executor.setWaitForTasksToCompleteOnShutdown(true);
executor.initialize();
return executor;
}
@Override
public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
return new MyAsyncUncaughtExceptionHandler();
}
}
下面的是對(duì)多線程異步的時(shí)候報(bào)出的異常處理方法,可以自定義一個(gè)處理多線程異常類來(lái)實(shí)現(xiàn)自身的業(yè)務(wù)邏輯.
import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import java.lang.reflect.Method;
public class MyAsyncUncaughtExceptionHandler implements
AsyncUncaughtExceptionHandler {
@Override
public void handleUncaughtException(Throwable ex,
Method method, Object... params) {
// handle exception
}
}
啟動(dòng)類上要記得添加異步和開(kāi)啟定時(shí)器的標(biāo)簽
@SpringBootApplication
@EnableScheduling
@Async
public class MultithreadingApplication {
public static void main(String[] args) {
SpringApplication.run(MultithreadingApplication.class, args);
}
}
業(yè)務(wù)邏輯方法:
@Async
@Scheduled(initialDelay=1000,fixedDelay = 5000)
public void test(){
SimpleDateFormat format=new SimpleDateFormat("HH:mm:ss");
try {
logger.info("當(dāng)前線程為:"+Thread.currentThread().getName()+",方法開(kāi)始時(shí)間為:"+format.format(new Date()));
Thread.sleep(10000);
logger.info("當(dāng)前線程為:"+Thread.currentThread().getName()+",方法結(jié)束時(shí)間為:"+format.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
對(duì)于@Schedule注解的使用方法:
點(diǎn)進(jìn)去可以看到有幾個(gè)可選參數(shù):
fixedDelay:控制方法執(zhí)行的間隔時(shí)間，是以上一次方法執(zhí)行完開(kāi)始算起，如上一次方法執(zhí)行阻塞住了，那么直到上一次執(zhí)行完，并間隔給定的時(shí)間后，執(zhí)行下一次
fixedRate:是按照一定的速率執(zhí)行，是從上一次方法執(zhí)行開(kāi)始的時(shí)間算起，如果上一次方法阻塞住了，下一次也是不會(huì)執(zhí)行，但是在阻塞這段時(shí)間內(nèi)累計(jì)應(yīng)該執(zhí)行的次數(shù)，當(dāng)不再阻塞時(shí)，一下子把這些全部執(zhí)行掉，而后再按照固定速率繼續(xù)執(zhí)行。
initialDelay:如： @Scheduled(initialDelay = 10000,fixedRate = 15000
這個(gè)定時(shí)器就是在上一個(gè)的基礎(chǔ)上加了一個(gè)initialDelay = 10000 意思就是在容器啟動(dòng)后,延遲10秒后再執(zhí)行一次定時(shí)器,以后每15秒再執(zhí)行一次該定時(shí)器.
cron表達(dá)式可以定制化執(zhí)行任務(wù)，但是執(zhí)行的方式是與fixedDelay相近的，也是會(huì)按照上一次方法結(jié)束時(shí)間開(kāi)始算起。
這里可以根據(jù)自身的業(yè)務(wù)需求,看到底選擇哪一個(gè)更適合,這里cron表達(dá)式就不再多言,可以結(jié)合自身應(yīng)用場(chǎng)景來(lái)定
這樣,需求就實(shí)現(xiàn)了
測(cè)試結(jié)果:
20-07-07 11:12:40.436 INFO 32360 --- [ main] o.s.b.w.embedded.tomcat.TomcatWebServer : Tomcat started on port(s): 8081 (http) with context path '' 2020-07-07 11:12:40.444 INFO 32360 --- [ main] c.e.m.MultithreadingApplication : Started MultithreadingApplication in 1.223 seconds (JVM running for 1.739) 2020-07-07 11:12:41.445 INFO 32360 --- [ scheduling-1] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService 2020-07-07 11:12:41.452 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-1,方法開(kāi)始時(shí)間為:11:12:41 2020-07-07 11:12:46.448 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-2,方法開(kāi)始時(shí)間為:11:12:46 2020-07-07 11:12:51.450 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-3,方法開(kāi)始時(shí)間為:11:12:51 2020-07-07 11:12:51.453 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-1,方法結(jié)束時(shí)間為:11:12:51 2020-07-07 11:12:56.449 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-2,方法結(jié)束時(shí)間為:11:12:56 2020-07-07 11:12:56.450 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-4,方法開(kāi)始時(shí)間為:11:12:56 2020-07-07 11:13:01.450 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-3,方法結(jié)束時(shí)間為:11:13:01 2020-07-07 11:13:01.452 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-5,方法開(kāi)始時(shí)間為:11:13:01 2020-07-07 11:13:06.451 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-4,方法結(jié)束時(shí)間為:11:13:06 2020-07-07 11:13:06.453 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-1,方法開(kāi)始時(shí)間為:11:13:06 2020-07-07 11:13:11.453 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-5,方法結(jié)束時(shí)間為:11:13:11 2020-07-07 11:13:11.455 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-2,方法開(kāi)始時(shí)間為:11:13:11 2020-07-07 11:13:16.453 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-1,方法結(jié)束時(shí)間為:11:13:16 2020-07-07 11:13:16.455 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-3,方法開(kāi)始時(shí)間為:11:13:16 2020-07-07 11:13:21.456 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-2,方法結(jié)束時(shí)間為:11:13:21 2020-07-07 11:13:21.457 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-4,方法開(kāi)始時(shí)間為:11:13:21 2020-07-07 11:13:26.456 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-3,方法結(jié)束時(shí)間為:11:13:26 2020-07-07 11:13:26.457 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-5,方法開(kāi)始時(shí)間為:11:13:26 2020-07-07 11:13:31.458 INFO 32360 --- [ PASCAL-4] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-4,方法結(jié)束時(shí)間為:11:13:31 2020-07-07 11:13:31.459 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-1,方法開(kāi)始時(shí)間為:11:13:31 2020-07-07 11:13:36.458 INFO 32360 --- [ PASCAL-5] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-5,方法結(jié)束時(shí)間為:11:13:36 2020-07-07 11:13:36.460 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-2,方法開(kāi)始時(shí)間為:11:13:36 2020-07-07 11:13:41.459 INFO 32360 --- [ PASCAL-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-1,方法結(jié)束時(shí)間為:11:13:41 2020-07-07 11:13:41.462 INFO 32360 --- [ PASCAL-3] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-3,方法開(kāi)始時(shí)間為:11:13:41 2020-07-07 11:13:46.461 INFO 32360 --- [ PASCAL-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:PASCAL-2,方法結(jié)束時(shí)間為:11:13:46
每隔五秒執(zhí)行一次
-----------------------分割線-----------------------
如果有多個(gè)定時(shí)任務(wù),每個(gè)任務(wù)需要在不同的線程間處理的話,就要用另外的配置:如下:
/**
* 配置多個(gè)schedule的線程配置
*/
@Configuration
@EnableScheduling
public class ScheduleConfig implements SchedulingConfigurer{
/*
* 并行任務(wù)
*/
public void configureTasks(ScheduledTaskRegistrar taskRegistrar)
{
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setThreadNamePrefix("Schedule-Task-");
taskScheduler.setPoolSize(5);
taskScheduler.setAwaitTerminationSeconds(60);
taskScheduler.setWaitForTasksToCompleteOnShutdown(true);
taskScheduler.initialize();
taskRegistrar.setTaskScheduler(taskScheduler);
}
}
業(yè)務(wù)如下:
@Scheduled(cron = "*/5 * * * * ?")
public void test1(){
SimpleDateFormat format=new SimpleDateFormat("HH:mm:ss");
try {
logger.info("當(dāng)前線程為:"+Thread.currentThread().getName()+",方法開(kāi)始時(shí)間為:"+format.format(new Date()));
Thread.sleep(10000);
logger.info("當(dāng)前線程為:"+Thread.currentThread().getName()+",方法結(jié)束時(shí)間為:"+format.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
@Scheduled(cron = "*/5 * * * * ?")
public void test2(){
SimpleDateFormat format=new SimpleDateFormat("HH:mm:ss");
try {
logger.info("當(dāng)前線程為:"+Thread.currentThread().getName()+",方法開(kāi)始時(shí)間為:"+format.format(new Date()));
Thread.sleep(10000);
logger.info("當(dāng)前線程為:"+Thread.currentThread().getName()+",方法結(jié)束時(shí)間為:"+format.format(new Date()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
測(cè)試結(jié)果:
2020-07-07 11:34:53.101 INFO 27440 --- [ main] c.e.m.MultithreadingApplication : Started MultithreadingApplication in 1.147 seconds (JVM running for 1.74) 2020-07-07 11:34:55.002 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-2,方法開(kāi)始時(shí)間為:11:34:55 2020-07-07 11:34:55.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法開(kāi)始時(shí)間為:11:34:55 2020-07-07 11:35:05.003 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-2,方法結(jié)束時(shí)間為:11:35:05 2020-07-07 11:35:05.003 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法結(jié)束時(shí)間為:11:35:05 2020-07-07 11:35:10.001 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-2,方法開(kāi)始時(shí)間為:11:35:10 2020-07-07 11:35:10.001 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法開(kāi)始時(shí)間為:11:35:10 2020-07-07 11:35:20.001 INFO 27440 --- [Schedule-Task-2] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-2,方法結(jié)束時(shí)間為:11:35:20 2020-07-07 11:35:20.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法結(jié)束時(shí)間為:11:35:20 2020-07-07 11:35:25.001 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法開(kāi)始時(shí)間為:11:35:25 2020-07-07 11:35:25.003 INFO 27440 --- [Schedule-Task-3] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-3,方法開(kāi)始時(shí)間為:11:35:25 2020-07-07 11:35:35.001 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法結(jié)束時(shí)間為:11:35:35 2020-07-07 11:35:35.003 INFO 27440 --- [Schedule-Task-3] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-3,方法結(jié)束時(shí)間為:11:35:35 2020-07-07 11:35:40.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法開(kāi)始時(shí)間為:11:35:40 2020-07-07 11:35:40.002 INFO 27440 --- [Schedule-Task-5] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-5,方法開(kāi)始時(shí)間為:11:35:40 2020-07-07 11:35:50.002 INFO 27440 --- [Schedule-Task-1] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-1,方法結(jié)束時(shí)間為:11:35:50 2020-07-07 11:35:50.002 INFO 27440 --- [Schedule-Task-5] c.e.multithreading.service.TestService : 當(dāng)前線程為:Schedule-Task-5,方法結(jié)束時(shí)間為:11:35:50
以上這篇Springboot集成定時(shí)器和多線程異步處理操作就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
ehcache開(kāi)源緩存框架_動(dòng)力節(jié)點(diǎn)Java學(xué)院整理
Ehcache是現(xiàn)在最流行的純Java開(kāi)源緩存框架，這篇文章主要介紹了ehcache框架的相關(guān)資料，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-07-07
Java詳解多線程協(xié)作作業(yè)之信號(hào)同步
信號(hào)量同步是指在不同線程之間，通過(guò)傳遞同步信號(hào)量來(lái)協(xié)調(diào)線程執(zhí)行的先后次序。CountDownLatch是基于時(shí)間維度的Semaphore則是基于信號(hào)維度的
2022-05-05 
如何使用IntelliJ IDEA中的Live Templates自定義代碼模板
在IntelliJ IDEA中,通過(guò)使用LiveTemplates功能,可以實(shí)現(xiàn)快速編碼和自定義代碼模板,例如,輸入“main”可以自動(dòng)補(bǔ)全主函數(shù)結(jié)構(gòu),“sout”可以補(bǔ)全輸出語(yǔ)句,用戶可以通過(guò)設(shè)置中的LiveTemplates選項(xiàng)查看和定義快捷模板,支持使用分組管理和參數(shù)化模板內(nèi)容,適應(yīng)復(fù)雜的編碼需求
2024-11-11 
這篇文章主要介紹了基于logback.xml不生效問(wèn)題的解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2023-06-06 
在本篇內(nèi)容里系小編給大家分享的是一篇關(guān)于Java迭代器遍歷list的方法總結(jié)內(nèi)容，有需要的朋友們可以參考學(xué)習(xí)下。
2022-11-11 
RocketMQ?Broker實(shí)現(xiàn)高可用高并發(fā)的消息中轉(zhuǎn)服務(wù)
RocketMQ消息代理（Broker）是一種高可用、高并發(fā)的消息中轉(zhuǎn)服務(wù)，能夠接收并存儲(chǔ)生產(chǎn)者發(fā)送的消息，并將消息發(fā)送給消費(fèi)者。它具有多種消息存儲(chǔ)模式和消息傳遞模式，支持水平擴(kuò)展和故障轉(zhuǎn)移等特性，可以為分布式應(yīng)用提供可靠的消息傳遞服務(wù)
2023-04-04 
這篇文章主要介紹了springboot swagger2注解使用，本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
2020-05-05 
這篇文章主要給大家介紹了關(guān)于java Long==Long有趣的現(xiàn)象的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
2018-09-09 
這篇文章主要介紹了Springboot集成規(guī)則引擎Drools方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2023-11-11