当前位置: 首页 > news >正文

java 定时任务不按照规定时间执行

这里写目录标题

  • 使用异步启动可能出现的问题
  • 排查代码中添加的定时任务步骤是否正确
  • 排查是否任务阻塞,如果定时任务出现异常阻塞后,将不会在次执行
  • java中多个@Scheduled定时器不执行
    • 为了让@Scheduled效率更高,我们可以通过两种方法将定时任务变成多线程执行:
      • 方法1、在启动类中配置TaskScheduler线程池大小:
      • 方法2、利用Spring提供的@Async注解和@EnableAsync注解
    • 方法三 主启动类添加线程
    • 或者使用配置类的形式
      • 定时任务测试

**是因为springboot默认给定时任务配置的线程池只有一个线程,当很多个定时任务都加了异步注解,没有配置线程池时,他们会因为只有一个线程出问题。
因为springboot的定时任务默认的线程池只有一个线程,就算加了异步,也不能使得一个任务结束下个任务才能开始,所以要配置一下或者重写定时任务的线程池,也可以将异步注解去掉,将异步注解去掉,springboot就会给定时任务配置一个固定的线程,不受干扰.
没有配置定时任务线程池时,默认用的是springboot分配给定时任务的线程池SimpleAsyncTaskExecutor,当一个服务定时任务过多时,会有问题比如你一个任务的周期是5秒,= 这5秒你要发送100条短信,用之前的固定的线程肯定没有问题,现在你改成多个线程。5秒如果你上个任务没有执行完成,那现在你任务的第二个周期到了还是会执行,如果没有控制可能会重复发=
**

使用异步启动可能出现的问题

会有问题比如你一个任务的周期是5秒, 这5秒你要发送100条短信,用之前的固定的线程肯定没有问题,现在你改成多个线程。5秒如果你上个任务没有执行完成,那现在你任务的第二个周期到了还是会执行,如果没有控制可能会重复发 

排查代码中添加的定时任务步骤是否正确

启动类上加 @EnableScheduling 注解
定时任务类上加@Component
定时方法上加@Scheduled

排查是否任务阻塞,如果定时任务出现异常阻塞后,将不会在次执行

解决:进行trycatch异常抛出

java中多个@Scheduled定时器不执行

原因是:@Scheduled注解会在默认情况下以单线程的方式执行定时任务。
这个“单线程”指两个方面:

如果一个定时任务执行时间大于其任务间隔时间,那么下一次将会等待上一次执行结束后再继续执行。
如果多个定时任务在同一时刻执行,任务会依次执行

为了让@Scheduled效率更高,我们可以通过两种方法将定时任务变成多线程执行:

方法1、在启动类中配置TaskScheduler线程池大小:

@Bean
public TaskScheduler taskScheduler() {
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(10);//不配置默认是1
return taskScheduler;
}

方法2、利用Spring提供的@Async注解和@EnableAsync注解

@Component
@EnableAsync   //开启异步支持
public class TimedTask{
@Async // 对某个方法进行异步执行
@Scheduled(initialDelay = 1,fixedDelay=10000)//initialDelay 在容器启动后,延迟1毫秒再执行一次定时器
//fixedDelay  以上一次方法执行完开始算起,如上一次方法执行阻塞住了,那么直到上一次执行完,并间隔给定的时间后,执行下一次
public void aa() {
//执行业务逻辑
}@Async
@Scheduled(initialDelay = 1,fixedDelay=10000)
public void bb() {
//执行业务逻辑
}

方法三 主启动类添加线程

复制代码
@Beanpublic Executor executor1() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setThreadNamePrefix("test-schedule1-");executor.setMaxPoolSize(20);executor.setCorePoolSize(15);executor.setQueueCapacity(10);executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());return executor;}
复制代码

或者使用配置类的形式

@Configuration
@EnableAsync
public class ExecutorConfig {@Beanpublic Executor executor1() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setThreadNamePrefix("test-schedule1-");executor.setMaxPoolSize(20);executor.setCorePoolSize(15);executor.setQueueCapacity(10);executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());return executor;}@Beanpublic Executor executor2() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setThreadNamePrefix("test-schedule2-");executor.setMaxPoolSize(20);executor.setCorePoolSize(15);executor.setQueueCapacity(10);executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());return executor;}}

定时任务测试

@Component
@Slf4j
@EnableScheduling
public class test {@Async("executor1")  //指定线程池bean的名字  为什么是这个名字,可以自行学习下spring 关于bean的生命周期和创建过程@Scheduled(cron = "0 0/1 * * * ?")public void test() {System.out.println(Thread.currentThread().getName());}
}
复制代码
@Component
@Slf4j
@EnableScheduling
public class test1 {@Async@Scheduled(cron = "0 0/1 * * * ?")public void test1() {System.out.println(Thread.currentThread().getName() + "-------");}
}

执行结果
可以看到未指定线程池,默认就会使用的是SimpleAsyncTaskExecutor
在这里插入图片描述
也可以选择不配置异步,用同步,那么springboot就会给它分配固定的线程,不会被干扰
– 没有配置定时任务线程池时,默认用的是springboot分配给定时任务的线程池SimpleAsyncTaskExecutor,
在这里插入图片描述

http://www.lryc.cn/news/106178.html

相关文章:

  • Android复习(Android基础-四大组件)—— Activity
  • Linux系统安装部署MongoDB完整教程(图文详解)
  • CSS图片放到<div>里面,自适应宽高全部显示,点击图片跳到新页面预览,点击旋转按钮图片可旋转
  • 二阶段web基础与http协议
  • SpringBoot+Freemark根据html模板动态导出PDF
  • XPath数据提取与贴吧爬虫应用示例
  • 字符串匹配-KMP算法
  • Java面向对象之UML类图
  • 【机器学习】西瓜书学习心得及课后习题参考答案—第4章决策树
  • 2023.8.2
  • windows运行窗口常用快捷键命令
  • HDFS的QJM方案
  • 安装win版本的neo4j(2023最新版本)
  • ChatGPT结合知识图谱构建医疗问答应用 (二) - 构建问答流程
  • 聊天系统登录后端实现
  • Ajax笔记_01(知识点、包含代码和详细解析)
  • Eureka 学习笔记2:EurekaClient
  • Spring引入并启用log4j日志框架-----Spring框架
  • Redis实现延时队列
  • 无限遍历,Python实现在多维嵌套字典、列表、元组的JSON中获取数据
  • 信息学奥赛一本通——1180:分数线划定
  • SpringApplication对象的构建及spring.factories的加载时机
  • 基于传统检测算法hog+svm实现图像多分类
  • slice() 方法,使用 concat() 方法, [...originalArray],find(filter),移出类名 removeAttr()
  • Zabbix报警机制、配置钉钉机器人、自动发现、主动监控概述、配置主动监控、zabbix拓扑图、nginx监控实例
  • ELK日志分析系统概述及部署
  • HTML拖拽
  • 【vue】 vue2 监听滚动条滚动事件
  • k8s目录
  • 设计模式行为型——解释器模式