SpringBoot中配置定時任務(wù)及線程池和多線程池執(zhí)行的方法是怎樣的-創(chuàng)新互聯(lián)

SpringBoot中配置定時任務(wù)及線程池和多線程池執(zhí)行的方法是怎樣的,很多新手對此不是很清楚,為了幫助大家解決這個難題,下面小編將為大家詳細講解,有這方面需求的人可以來學習下,希望你能有所收獲。

成都創(chuàng)新互聯(lián)-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價比石林網(wǎng)站開發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫,直接使用。一站式石林網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們,業(yè)務(wù)覆蓋石林地區(qū)。費用合理售后完善,10余年實體公司更值得信賴。

配置基礎(chǔ)的定時任務(wù)

最基本的配置方法,而且這樣配置定時任務(wù)是單線程串行執(zhí)行的,也就是說每次只能有一個定時任務(wù)可以執(zhí)行,可以試著聲明兩個方法,在方法內(nèi)寫一個死循環(huán),會發(fā)現(xiàn)一直卡在一個任務(wù)上不動,另一個也沒有執(zhí)行。

1、啟動類

添加@EnableScheduling開啟對定時任務(wù)的支持

@EnableScheduling@SpringBootApplicationpublic class TestScheduledApplication extends SpringBootServletInitializer { @Override  protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {  return builder.sources(this.getClass()); } public static void main(String[] args) {  new SpringApplicationBuilder(TestScheduledApplication.class).web(true).run(args); }}

2、配置執(zhí)行定時任務(wù)的類

添加@Component掃描本類,在方法上添加@Scheduled注解聲明定時任務(wù),配置時間周期

@Componentpublic class TestTask1 { private static final Logger logger = LogManager.getLogger(); // 間隔1秒執(zhí)行一次 @Scheduled(cron = "0/1 * * * * ?") public void method1() {  logger.info("——————————method1 start——————————");  logger.info("——————————method1 end——————————"); }}

配置線程池執(zhí)行定時任務(wù)

因為有時候需要執(zhí)行的定時任務(wù)會很多,如果是串行執(zhí)行會帶來一些問題,比如一個很耗時的任務(wù)阻塞住了,一些需要短周期循環(huán)執(zhí)行的任務(wù)也會卡住,所以可以配置一個線程池來并行執(zhí)行定時任務(wù)

1、配置線程池

添加@EnableAsync開啟對異步的支持

@Configuration@EnableAsyncpublic class ExecutorConfig {  @Bean public Executor executor1() {  ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  executor.setThreadNamePrefix("test-schedule2-");  executor.setMaxPoolSize(20);  executor.setCorePoolSize(15);  executor.setQueueCapacity(0);  executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());  return executor; }}

2、配置定時任務(wù)異步執(zhí)行

添加@Async注解,表示該定時任務(wù)是異步執(zhí)行的,因為上面線程池配置了名字,所以可以看到打印的日志是該線程池中的線程在執(zhí)行任務(wù),如果沒有配置線程池的話會默認使用SimpleAsyncTaskExecutor,這個異步執(zhí)行器每次都會開啟一個子線程執(zhí)行,性能消耗比較大,所以好是自己配置線程池

@Async@Scheduled(cron = "0/1 * * * * ?")public void method1() { logger.info("——————————method1 start——————————"); logger.info("——————————method1 end——————————");}

配置多個線程池分別執(zhí)行不同的定時任務(wù)

因為有些定時任務(wù)是比較重要的,有些則是不太重要的,想把定時任務(wù)分別放到不同的線程池中,也是可以實現(xiàn)的。

1、配置多個線程池

分別配置兩個線程池

@Configuration@EnableAsyncpublic class ExecutorConfig1 { @Bean public Executor executor1() {  ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  executor.setThreadNamePrefix("test-schedule1-");  executor.setMaxPoolSize(20);  executor.setCorePoolSize(15);  executor.setQueueCapacity(0);  executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());  return executor; }  @Bean public Executor executor2() {  ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  executor.setThreadNamePrefix("test-schedule2-");  executor.setMaxPoolSize(20);  executor.setCorePoolSize(15);  executor.setQueueCapacity(0);  executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());  return executor;  }}

2、定時任務(wù)顯示指定調(diào)用線程池

因為上面在配置類里面初始化了兩個線程池,所以會有兩個線程池分別叫executor1和executor1被生成放到容器中,因為@Bean注解生成的對象默認就是和方法名相同的名字,而@Async注解是可以指定使用哪個線程池的。這樣就可以在不同的線程池中執(zhí)行不同的定時任務(wù)了

// 間隔1秒執(zhí)行一次@Async("executor1")@Scheduled(cron = "0/1 * * * * ?")public void method1() { logger.info("——————————method1 start——————————"); logger.info("——————————method1 end——————————");}// 間隔1秒執(zhí)行一次@Scheduled(cron = "0/1 * * * * ?")@Async("executor2")public void method2() { logger.info("——————————method2 start——————————"); logger.info("——————————method2 end——————————");}

注意:

  1. 沒有配置自己的線程池時,會默認使用SimpleAsyncTaskExecutor。  如果項目中只配置了一個線程池,那么不需要顯示指定使用這個線程池,spring也會自動使用用戶配置的線程池,但是如果配置了多個就必須要顯示指定,否則還是會使用默認的。  如果想要指定使用哪個線程池,可以使用@Async("executor2")顯示指定。

看完上述內(nèi)容是否對您有幫助呢?如果還想對相關(guān)知識有進一步的了解或閱讀更多相關(guān)文章,請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝您對創(chuàng)新互聯(lián)網(wǎng)站建設(shè)公司,的支持。

網(wǎng)頁標題:SpringBoot中配置定時任務(wù)及線程池和多線程池執(zhí)行的方法是怎樣的-創(chuàng)新互聯(lián)
URL網(wǎng)址:http://muchs.cn/article22/pchcc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供云服務(wù)器App開發(fā)、品牌網(wǎng)站制作、網(wǎng)站制作、標簽優(yōu)化、靜態(tài)網(wǎng)站

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

綿陽服務(wù)器托管