@Schedule 如何解决定时任务推迟执行

目录
  • 前言
  • 一、@Scheduled
    • 1、代码
    • 2、结果
  • 二、@Scheduled + 配置线程池
    • 1、代码
    • 2、结果
  • 三、@Scheduled + @Async
    • 1、代码
    • 2、结果

前言

SpringBoot 实现定时任务很简单，只需要使用**@Scheduled**注解即可，但是该注解是实现的定时任务默认是单线程的，也就意味着多个定时任务执行时就可能导致线程堵塞，延缓定时任务的执行。

下面就一步一步来解决这个问题。

一、@Scheduled

1、代码

// 启用定时任务
@EnableScheduling
@SpringBootApplication
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

@Component
public class Task {
    Logger logger = LoggerFactory.getLogger(Task.class);
	// 每五秒执行一次
    @Scheduled(cron = "0/5 * * * * ?")
    public void taskTestA() throws InterruptedException {
        logger.info("A:");
        TimeUnit.SECONDS.sleep(20);
    }

    // 每十秒执行一次
    @Scheduled(cron = "0/10 * * * * ?")
    public void taskTestB() {
        logger.info("B:");
    }
}

2、结果

由图可知，首先这两个定时任务都是单线程的，但是当定时A执行了一次后，由于定时A中有个休眠20秒，然后执行定时任务B，所以线程A第二次执行在25秒后才执行，这就是由于@Scheduled定时任务是单线程，造成的线程堵塞，导致定时任务推迟执行。

二、@Scheduled + 配置线程池

1、代码

和前面@Scheduled 相比，仅仅增加了配置线程池

// 若不设置默认为单线程，这里设置使用线程池，大小为4
spring：
  task:
    scheduling:
      pool:
        size: 4

2、结果

由图可知，增加了线程池，这样使得定时任务A和B在不同的线程进行执行，但是定时任务A的第二次执行，依旧是在25秒后执行，由此可知这种方式其实解决的是不同定时任务之间的进程堵塞。

三、@Scheduled + @Async

1、代码

和前面相比，仅仅增加了配置

// 启用异步，动态创建线程
@EnableAsync
@EnableScheduling
@SpringBootApplication
public class DemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}
@Component
public class Task {
    Logger logger = LoggerFactory.getLogger(Task.class);
    // 异步，动态创建线程
    @Async
    @Scheduled(cron = "0/5 * * * * ?")
    public void taskTestA() throws InterruptedException {
        logger.info("A:");
        TimeUnit.SECONDS.sleep(20);
    }
    // 异步，动态创建线程
    @Async
    @Scheduled(cron = "0/10 * * * * ?")
    public void taskTestB() {
        logger.info("B:");
    }
}

2、结果

由图可知，启用了异步，使用了spring 默认的线程池，动态创建线程，这样使得定时任务A和B在不同的线程进行执行，同时任务A的多次运行也是异步执行，这样就能确保所有定时任务不会延迟执行！

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

赞 (0)

