SpringBoot 定时任务实践、定时任务按指定时间执行

Q1. springboot怎样创建定时任务?

很显然,人人都知道,@Scheduled(cron = ".....")

Q2. 如上所示创建了定时任务却未能执行是为什么?

如果你的cron确定没写错的话

cron表达式是否合法,可参考此处,https://tool.lu/crontab/,选择Spring表达式。

那么可能是你启动类少了一个注解:@EnableScheduling
如下图
在这里插入图片描述


Q3. 多个定时任务,未能严格按照指定的时间执行,为什么?

比如有4个定时任务,分别是每天凌晨的1点整、2点整、3点整、4点整执行;
但观察日志发现并不是。
比如1点整开始执行第一个(如果会执行很久的话)
2点半才开始执行第2个
后面的以此类推都不一定严格按照指定时间。
那么,为什么?

因为springboot里面的定时任务默认是单线程执行的。后面的定时任务会排队、顺延。
比如Job1执行了1.5h,Job2的时间尽管到了,但没有线程可用,就只能等Job1完成之后才执行。
所以就会出现顺延现象。

Q4. 如何确保定时任务在特定时间执行?

这里思路就很简单了,多线程,即创建一个线程池,比如4个线程,并且指定使用这个线程池里的线程来做这4个定时任务,肯定是足够的。
这样的话就不会依次影响了。

注意,只给定时任务增加@Async注解是不够的。

step1,初始化线程池

