解决多个@Scheduled定时任务执行时个别不执行问题

 更新时间:2024年08月02日 15:19:03   作者:在代码的路上奔跑  
这篇文章主要介绍了解决多个@Scheduled定时任务执行时个别不执行问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

多个@Scheduled定时任务执行时个别不执行

原因

项目在启动时,如果没有指定线程池的大小,默认会创建核心线程数为1的默认线程池,故而当项目中出现多个@Scheduled线程时,只能一个个的执行,从而导致个别线程执行时间过长(或长期执行)时,其他定时器不能按照指定的规则进行执行。

解决办法

1、配置执行线程池的大小

spring.task.scheduling.pool.size=10

2.将定时器设置为异步线程

/**
异步线程
定时器延迟1秒启动,每距上一次执行完成后间隔3秒执行一次
*/
@Async(“taskExecutor”)
@Scheduled(initialDelay = 1000L, fixedDelay = 3000L)
public void test(){System.out.println(“—”+System.currentTimeMillis());//业务内容
}

@Scheduled多定时任务,重叠执行

@Scheduled如果有两个定时任务,定时任务重复时,只有一个可以执行。如下

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
import java.time.LocalDateTime;
 
@Component
public class MyScheduled {
 
    @Scheduled(cron = "0/5 * * * * ?")
    public void execute1(){
        String curName = Thread.currentThread().getName() ;
        System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute1对应的线程名: "+curName);
        try {
            Thread.sleep(1000);
        } catch (Exception e) {
            e.printStackTrace();
        }
 
    }
 
    @Scheduled(cron = "0/5 * * * * ?")
    public void execute2(){
 
        String curName = Thread.currentThread().getName() ;
        System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute2对应的线程名: "+curName);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

通过执行可以看到,打印线程名称为同一个。即如果不手动指定线程池,则默认启动单线程,进行执行定时任务。

如果想要多个定时任务重叠执行,需要手动指定线程池,如下

import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Component;
 
import java.time.LocalDateTime;
 
@Component
@EnableScheduling
public class MyScheduled {
 
    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(50);
        return taskScheduler;
    }
 
    @Scheduled(cron = "0/5 * * * * ?")
    public void execute1(){
        String curName = Thread.currentThread().getName() ;
        System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute1对应的线程名: "+curName);
        try {
            Thread.sleep(1000);
        } catch (Exception e) {
            e.printStackTrace();
        }
 
    }
 
    @Scheduled(cron = "0/5 * * * * ?")
    public void execute2(){
 
        String curName = Thread.currentThread().getName() ;
        System.out.println("当前时间:"+LocalDateTime.now()+"  任务execute2对应的线程名: "+curName);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

此时,多个定时任务,是不通的线程执行,同时,定时任务可以重叠执行。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • 在Python中生成二维码的详细步骤

    在Python中生成二维码的详细步骤

    二维码(QR Code)作为一种快速响应码,因其高效的信息存储和便捷的扫描方式,在现代生活中得到了广泛应用,Python作为一门功能强大的编程语言,通过其丰富的第三方库,可以轻松实现二维码的生成,本文详细介绍在Python中生成二维码的详细步骤和用法
    2024-09-09
  • python中SQLAlchemy使用前端页面实现插入数据

    python中SQLAlchemy使用前端页面实现插入数据

    这篇文章主要介绍了SQLAlchemy使用前端页面实现插入数据,文章内容介绍详细巨头有一定的参考价值,需要的小伙伴可以参考一下
    2022-03-03
  • 使用python客户端访问impala的操作方式

    使用python客户端访问impala的操作方式

    这篇文章主要介绍了使用python客户端访问impala的操作方式,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-03-03
  • 浅析Python中接口与抽象基类的使用

    浅析Python中接口与抽象基类的使用

    这篇文章主要为大家详细介绍了Python中两个为面向对象编程提供的强大工具接口和抽象基类的使用,感兴趣的小伙伴可以跟随小编一起学习一下
    2024-12-12
  • Selenium 安装和简单使用的实现

    Selenium 安装和简单使用的实现

    这篇文章主要介绍了Selenium 安装和简单使用的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-12-12
  • python3 使用ssh隧道连接mysql的操作

    python3 使用ssh隧道连接mysql的操作

    这篇文章主要介绍了python3 使用ssh隧道连接mysql的操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-12-12
  • python3自动更新缓存类的具体使用

    python3自动更新缓存类的具体使用

    本文介绍了使用一个自动更新缓存的Python类AutoUpdatingCache,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2025-01-01
  • 解决python删除文件的权限错误问题

    解决python删除文件的权限错误问题

    下面小编就为大家分享一篇解决python删除文件的权限错误问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-04-04
  • Python Flask异步发送邮件实现方法解析

    Python Flask异步发送邮件实现方法解析

    这篇文章主要介绍了Python Flask异步发送邮件实现方法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-08-08
  • 对网站内嵌gradio应用的输入输出做审核实现详解

    对网站内嵌gradio应用的输入输出做审核实现详解

    这篇文章主要为大家介绍了对网站内嵌gradio应用的输入输出做审核实现详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-04-04

最新评论