相关推荐

  • SpringBoot中使用@scheduled定时执行任务的坑

    目录 解决办法 1.将@Scheduled注释的方法内部改成异步执行 2.把Scheduled配置成成多线程执行 要注意什么坑 不绕弯子了,直接说这个坑是啥: SpringBoot使用@scheduled定时执行任务的时候是在一个单线程中,如果有多个任务,其中一个任务执行时间过长,则有可能会导致其他后续任务被阻塞直到该任务执行完成.也就是会造成一些任务无法定时执行的错觉 可以通过如下代码进行测试:     @Scheduled(cron = "0/1 * * * * ? ")    

  • Spring多定时任务@Scheduled执行阻塞问题解决

    目录 一. 问题描述 二. 场景复现 三. 解决方案 方案一:使用@Async注解实现异步任务 方案二:手动设置定时任务的线程池大小 四. 总结 一. 问题描述 最近项目中发现一个问题,计划每日凌晨4:40执行一个定时任务,使用注解方式: @Scheduled(cron = “0 40 4 * * ?”),cron表达式明显没有问题,但是这个定时任务总是不按时执行,有时候得等到8点多,有时候9点多才执行.后来查了下,原来这种定时方式默认是单线程执行的,恰好我这里有多个定时任务,并且其中有个在4:

  • Java @Scheduled定时器用法解析

    目录 @Scheduled定时器用法 @Scheduled的几种使用方式 两个方法串行执行 两个方法并行,且自己也并行 两个方法并行,且自己串行 @Scheduled定时器用法 程序中若需要在某个时间循环执行某项任务,就可以使用@Scheduled定时器 源码如下:     @Scheduled(cron="0 0 21 * * ?") //每天晚上九点执行一次    21点     public void taskCycle() throws  Exception{        

  • 多线程Spring通过@Scheduled实现定时任务

    目录 前言 一 定时任务调度注解@Scheduled 二 使用@Async实现异步调度 建立spring线程池 为异步调度方法指定线程池 前言 技术的入门大多比较简单,把别人的代码复制过来,删删改改,基本也就能实现个功能,查看个API大概也就知道如何实现几个功能,但是,如果对一项技术了解的足够深入,就要知道一个技术的优缺点,以及他存在的问题,这些就需要大量的时间及思考,疾风知劲草,只有足够了解才能临危不惧,才能在如疾风般强劲的bug来临时微微一笑,绝对不倒! 一 定时任务调度注解@Schedul

  • SpringBoot中定时任务@Scheduled注解的使用解读

    SpringBoot中定时任务@Scheduled注解的使用解读

    目录 概述 注解定义 参数说明 源码解析 使用详解 定时任务同步/异步执行 fixedRate/fixedDelay区别 项目开发中,经常会遇到定时任务的场景,Spring提供了@Scheduled注解,方便进行定时任务的开发 概述 要使用@Scheduled注解,首先需要在启动类添加@EnableScheduling,启用Spring的计划任务执行功能,这样可以在容器中的任何Spring管理的bean上检测@Scheduled注解,执行计划任务 注解定义 @Target({ElementTyp

  • 关于@Scheduled注解的任务为什么不执行的问题

    目录 概述 举例说明 原因分析 解决方案 概述 在SpringBoot中可以通过@Scheduled来注解定义一个定时任务,但是有时候你可能发现有的定时任务道理时间却没有执行,但是又不是每次都不执行,为什么呢??? 举例说明 下面这段diam定义了一个没隔10s执行一次的定时任务: package com.study.practice.schedule; import lombok.extern.slf4j.Slf4j; import org.springframework.scheduling

  • @Schedule 如何解决定时任务推迟执行

    @Schedule 如何解决定时任务推迟执行

    目录 前言 一.@Scheduled 1.代码 2.结果 二.@Scheduled + 配置线程池 1.代码 2.结果 三.@Scheduled + @Async 1.代码 2.结果 前言 SpringBoot 实现定时任务很简单,只需要使用**@Scheduled**注解即可,但是该注解是实现的定时任务默认是单线程的,也就意味着多个定时任务执行时就可能导致线程堵塞,延缓定时任务的执行. 下面就一步一步来解决这个问题. 一.@Scheduled 1.代码 // 启用定时任务 @EnableSch

  • springboot schedule 解决定时任务不执行的问题

    @schedule 注解 是springboot 常用的定时任务注解,使用起来简单方便,但是如果定时任务非常多,或者有的任务很耗时,会影响到其他定时任务的执行,因为schedule 默认是单线程的,一个任务在执行时,其他任务是不能执行的.解决办法是重新配置schedule,改为多线程执行.只需要增加下面的配置类就可以了. import org.springframework.boot.autoconfigure.batch.BatchProperties; import org.springfr

  • laravel 解决crontab不执行的问题

    最近在写laravel的时候遇到一个定时器的问题 手动的执行 php /usr/share/nginx/html/mylaravel/artisan schedul:run 可以生效 但是写在定时器中却不执行 * * * * * php /usr/share/nginx/html/mylaravel/artisan schedul:run 先看下代码 /app/Console/Commands/test.php 1.设置 $signature 属性 protected $signature =

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

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

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

  • 聊聊通过celery_one避免Celery定时任务重复执行的问题

    在使用Celery统计每日访问数量的时候,发现一个任务会同时执行两次,发现同一时间内(1s内)竟然同时发送了两次任务,也就是同时产生了两个worker,造成统计两次,一直找不到原因. 参考:https://blog.csdn.net/qq_41333582/article/details/83899884 有人使用 Redis 实现了分布式锁,然后也有人使用了 Celery Once. Celery Once 也是利用 Redis 加锁来实现, Celery Once 在 Task 类基础上实现

  • Python中schedule模块关于定时任务使用方法

    目录 1 取消定时任务 2 定时任务只执行一次 3 获取所有的定时任务 4 取消所有任务 5 给定时任务打标签,同样通过标签获取或取消定时任务 1 取消定时任务 比如当满足一定条件时,就取消定时任务,在这种场景下,不可能说把进程干掉,所以可以利用取消定时任务的功能 如下代码,通过count控制当执行了5此以后,就取消定时任务 import schedule import time count=0 def do_func(name,age): global count count+=1 print

  • Linux中crontab定时任务不执行的原因

    最近在linux中遇到了个crontab定时任务不执行的case,在这给大家分享一下,避免踩到我遇到的坑. 先贴脚本吧 为了方便展示,把脚本入参,都写死了 #!/usr/bin/env bash # 1输出文件,到log 例如: bg # 2 目标文件目录 不带最后的/ 例如:/opt/flume/home/hdp_lbg_ectech/rawdata/xxx/web_vip_bg # 3 执行的时候选择前几天的日志 例如:1 LAST_DAY=$(date +"%Y-%m-%d" -

  • python except异常处理之后不退出,解决异常继续执行的实现

    写了个等待分析结果,解析分析结果json的脚本 那个文件生成时候有点大,有时候监测到新文件就去解析可能文件只生成了一半,就会抛出异常退出当前线程,此次的分析结果就丢失了,如果load json文件失败,一般就是上百M到几G的json大文件,等待10秒,如果再次load失败,重新再load一次,这样脚本看上去挺繁琐的,监控线程又只能监控文件的创建,修改和删除,不知道创建的文件是否写完毕. def run_analyze(): sleep(2) berror = True temp = {} whi

  • crontab定时任务不执行的原因分析与解决方法

    前言 实现Linux定时任务有:cron.anacron.at等,cron是服务名称,crond是后台进程,crontab则是定制好的计划任务表 然而今天真是长知识 用了 crontab 这么久 才知道原来也需要 启动 添加了定时任务 但是并不好使 [root@dev-gl-lh1 ApiAgent]# cat /etc/crontab SHELL=/bin/bash PATH=/sbin:/bin:/usr/sbin:/usr/bin MAILTO=root HOME=/ # For deta

随机推荐