文件1, SchedulerConfig.java
package cn.xxx.starter.config;import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;import javax.annotation.Resource;/*** @author * @date 2024/4/2 14:22* @desc*/
@Configuration
public class SchedulerConfig implements SchedulingConfigurer {@Resourceprivate ThreadPoolTaskScheduler threadPoolTaskScheduler;@Overridepublic void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {scheduledTaskRegistrar.setTaskScheduler(threadPoolTaskScheduler);}
}
文件2, ThreadPoolTaskSchedulerConfig.java
package cn.xxx.starter.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;import java.util.concurrent.Executor;/*** @author * @date 2024/4/1 17:45* @desc*/
@Configuration
@EnableAsync
public class ThreadPoolTaskSchedulerConfig {private int corePoolSize = 4;@Beanpublic ThreadPoolTaskScheduler threadPoolTaskScheduler() {ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler();//线程池大小为10threadPoolTaskScheduler.setPoolSize(corePoolSize);//设置线程名称前缀threadPoolTaskScheduler.setThreadNamePrefix("AsyncJob-thread-");//关键点: 设置线程池关闭的时候等待所有任务都完成再继续销毁其他的BeanthreadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true);//关键点:设置线程池中任务的等待时间,如果超过这个时候还没有销毁就强制销毁,以确保应用最后能够被关闭,而不是阻塞住threadPoolTaskScheduler.setAwaitTerminationSeconds(60 * 60);threadPoolTaskScheduler.initialize();return threadPoolTaskScheduler;}
}

step2 ,启动定时任务时指定使用此线程池

XxxxJob.java

package cn.xxx.starter.task.job;import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Slf4j
@Component
public class Job1{@Async(value = "threadPoolTaskScheduler")@Scheduled(cron = "0 30 */1 * * ?")public void execute() {       try {//......}catch (Exception e){log.error("Job1出错 e = {}, stackTrace = {} ", e.getMessage(), JSON.toJSONString(e.getStackTrace()));}finally {log.info("Job1结束");       }}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/802397.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Android集成微信支付

官方api:Android接入指南 | 微信开放文档 打开微信开放平台登录账户后点击创建应用 根据提示填写完相应的内容提交审核通过后,需要开通支付权限。 1.接着在你的项目工程build.gradle文件中添加微信支付依赖库 ​api com.tencent.mm.opensdk:wechat-sdk…

python代码使用过程中使用快捷键注释时报错

1.代码 2.代码报错 3.代码注释后的结果 4. 原因

sql注入方式之联合注入

1.1 靶场环境 系统centos7 IP地址192.168.1.24 1.2 联合注入原理 联合查询注入是联合两个表进行注入攻击,使用关键词 union select 对两个表进行联合查询。两个表的字段要数要相同,不然会出现报错。 1.3 找注入点 找注入点,当输入id1 an…

C语言——文件管理

文件:即磁盘上的文件,使用文件可以将数据直接存放在电脑的硬盘上,做到数据持久化。 在程序设计中,按文件的功能划分,将文件分为程序文件与数据文件 程序文件 程序文件包括源文件(.c)&#xff0…

Centos7搭建 Skywalking 单机版

介绍 Skywalking是应用性能监控平台,可用于分布式系统,支持微服务、云原生、Docker、Kubernetes 等多种架构场景。 整体架构如图 Agent :在应用中,收集 Trace、Log、Metrics 等监控数据,使用 RPC、RESTful API、Kafk…

【算法详解】二分查找

1. 二分查找算法介绍 「二分查找算法(Binary Search Algorithm)」:也叫做 「折半查找算法」、「对数查找算法」。是一种在有序数组中查找某一特定元素的搜索算法。 基本算法思想:先确定待查找元素所在的区间范围,在逐步…

骨传导耳机哪个品牌质量比较好?精选六大必看的耳机选购指南

骨传导耳机,是作为近年来深受消费者喜欢的蓝牙耳机产品,目前已经成为了热度最高的骨蓝牙耳机。然而,随着骨传导耳机的热度增高,市场上开始出现一些质量参差不齐、音质不佳的劣质产品,如果使用这些劣质产品的话&#xf…

C语言从入门到实战————文件操作

目录 前言 1. 为什么使用文件? 2. 什么是文件? 2.1 程序文件 2.2 数据文件 2.3 文件名 3. ⼆进制文件和文本文件? 4. 文件的打开和关闭 4.1 流和标准流 4.1.1 流 4.1.2 标准流 4.2 文件指针 4.3 文件的打开和关闭 5. 文…

基于java+springboot+vue实现的旅游管理系统(文末源码+Lw)23-234

摘 要 如今社会上各行各业,都喜欢用自己行业的专属软件工作,互联网发展到这个时候,人们已经发现离不开了互联网。新技术的产生,往往能解决一些老技术的弊端问题。因为传统旅游管理系统信息管理难度大,容错率低&#…

使用yolov8实现自动车牌识别(教程+代码)

该项目利用了一个被标记为“YOLOv8”的目标检测模型,专门针对车牌识别任务进行训练和优化。整个系统通常分为以下几个核心步骤: 数据准备: 收集包含车牌的大量图片,并精确地标记车牌的位置和文本信息。数据集可能包含各种环境下的…

短剧小程序开发:解锁碎片时间的观影新风尚

随着移动互联网的飞速发展,人们对内容的消费方式也在不断升级。短剧作为一种新型的内容形态,正逐渐受到广大用户的青睐。为了满足用户随时随地观看短剧的需求,我们推出了全新的短剧小程序开发服务,为您解锁碎片时间的观影新风尚。…

C/C++中局部变量static用法实例

1. 普通局部变量存储于进程栈空间,使用完毕会立即释放,静态局部变量使用static修饰符定义,即使在声明时未赋初值,编译器也会把它初始化为0,并且静态局部变量存储于进程的全局数据区,即使函数返回&#xff0…

解密项目管理专业术语:十大名词背后的实战技巧

项目管理是一门综合学科,涵盖了一系列方法、技能和工具。今天为大家带来项目管理的十大专业术语,它们分别是项目范围、利益相关者管理、工作分解结构(WBS)、里程碑、风险管理、资源分配、关键路径法(CPM)、…

双向链表介绍

目录 1. 双向链表的结构 2. 双向链表的实现 初始化哨兵位: 打印链表: 尾插: 头插: 尾删: 头删: 查找: 在指定位置之后插入数据: 删除目标位置的数据: 销毁链…

CAXA电子图版2020版 下载地址及安装教程

CAXA电子图板是一款由国内软件公司CAXA开发的专业CAD(计算机辅助设计)软件。它主要用于绘制和编辑各种类型的二维图纸和工程图纸,广泛应用于建筑、机械、电气和电子等行业。 CAXA电子图板具有以下主要功能和特点: 二维绘图&…

什么是自动化测试?深入了解其作用!

本文介绍了自动化测试的概念,以及为什么重要。自动化测试可以帮助你节省时间和金钱,并提高你的软件质量 自动化测试是指利用工具模拟人为操作,自动执行测试用例,并生成测试结果的过程。它是一种高效、准确、一致的测试方法&#…

C++手撕红黑树

文章目录 红黑树概念性质(条件限制)节点的定义红黑树的结构红黑树的插入cur为红,p为红,g为黑,u存在且为红cur为红,p为红,g为黑,u不存在或u为黑,插入到p对应的一边cur为红…

02 _ 分布式系统的指标:啥是分布式的三围

你好,我是聂鹏程。 在上一篇文章中,通过对分布式发展历程的学习,我们对分布式技术有了一个整体印象。接下来,我们就再来看看可以用哪些指标去具体地衡量一个分布式系统。如果你已经对分布式系统的指标了解得很清楚了,…

群晖NAS使用Docker部署Potopea在线图片编辑工具并实现公网访问

文章目录 1. 部署Photopea2. 运行Photopea3. 群晖安装Cpolar4. 配置公网地址5. 公网访问测试6. 固定公网地址 本文主要介绍如何在群晖NAS使用Docker部署Potopea在线图片编辑工具,并结合cpolar内网穿透实现公网环境可以远程访问本地部署的Potopea. Photopea是一款强大…

第十五届蓝桥杯测试组模拟赛两期

文章目录 功能测试一期-场景法-登录功能一期-等价类-边界值-添加用户账号输入框一期-登录-缺陷报告一期- UI自动化测试一期-单元测试-路径覆盖二期-正交法-搜索条件组合二期-测试用例二期-缺陷报告二期-自动化测试二期-单元测试-基本路径覆盖 功能测试 一期-场景法-登录功能 …