Spring?Boot多個(gè)定時(shí)任務(wù)阻塞問(wèn)題的解決方法

更新時(shí)間：2022年01月04日 16:38:25 作者：不才陳某

在日常的項(xiàng)目開(kāi)發(fā)中,往往會(huì)涉及到一些需要做到定時(shí)執(zhí)行的代碼,下面這篇文章主要給大家介紹了關(guān)于Spring?Boot多個(gè)定時(shí)任務(wù)阻塞問(wèn)題的解決方法,需要的朋友可以參考下

前言

今天這篇文章介紹一下Spring Boot 中如何開(kāi)啟多線程定時(shí)任務(wù)？

為什么Spring Boot 定時(shí)任務(wù)是單線程的？

想要解釋為什么，一定要從源碼入手，直接從@EnableScheduling這個(gè)注解入手，找到了這個(gè)ScheduledTaskRegistrar類，其中有一段代碼如下：

protected void scheduleTasks() {
  if (this.taskScheduler == null) {
   this.localExecutor = Executors.newSingleThreadScheduledExecutor();
   this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
  }
}

如果taskScheduler為null，則創(chuàng)建單線程的線程池：Executors.newSingleThreadScheduledExecutor()。

多線程定時(shí)任務(wù)如何配置？

下面介紹三種方案配置多線程下的定時(shí)任務(wù)。

1、重寫(xiě)SchedulingConfigurer#configureTasks()

直接實(shí)現(xiàn)SchedulingConfigurer這個(gè)接口，設(shè)置taskScheduler，代碼如下：

@Configuration
public class ScheduleConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        //設(shè)定一個(gè)長(zhǎng)度10的定時(shí)任務(wù)線程池
        taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));
    }
}

2、通過(guò)配置開(kāi)啟

Spring Boot quartz 已經(jīng)提供了一個(gè)配置用來(lái)配置線程池的大小，如下；

spring.task.scheduling.pool.size=10

只需要在配置文件中添加如上的配置即可生效！

3、結(jié)合@Async

@Async這個(gè)注解都用過(guò)，用來(lái)開(kāi)啟異步任務(wù)的，使用@Async這個(gè)注解之前一定是要先配置線程池的，配置如下：

    @Bean
    public ThreadPoolTaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPoolTaskExecutor();
        poolTaskExecutor.setCorePoolSize(4);
        poolTaskExecutor.setMaxPoolSize(6);
        // 設(shè)置線程活躍時(shí)間（秒）
        poolTaskExecutor.setKeepAliveSeconds(120);
        // 設(shè)置隊(duì)列容量
        poolTaskExecutor.setQueueCapacity(40);
        poolTaskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 等待所有任務(wù)結(jié)束后再關(guān)閉線程池
        poolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        return poolTaskExecutor;
    }

然后在@Scheduled方法上標(biāo)注@Async這個(gè)注解即可實(shí)現(xiàn)多線程定時(shí)任務(wù)，代碼如下：

 @Async
    @Scheduled(cron = "0/2 * * * * ? ")
    public void test2() {
        System.out.println("..................執(zhí)行test2.................");
    }

總結(jié)

本篇文章介紹了Spring Boot 中實(shí)現(xiàn)多線程定時(shí)任務(wù)的三種方案，你喜歡哪一種？

到此這篇關(guān)于Spring Boot多個(gè)定時(shí)任務(wù)阻塞問(wèn)題解決的文章就介紹到這了,更多相關(guān)SpringBoot多定時(shí)任務(wù)阻塞內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: