SpringBoot从入门到精通(三十五)使用@Scheduled实现多线程定时任务

简介: 默认情况下,Spring Boot定时任务是按单线程方式执行的,也就是说,如果同一时刻有两个定时任务需要执行,那么只能在一个定时任务完成之后再执行下一个。如果只有一个定时任务,这样做肯定没问题;当定时任务增多时,如果一个任务被阻塞,则会导致其他任务无法正常执行。要解决这个问题,需要配置任务调度线程池。

默认情况下,Spring Boot定时任务是按单线程方式执行的,也就是说,如果同一时刻有两个定时任务需要执行,那么只能在一个定时任务完成之后再执行下一个。如果只有一个定时任务,这样做肯定没问题;当定时任务增多时,如果一个任务被阻塞,则会导致其他任务无法正常执行。要解决这个问题,需要配置任务调度线程池。


一、实现多线程定时任务

下面通过示例演示Spring Boot 实现多线程定时任务。


1. 增加多线程配置类

config目录下增加SchedulerConfig配置类,代码如下:

public class SchedulerConfig {
    @Bean
    public Executor taskScheduler() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(3);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(3);
        executor.initialize();
        return executor;
    }
}

设置执行线程池为3,最大线程数为10


2. 修改SchedulerTask定时任务

修改之前定义的SchedulerTask定时任务的类,在方法上增加@Async注解,使得后台任务能够异步执行,代码如下:

@EnableAsync // 开启异步事件的支持
@Component
public class SchedulerTask {
    private static final Logger logger = LoggerFactory.getLogger(SchedulerTask.class);
    @Async
   @Scheduled(cron="*/10 * * * * ?")
    public void taskCron() {
       SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
       logger.info("SchedulerTask taskCron 现在时间: " + dateFormat.format(new Date()));
    }
    @Async
   @Scheduled(fixedRate = 5000)
    public void taskFixed() {
       SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
       logger.info("SchedulerTask taskFixed 现在时间: " + dateFormat.format(new Date()));
    }
}

在上面的示例中,定时任务类SechedulerTask增加了@EnableAsync注解,开启了异步事件支持。同时,在定时方法上增加@Async注解,使任务能够异步执行,这样各个后台任务就不会阻塞。



二、测试验证

配置修改完成后,重新启动项目,查看后台任务的运行情况。如图10-2所示,全部的后台任务分成了多个线程执行,这样任务之间不会相互影响。

image.png

通过后台日志可以看到,Spring Boot启动线程池负责调度执行后台任务,各个后台任务之间相对独立、互不影响。



最后

以上,我们就把Spring Boot实现多线程定时任务介绍完了。

相关文章
|
8天前
|
Java 数据处理 调度
Java多线程编程入门指南
Java多线程编程入门指南
|
7天前
|
安全 Java 数据库连接
Spring Boot 优雅关机时异步线程安全优化
Spring Boot 优雅关机时异步线程安全优化
8 1
|
14天前
|
Java 关系型数据库 MySQL
Mybatis入门之在基于Springboot的框架下拿到MySQL中数据
Mybatis入门之在基于Springboot的框架下拿到MySQL中数据
17 4
|
14天前
|
Java 应用服务中间件 Maven
Springboot入门基础知识详解 parent starter 引导类 辅助功能
Springboot入门基础知识详解 parent starter 引导类 辅助功能
20 2
|
14天前
|
Java 程序员
浅浅纪念花一个月完成Springboot+Mybatis+Springmvc+Vue2+elementUI的前后端交互入门项目
浅浅纪念花一个月完成Springboot+Mybatis+Springmvc+Vue2+elementUI的前后端交互入门项目
25 1
|
19天前
|
Java 开发者
告别单线程时代!Java 多线程入门:选继承 Thread 还是 Runnable?
【6月更文挑战第19天】在Java中,面对多任务需求时,开发者可以选择继承`Thread`或实现`Runnable`接口来创建线程。`Thread`继承直接但限制了单继承,而`Runnable`接口提供多实现的灵活性和资源共享。多线程能提升CPU利用率,适用于并发处理和提高响应速度,如在网络服务器中并发处理请求,增强程序性能。不论是选择哪种方式,都是迈向高效编程的重要一步。
|
19天前
|
监控 程序员 调度
协程实现单线程并发(入门)
协程实现单线程并发(入门)
18 1
|
17小时前
|
Java 程序员 BI
在Spring Boot中实现多线程任务调度
在Spring Boot中实现多线程任务调度
|
29天前
|
Java 调度 Spring
SpringBoot多个@Scheduled注解的方法,会阻塞吗
【6月更文挑战第9天】SpringBoot多个@Scheduled注解的方法,会阻塞吗
23 5
|
24天前
|
消息中间件 设计模式 Java
SpringBoot+Schedule 定时任务的配置开关
SpringBoot+Schedule 定时任务的配置开关
17 0
SpringBoot+Schedule 定时任务的配置开关