文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

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

2024-04-02 19:55

关注

@Scheduled定时器遇到的问题

@Scheduled 这个注解确实给我们带了很大的方便,我们只要加上该注解,并且根据需求设置好就可以使用定时任务了。

但是,我们需要注意的是,@Scheduled 并不一定一定会按时执行。

因为使用@Scheduled 的定时任务虽然是异步执行的,但是,不同的定时任务之间并不是并行的!!!!!!!!

在其中一个定时任务没有执行完之前,其他的定时任务即使是到了执行时间,也是不会执行的,它们会进行排队。

也就是如果你想你不同的定时任务互不影响,到时间就会执行,那么你最好将你的定时任务方法自己搞成异步方法,这样,

定时任务其实就相当于调用了一个线程执行任务,一瞬间就结束了。当然,也可以勉强当做是任务都会定时执行。

下面说一下@Scheduled 注解的几个参数

一、可以通过配置文件配置进来的

使用表达式,该表达式表示每一秒中执行一次。如果上一次方法超过了定时时间还没有执行完,那么下一次定时不会执行,

直到上次方法执行完后,就会立即执行下一次的定时任务

该方式在工程启动的时候,并不会立即执行,会按照定时表达式的规律进行执行。例如这里,就是1秒后才会执行。


@Scheduled(cron="0/1 * * * * ?")   

使用固定速率。该表达式表示每隔一秒钟执行一次。如果上一次方法超过了1秒钟还没执行完,下一次任务也不会执行,直到

上次方法执行完,下次的定时就会立即执行。

该方式在工程启动的时候,会立即执行,接下来会按规律进行执行。


@Scheduled(fixedRateString="1000")   // 单位:毫秒

该方式和上一个的不同在于多加了一个参数,这个参数是一个初始化参数。

加上initialDelayString后,在刚启动的时候,就不会立即执行了,而是会等到10秒之后才会执行,即使fixedRateString才

1秒钟。也会在10秒后才会第一次执行。

注意:initialDelayString不能喝cron组合使用。


@Scheduled(fixedRateString="1000",initialDelayString="10000")

使用固定延迟。该表达式表示每次执行完后一秒再次执行。每一次执行,无论执行多长时间,下一次执行都会在上一次方法

执行完后,再过一秒钟,再次执行。

该方式在工程启动的时候,会立即执行,接下来会按规律进行执行。


@Scheduled(fixedDelayString="1000")

二、不可通过配置文件配置的 (作用相同)


   @Scheduled(fixedRate=1000)      // 它们都是接受一个long类型的参数
   @Scheduled(fixedDelay=1000)
   @Scheduled(fixedRate=1000,initialDelay=10000)

这里粘贴一下cron表达式的规则:

字段 允许值 允许的特殊字符
0-59 , - * /
小时 0-23 , - * /
日期 1-31 , - * ? / L W C
月份 1-12 或者 JAN-DEC , - * /
星期 1-7 或者 SUN-SAT , - * ? / L C #
年(可选) 留空, 1970-2099 , - * /

定时任务@Scheduled使用的那些坑

@Scheduled是spring自带的注解,默认是单线程,常用作定时任务使用,但是如果是集群版的机器的话,就考虑加上分布式锁或者使用分布式定时任务代替。

一、使用的那些坑?

1.单线程

因为@Scheduled默认使用的是单线程,如果有两个任务A和B,那么任务A要是阻塞了,任务B就无法执行。

2.@Async和@EnableAsync

为了解决单线程带来的线程阻塞问题,我们可以使用@Async和@EnableAsync两个注解采用异步的方式去处理,这样就是不同的线程去执行,但是这种方式也带来一个新的问题,那就是如果任务A的任务执行时间>任务调度周期时间的话,就会发生上一个任务未执行完毕,下一个任务又开始执行的逻辑,这种也是有风险的。所以最好使用多线程方式,自己控制线程池的数量,线程名称等。

二、使用多线程

需要实现SchedulingConfigurer接口,然后自定义线程池,这样凡是用到@Scheduled注解的都可以用该线程池,同时也解决了上述比较坑的两个问题。


@Configuration
@EnableScheduling
public class ScheduleConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskExecutor());
    }
    @Bean
    public Executor taskExecutor() {
        return Executors.newScheduledThreadPool(20, (Runnable r) -> {
            Thread thread = new Thread(r);
            thread.setName("自定义线程名称");
            return thread;
        });
    }
}

以上这一行


thread.setName(“自定义线程名称”);

是设置线程名称,可以通过Thread.currentThread().getName()拿到该名称,便于在日志中进行排查问题。

小结一下

集群版本如果要使用@Scheduled的话,需要加分布式锁来控制,或者直接用分布式定时任务Elasticjob或者xxl-job等。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持编程网。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