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实现多线程定时任务介绍完了。

相关文章
|
23天前
|
前端开发 Java 数据库
SpringBoot入门 - 对Hello world进行MVC分层
SpringBoot入门 - 对Hello world进行MVC分层
40 3
SpringBoot入门 - 对Hello world进行MVC分层
|
23天前
|
Java 数据库连接 测试技术
SpringBoot入门 - 添加内存数据库H2
SpringBoot入门 - 添加内存数据库H2
32 3
SpringBoot入门 - 添加内存数据库H2
|
1月前
|
Java 应用服务中间件 数据库连接
SpringBoot入门(2) - SpringBoot HelloWorld
SpringBoot入门(2) - SpringBoot HelloWorld
39 2
SpringBoot入门(2) - SpringBoot HelloWorld
|
1月前
|
Java 中间件
SpringBoot入门(6)- 添加Logback日志
SpringBoot入门(6)- 添加Logback日志
74 5
|
1月前
|
前端开发 Java 数据库
SpringBoot入门(3) - 对Hello world进行MVC分层
SpringBoot入门(3) - 对Hello world进行MVC分层
33 4
|
16天前
|
Java 开发者 微服务
Spring Boot 入门:简化 Java Web 开发的强大工具
Spring Boot 是一个开源的 Java 基础框架,用于创建独立、生产级别的基于Spring框架的应用程序。它旨在简化Spring应用的初始搭建以及开发过程。
36 6
Spring Boot 入门:简化 Java Web 开发的强大工具
|
23天前
|
Java 应用服务中间件 数据库连接
SpringBoot入门 - SpringBoot HelloWorld
SpringBoot入门 - SpringBoot HelloWorld
SpringBoot入门 - SpringBoot HelloWorld
|
23天前
|
Java Spring
SpringBoot入门 - 定制自己的Banner
SpringBoot入门 - 定制自己的Banner
15 2
SpringBoot入门 - 定制自己的Banner
|
23天前
|
缓存 IDE Java
SpringBoot入门(7)- 配置热部署devtools工具
SpringBoot入门(7)- 配置热部署devtools工具
41 1
SpringBoot入门(7)- 配置热部署devtools工具
|
27天前
|
前端开发 Java 数据库
SpringBoot入门(3) - 对Hello world进行MVC分层
SpringBoot入门(3) - 对Hello world进行MVC分层
16 1
 SpringBoot入门(3) - 对Hello world进行MVC分层