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

SpringBoot定时任务 - Timer实现方式

定时任务在实际开发中有着广泛的用途,本文主要帮助你构建定时任务的知识体系,同时展示Timer 的schedule和scheduleAtFixedRate例子;后续的文章中我们将逐一介绍其它常见的与SpringBoot的集成。

知识准备

需要对定时任务的使用场景和常见的实现方式。

什么样的场景会使用定时任务?

比如每天/每周/每月生成日志汇总,定时发送推送信息,定时生成数据表格等

定时任务有哪些实现方式?

首先你需要构建如下实现定时任务的知识体系。在后续的文章中我们将逐一介绍在SpringBoot下的集成。

  • 定时任务基础
    • Cron表达式
    • Linux定时任务工具crontb
  • JDK内置
    • Timer
    • ScheduleExecutorService
  • Netty
    • HashedWheelTimer
  • Spring
    • Spring自带Schedule
    • Spring集成Quartz
  • 分布式集群
    • Quartz持久化JDBC方式
    • Elastic-job
    • xxl-job

Timer实现案例

Timer 的schedule和scheduleAtFixedRate例子如下。

schedule延迟任务

执行定时任务,延迟1秒开始执行。

@SneakyThrows
public static void timer() {// start timerTimer timer = new Timer();timer.schedule(new TimerTask() {public void run() {log.info("timer-task @{}", LocalDateTime.now());}}, 1000);// waiting to process(sleep to mock)Thread.sleep(3000);// stop timertimer.cancel();
}

输出

10:05:47.440 [Timer-0] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-task @2021-10-01T20:05:47.436

schedule周期任务

延迟0.5秒开始执行,每秒执行一次, 10秒后停止。

@SneakyThrows
public static void timerPeriod() {// start timerTimer timer = new Timer();timer.schedule(new TimerTask() {@SneakyThrowspublic void run() {log.info("timer-period-task @{}", LocalDateTime.now());Thread.sleep(100); // 可以设置的执行时间, 来测试当执行时间大于执行周期时任务执行的变化 }}, 500, 1000);// waiting to process(sleep to mock)Thread.sleep(10000);// stop timertimer.cancel();
}

输出

10:05:49.781 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:49.781
10:05:50.781 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:50.781
10:05:51.781 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:51.781
10:05:52.781 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:52.781
10:05:53.782 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:53.782
10:05:54.783 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:54.783
10:05:55.783 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:55.783
10:05:56.784 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:56.784
10:05:57.785 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:57.785
10:05:58.786 [Timer-1] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-period-task @2021-10-01T10:05:58.786

scheduleAtFixedRate

延迟0.5秒开始执行,每秒执行一次, 10秒后停止。

同时测试某次任务执行时间大于周期时间的变化。

@SneakyThrows
public static void timerFixedRate() {// start timerTimer timer = new Timer();timer.scheduleAtFixedRate(new TimerTask() {int count = 0;@SneakyThrowspublic void run() {if (count++==2) {Thread.sleep(5000); // 某一次执行时间超过了period(执行周期)}log.info("timer-fixedRate-task @{}", LocalDateTime.now());}}, 500, 1000);// waiting to process(sleep to mock)Thread.sleep(10000);// stop timertimer.cancel();
}

输出

10:05:59.781 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:05:59.781
10:06:00.782 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:00.782
10:06:06.783 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:06.783
10:06:06.783 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:06.783
10:06:06.783 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:06.783
10:06:06.783 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:06.783
10:06:06.783 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:06.783
10:06:06.783 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:06.783
10:06:07.781 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:07.781
10:06:08.781 [Timer-2] INFO tech.aizer.springboot.schedule.timer.timertest.TimerTester - timer-fixedRate-task @2021-10-01T10:06:08.781

(你会发现周期执行1秒中执行一次,但是某次执行了5秒,这时候,后续的任务会加快执行进度,一次性就执行了,执行的时间都是10:06:06.783, 所以scheduleAtFixedRate最大的特点是保证了总时间段内的执行次数

进一步理解

我们再通过一些问题来帮助你更深入理解Timer实现方式。

schedule 和 scheduleAtFixedRate 有何区别?

  • schedule:每次执行完当前任务后,然后间隔一个period的时间再执行下一个任务; 当某个任务执行周期大于时间间隔时,依然按照间隔时间执行下个任务,即它保证了任务之间执行的间隔
  • scheduleAtFixedRate:每次执行时间为上一次任务开始起向后推一个period间隔,也就是说下次执行时间相对于上一次任务开始的时间点;按照上述的例子,它保证了总时间段内的任务的执行次数

为什么几乎很少使用Timer这种方式?

Timer底层是使用一个单线来实现多个Timer任务处理的,所有任务都是由同一个线程来调度,所有任务都是串行执行,意味着同一时间只能有一个任务得到执行,而前一个任务的延迟或者异常会影响到之后的任务。

如果有一个定时任务在运行时,产生未处理的异常,那么当前这个线程就会停止,那么所有的定时任务都会停止,受到影响。

PS:在这点上你可以看到,定时任务Job中异常超时等一般都是要自行处理的,以防止对其它任务的影响。

http://www.lqws.cn/news/534727.html

相关文章:

  • 算法打卡 day4
  • 大数据赋能智慧城市:从数据洪流到科学规划的“智慧之匙”
  • Leetcode百题斩-DP
  • 全面学习 OpenAI API:从 Python 教程到 API Key 使用详解,快速上手调用和部署
  • 微服务分布式事务解决方案
  • Beam2.61.0版本消费kafka重复问题排查
  • Git 使用规范与命令使用场景详解
  • 【Excel数据分析】花垣县事业单位出成绩了,用Excel自带的M语言做一个数据分析
  • 45. 跳跃游戏 II
  • uniapp 和原生插件交互
  • Sentinel 授权规则详解与自定义异常处理
  • Tailwind CSS 尺寸控制
  • c++多线程编程
  • 《聊一聊ZXDoc》之汽车标定、台架标定、三高标定
  • 基于定制开发开源AI智能名片S2B2C商城小程序源码的H5游戏开发模式创新研究
  • 从零开始的云计算生活——第二十四天,重起航帆,初见MySQL数据库
  • 智能体决策框架对决:ReAct极速响应 vs Plan-and-Execute稳控全局
  • 【全志V821_FoxPi】3-2 Linux 5.4 SPI + XPT2046触摸(ADS7846) + tslib
  • SQL SERVER存储过程
  • 分享一些实用的PHP函数(对比js/ts实现)
  • VIVADO设定寄存器/存储器的初始值
  • 深入解析与修复 Linux 中的种种依赖项错误:Dependencies packages error solution
  • 【UniApp 日期选择器实现与样式优化实践】
  • 03.图生图基础工作流|提示词自动化|存储节点预设|提示词风格化
  • 以太网基础与 VLAN 配置实验
  • Vue3中的watch详解:掌握响应式侦听的艺术
  • 本地部署开源时间跟踪工具 Kimai 并实现外部访问( Windows 版本)
  • springboot集成mqtt收发消息
  • python + opencv实现简单的文字水印
  • 【LLM论文阅读】