聊聊SpringBoot的@Scheduled的并发问题

目录
  • SpringBoot @Scheduled的并发
  • spring @Scheduled 并发执行

SpringBoot @Scheduled的并发

由于SpringBoot自带的@Scheduled是一个阻塞执行的定时任务，所以效率会很慢，就会造成同一个时间段内只有一个定时任务在执行，其余的就会阻塞

现有两个定时任务

@Component("aa")
public class aa {
    @Scheduled(cron = "0 44 17 * * ?")
    public void bb() {
        try {
            System.out.println("aa执行时间：" + new Date());
            Thread.sleep(65000);
            System.out.println("aa完成时间：" + new Date());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
@Component("bb")
public class bb {
    @Scheduled(cron = "0 55 17 * * ?")
    public void aa() {
        try {
            System.out.println("bb执行时间：" + new Date());
            Thread.sleep(10000);
            System.out.println("bb完成时间：" + new Date());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

默认的在启动项加入@EnableScheduling注解就可以运行了

最终，执行的结果令人大跌眼镜。

aa的任务由于执行时间需要65秒，超过了bb任务执行的时间，结果bb任务执行的时间被阻塞掉，延迟了5秒执行。

解决方法是在启动项类中加入如下配置即可

 @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(50);
        return taskScheduler;
    }

如果是xml

 <!-- 注解式 -->
 <task:annotation-driven executor="myExecutor" scheduler="myScheduler"/>
 <task:executor id="myExecutor" pool-size="5"/>
 <task:scheduler id="myScheduler" pool-size="10"/>

spring @Scheduled 并发执行

spring @Scheduled ，默认基于单线程执行，如果需要基于多线程执行，需要在配置文件中配置如下

queue-capacity="500" rejection-policy="CALLER_RUNS" />
scheduler="scheduler" />

具体可以参考spring 帮助文档对annotation-driven的executor和scheduler的解释

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我们。

赞 (0)

相关推荐

  • SpringBoot中使用@Scheduled注解创建定时任务的实现

    在项目日常开发过程中,经常需要定时任务来帮我们做一些工作,如清理日志.定时任务的实现方法主要有 Timer.Quartz 以及 elastic-job Timer 实现定时任务 只执行一次的定时任务 Timer timer = new Timer(); timer.schedule(new TimerTask() { @Override public void run() { System.out.println("2000毫米后执行一次."); } }, 2000); timer.s

  • 深入剖析springBoot中的@Scheduled执行原理

    深入剖析springBoot中的@Scheduled执行原理

    目录 springBoot @Scheduled执行原理 一.前言 二.@Scheduled使用方式 三.@Scheduled代码执行原理说明 @Scheduled 的一些坑 springBoot @Scheduled执行原理 一.前言 本文主要介绍Spring Boot中使用定时任务的执行原理. 二.@Scheduled使用方式 定时任务注解为@Scheduled.使用方式举例如下: //定义一个按时间执行的定时任务,在每天16:00执行一次. @Scheduled(cron = "0 0 1

  • springboot 定时任务@Scheduled实现解析

    这篇文章主要介绍了springboot 定时任务@Scheduled实现解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 1.pom.xml中导入必要的依赖: <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version&g

  • 使用springboot时,解决@Scheduled定时器遇到的问题

    目录 @Scheduled定时器遇到的问题 下面说一下@Scheduled 注解的几个参数 一.可以通过配置文件配置进来的 二.不可通过配置文件配置的 (作用相同) 定时任务@Scheduled使用的那些坑 一.使用的那些坑? 1.单线程 2.@Async和@EnableAsync 二.使用多线程 小结一下 @Scheduled定时器遇到的问题 @Scheduled 这个注解确实给我们带了很大的方便,我们只要加上该注解,并且根据需求设置好就可以使用定时任务了. 但是,我们需要注意的是,@Sche

  • SpringBoot项目中使用@Scheduled读取动态参数

    目录 使用@Scheduled读取动态参数 1.基于@Scheduled可配置开发 2.基于代码实现 spring boot Scheduled动态配置 使用@Scheduled读取动态参数 1.基于@Scheduled可配置开发 application.propertites: read.timer.parmas=0 0/1 * * * * 定时类: @Component public class ScheduledService { Logger logger= LoggerFactory.

  • SpringBoot执行定时任务@Scheduled的方法

    在做项目时,需要一个定时任务来接收数据存入数据库,后端再写一个接口来提供该该数据的最新的那一条. 数据保持最新:设计字段sign的值(0,1)来设定是否最新 定时任务插入数据:首先进行更新,将所有为1即新数据设置过期,然后插入新数据,设置sign为1.这两个操作是原子操作.通过添加事务来进行控制. Java 定时任务的几种实现方式 基于 java.util.Timer 定时器,实现类似闹钟的定时任务 使用 Quartz.elastic-job.xxl-job 等开源第三方定时任务框架,适合分布式

  • springboot定时任务@Scheduled执行多次的问题

    springboot定时任务@Scheduled执行多次的问题

    目录 springboot定时任务@Scheduled执行多次 原因 解决方法 使用 @Scheduled 定时任务突然不执行了 springboot定时任务@Scheduled执行多次 在spring boot开发定时任务时遇到一个很怪异的现象..我进行调试模式,在没有bug的情况下.执行了三 次才停止..如图: 原因 是因为执行时间太短,在CronSequenceGenerator.class的next方法. public Date next(Date date) { Calendar ca

  • 聊聊SpringBoot的@Scheduled的并发问题

    聊聊SpringBoot的@Scheduled的并发问题

    目录 SpringBoot @Scheduled的并发 spring @Scheduled 并发执行 SpringBoot @Scheduled的并发 由于SpringBoot自带的@Scheduled是一个阻塞执行的定时任务,所以效率会很慢,就会造成同一个时间段内只有一个定时任务在执行,其余的就会阻塞 现有两个定时任务 @Component("aa") public class aa { @Scheduled(cron = "0 44 17 * * ?") pub

  • Springboot通过Scheduled实现定时任务代码

    定时任务一般会存在中大型企业级项目中,为了减少服务器.数据库的压力往往会采用时间段性的去完成某些业务逻辑.比较常见的就是金融服务系统推送回调,一般支付系统订单在没有收到成功的回调返回内容时会持续性的回调,这种回调一般都是定时任务来完成的.还有就是报表的生成,我们一般会在客户访问量过小的时候来完成这个操作,那往往都是在凌晨.这时我们也可以采用定时任务来完成逻辑.SpringBoot为我们内置了定时任务,我们只需要一个注解就可以开启定时为我们所用了. 在开发中,定时任务是常见的功能,在spring

  • spring-boot通过@Scheduled配置定时任务及定时任务@Scheduled注解的方法

    串行的定时任务 @Component public class ScheduledTimer { private Logger logger = Logger.getLogger(this.getClass()); /** * 定时任务,1分钟执行1次,更新潜在客户超时客户共享状态 */ @Scheduled(cron="0 0/1 8-20 * * ?") public void executeUpdateCuTask() { Thread current = Thread.curr

  • Springboot定时任务Scheduled重复执行操作

    今天用scheduled写定时任务的时候发现定时任务一秒重复执行一次,而我的cron表达式为 * 0/2 * * * * . 在源码调试的过程中,发现是我的定时任务执行过程太短导致的. 于是我另外写了个简单的定时任务 @Component public class TestJob { @Scheduled(cron = "* 0/2 * * * *") public void test() { System.out.println("测试开始"); System.o

  • SpringBoot实现动态多线程并发定时任务

    SpringBoot实现动态多线程并发定时任务

    本文实例为大家分享了SpringBoot实现动态多线程并发定时任务的具体代码,供大家参考,具体内容如下 实现定时任务有多种方式,使用spring自带的,继承SchedulingConfigurer的方式. 一.实现 1.启动类 在启动类添加注解@EnableScheduling开启,不然不起用做. 2.新建任务类 添加注解@Component注册到spring的容器中. package com.example.demo.task; import com.example.demo.entity.M

  • 解决SpringBoot内嵌Tomcat并发容量的问题

    解决SpringBoot内嵌Tomcat并发容量的问题

    一.SpringBoot内嵌Tomcat默认配置与优化 在做一个关于秒杀系统的模块,进行Jmeter压测性能的时候发现tomcat并发上不去,深入原因找到可供优化的地方,力求最大性能. 发现并发容器问题 对单接口进行6000线程压测,每个线程请求5次,线程在5秒内创建完毕,当进行一半的时候,已经出现了请求响应时间过大及其错误率达到了43%.这个并发容量对于配置比较好点的服务器相对来说有点弱. 深入SpringBoot底层了解原因 在SpringBoot官方文档中提到了关于元数据的配置 可以看到,

  • 详细聊聊SpringBoot中动态切换数据源的方法

    详细聊聊SpringBoot中动态切换数据源的方法

    其实这个表示有点不太对,应该是 Druid 动态切换数据源的方法,只是应用在了 springboot 框架中,准备代码准备了半天,之前在一次数据库迁移中使用了,发现 Druid 还是很强大的,用来做动态数据源切换很方便. 首先这里的场景跟我原来用的有点点区别,在项目中使用的是通过配置中心控制数据源切换,统一切换,而这里的例子多加了个可以根据接口注解配置 第一部分是最核心的,如何基于 Spring JDBC 和 Druid 来实现数据源切换,是继承了org.springframework.jdbc

  • 聊聊SpringBoot中组件无法被注入的问题

    聊聊SpringBoot中组件无法被注入的问题

    目录 SpringBoot中组件无法被注入 1.描述问题 2.解决问题 3.总结问题 解决在@Component注入为null SpringBoot中组件无法被注入 1.描述问题 在SpringBoot中,无法通过注解@AutoWired来自动绑定实体bean或者组件component. 2.解决问题 首先检查自己的是否在实体类上加上了@Component这样的注解,@ComponentScan可以扫描的有@Service.@Repository.@Componnet.@Controller.@

随机推荐