Jave 定时任务:使用Timer类执行定时任务为何会发生任务阻塞?如何解决?

IDE:IntelliJ IDEA 2022.2.3 x64
操作系统:win10 x64 位 家庭版
JDK: 1.8


文章目录

  • 一、Timer类是什么?
  • 二、Timer类主要由哪些部分组成?
    • 1.TaskQueue
    • 2. TimerThread
  • 三、示例代码分析
  • 四、自定义TimerTask为什么会发生任务相互阻塞的问题?
    • 4.1 使用schedule添加任务,如任务执行超时,会导致任务丢失(少执行)
    • 4.2 使用scheduleAtFixedRate添加任务,如任务执行超时,会导致任务执行时间乱掉,下一个任务会马上执行
  • 五、Timer类的应用特性
  • 六、如何解决任务阻塞问题?


在这里插入图片描述


提示:以下是本篇文章正文内容,下面案例可供参考

一、Timer类是什么?

Java Timer类是一个用于调度任务的类,它可以在指定的时间间隔内执行一次或多次任务。它提供了一种简单的方式来安排和执行定时任务,可以用于各种应用程序中,如计划任务、定时器等。

Java Timer类位于java.util包中,它有两个主要的子类:Timer和TimerTask。其中,Timer类用于调度任务,而TimerTask类则表示一个具体的任务,需要实现run()方法来定义任务的具体行为。

使用Java Timer类可以方便地创建和管理定时任务,但需要注意的是,它的精度有限,如果需要更高精度的任务调度,可以考虑使用ScheduledThreadPoolExecutor等其他工具。


二、Timer类主要由哪些部分组成?

在这里插入图片描述

1.TaskQueue

官方解释

The timer task queue:This data structure is shared with the timer thread. The timer produces tasks, via its various schedule calls, and
the timer thread consumes, executing timer tasks as appropriate, and
removing them from the queue when they’re obsolete.

在这里插入图片描述

一句话,就是一个用于存储和处理任务的队列,里面存放TimeTask

2. TimerThread

官方解释

The timer thread.

在这里插入图片描述

显而易见,就是处理线任务的线程


三、示例代码分析

示例代码如下所示

import java.util.Date;
import java.util.Timer;
import java.util.TimerTask;

public class myTimerTest {

    public static void main(String[] args){
        Timer timer = new Timer(); //任务执行
        for (int i = 0; i < 2 ; i++) {
           TimerTask timerTask = new FooTimerTask("FooTimerTask"+i);
           //将timerTask以当前时间执行,以2秒时间为间隔再次触发,即12:00:00执行,那么12:00:02 会再次触发执行
           timer.schedule(timerTask,new Date(),2000);//任务添加
        }

    }
}

class FooTimerTask extends TimerTask {

    private String name;

    public FooTimerTask(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        try {
            System.out.println(name+" - startTime = "+new Date());
            //延迟3秒执行
            Thread.sleep(3000);
            System.out.println(name+" - endTime = "+new Date());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}


注意

其中,任务会在 Timer timer = new Timer();时执行,而并非大家认为的在timer.schedule(timerTask,new Date(),2000);时执行,该代码是将该timerTask添加到TaskQueue中(任务队列中)

不信,请看如下的源代码

①在new Timer()时执行任务
在这里插入图片描述

在这里插入图片描述
在这里插入图片描述

在这里插入图片描述

②在timer.schedule(timerTask,new Date(),2000)时添加任务至任务队列中
在这里插入图片描述
在这里插入图片描述

通过上述源代码演示,Timer类是在new Timer()中以多线程的方式运行TimerThread的start()方法,进而调用其中的run()方法。而我们自子自定义的FooTimerTask 的run()方法却是以单线程的方式被调用。
在TimerThread中的run方法中mainLoop方法里以死循环不断检查是否有任务需要开始执行了,有就执行它,执行任务也是用这个线程执行。

何以见得?

在mainLoop方法中
在这里插入图片描述
我们自定义的FooTimerTask会以单线程的方式执行,这样任务可能会相互阻塞


四、自定义TimerTask为什么会发生任务相互阻塞的问题?

4.1 使用schedule添加任务,如任务执行超时,会导致任务丢失(少执行)

示例代码如下所示

public class myTimerTest {

    public static void main(String[] args){
        Timer timer = new Timer(); //任务执行
        for (int i = 0; i < 2 ; i++) {
           TimerTask timerTask = new FooTimerTask("FooTimerTask"+i);
           //将timerTas以当前时间执行,间隔2s后触发执行,比如在12:00:00执行timerTas,下一次触发就是12:00:02时执行,余者类推
           timer.schedule(timerTask,new Date(),2000);//任务添加
        }

    }
}

class FooTimerTask extends TimerTask {

    private String name;

    public FooTimerTask(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        try {
            System.out.println(name+" - startTime = "+new Date());
            //延迟3秒执行
            Thread.sleep(3000);
            System.out.println(name+" - endTime = "+new Date());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

示例运行如下

在这里插入图片描述

这里有个问题:根据上述代码定义,自定义timerTask会在间隔2s后执行,而timerTask自己的执行会延迟3s才会真正结束,那么我们所推测它的执行场景应该是这样的:

假如任务A在12:00:00开始执行,12:00:03执行结束,那么下一个任务B将会在12:00:05开始执行

但上述代码的运行结果却与我们的推测 大相径庭

思考①

那如果timerTask去掉延迟3s的代码,运行结果应该是如“任务A在12:00:00开始执行,12:00:0执行结束,那么下一个任务B将会在12:00:03开始执行”这样执行吧?

代码示例如下

class FooTimerTask extends TimerTask {

    private String name;

    public FooTimerTask(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        System.out.println(name+" - startTime = "+new Date());
        System.out.println(name+" - endTime = "+new Date());
//        try {
//            System.out.println(name+" - startTime = "+new Date());
//            //延迟3秒执行
//            Thread.sleep(3000);
//            System.out.println(name+" - endTime = "+new Date());
//        } catch (InterruptedException e) {
//            e.printStackTrace();
//        }
    }
}

运行如下
在这里插入图片描述
看来,任务阻塞的问题就出现在延迟3s的代码上

思考②

如果一个任务本身执行时间过长,超过预设的时间间隔(即任务执行超时),为什么会发生任务阻塞的问题?

任务阻塞问题;会导致后面的任务往后推移,预想在这个间隔内存在的任务执行就没了,任务少执行了【假如在10s的时间段内,任务正常执行5次,假如发生任务超时,可能会执行3-4次】

通过如下追踪源代码可知

①追踪进入schedule()方法中
在这里插入图片描述

注意:schedule方法将period值加了负号,即-period

②追踪进入sched()方法中
在这里插入图片描述

任务task的nextExecutionTime被赋值为time(传入的时间)

③追踪进入run()方法中的mainLoop()方法中
在这里插入图片描述

④追踪进入queue.rescheduleMin()方法中
在这里插入图片描述
⑤追踪进入fixDown()方法中
在这里插入图片描述

结论

由此可知,schedule里Timertask真正的执行时间取决上一个任务的结束时间,并非以预设的时间为准,故如某一个任务执行超时,则有可能出现任务丢失的问题

4.2 使用scheduleAtFixedRate添加任务,如任务执行超时,会导致任务执行时间乱掉,下一个任务会马上执行

示例代码如下所示

public class myTimerTest {

    public static void main(String[] args){
        Timer timer = new Timer(); //任务执行
        for (int i = 0; i < 2 ; i++) {
           TimerTask timerTask = new FooTimerTask("FooTimerTask"+i);
            timer.scheduleAtFixedRate(timerTask,new Date(),2000);
        }
    }
}

class FooTimerTask extends TimerTask {

    private String name;

    public FooTimerTask(String name) {
        this.name = name;
    }

    @Override
    public void run() {
        try {
            System.out.println(name+" - startTime = "+new Date());
            //延迟3秒执行
            Thread.sleep(3000);
            System.out.println(name+" - endTime = "+new Date());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

运行如下

在这里插入图片描述

思考

为什么一旦任务发生超时,下一个任务会马上触发执行?

通过如下追踪源代码可知

①追踪进入schedule()方法中
在这里插入图片描述

②追踪进入sched()方法中
在这里插入图片描述

任务task的nextExecutionTime被赋值为time(传入的时间)

③追踪进入run()方法中的mainLoop()方法中
在这里插入图片描述

注:剩余追踪步骤和4.1小节一致,故不予展示

结论

scheduLeAtFixedRate()方法会严格按照预设时间作为TimerTask的执行时间,如果发生任务超时,下一个任务会直接触发


五、Timer类的应用特性

  • 运行时异常会导致timer线程终止
  • 任务调度是基于绝对时间的,对系统时间敏感

六、如何解决任务阻塞问题?

解决方案

在自定义TimerTask里的run()方法里使用线程池去执行,即可解决上述问题


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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Actor对象的引用 怎么设置他的材质?或设置是否启用重力?

这个蓝图我是想当重叠触发,将另一个Target Actor(一个球体)设置他的z增加50,但是为什么在触发的时候会抽搐?而且我想要设置他的材质等等这些属性都不行

SQL INSERT INTO 语句详解:插入新记录、多行插入和自增字段

SQL INSERT INTO 语句用于在表中插入新记录。 INSERT INTO 语法 可以以两种方式编写INSERT INTO语句&#xff1a; 指定要插入的列名和值&#xff1a; INSERT INTO 表名 (列1, 列2, 列3, ...) VALUES (值1, 值2, 值3, ...);如果要为表的所有列添加值&#xff0c;则无需在SQL…

【Linux】-进程间通信-匿名管道通信(以及模拟一个进程池)

&#x1f496;作者&#xff1a;小树苗渴望变成参天大树&#x1f388; &#x1f389;作者宣言&#xff1a;认真写好每一篇博客&#x1f4a4; &#x1f38a;作者gitee:gitee✨ &#x1f49e;作者专栏&#xff1a;C语言,数据结构初阶,Linux,C 动态规划算法&#x1f384; 如 果 你 …

16.live555mediaserver-保活机制

live555工程代码路径 live555工程在我的gitee下&#xff08;doc下有思维导图、drawio图&#xff09;&#xff1a; live555 https://gitee.com/lure_ai/live555/tree/master 章节目录链接 0.前言——章节目录链接与为何要写这个&#xff1f; https://blog.csdn.net/yhb1206/art…

解析Spring Boot中的CommandLineRunner和ApplicationRunner:用法、区别和适用场景详解

在Spring Boot应用程序中&#xff0c;CommandLineRunner和ApplicationRunner是两个重要的接口&#xff0c;它们允许我们在应用程序启动后执行一些初始化任务。本文将介绍CommandLineRunner和ApplicationRunner的区别&#xff0c;并提供代码示例和使用场景&#xff0c;让我们更好…

PWM实验

PWM相关概念 PWM:脉冲宽度调制定时器 脉冲&#xff1a;方波信号&#xff0c;高低电平变化产生方波 周期&#xff1a;高低电平变化所需要时间 频率&#xff1a;1s钟可以产生方波个数 占空比&#xff1a;在一个方波内&#xff0c;高电平占用的百分比 宽度调制&#xff1a;占…

飞鼠异地组网工具实战之访问k8s集群内部服务

飞鼠异地组网工具实战之访问k8s集群内部服务 一、飞鼠异地组网工具介绍1.1 飞鼠工具简介1.2 飞鼠工具官网 二、本次实践介绍2.1 本次实践场景描述2.2 本次实践前提2.3 本次实践环境规划 三、检查本地k8s集群环境3.1 检查k8s各节点状态3.2 检查k8s版本3.3 检查k8s系统pod状态 四…

RVC从入门到......

RVC变声器官方教程&#xff1a;10分钟克隆你的声音&#xff01;一键训练&#xff0c;低配显卡用户福音&#xff01;_哔哩哔哩_bilibili配音&#xff1a;AI逍遥散人&#xff08;已授权&#xff09;关注UP主并私信"RVC"&#xff08;三个字母&#xff09;自动获取一键训…

PL/SQL编程

一、Oracle常用函数 concat&#xff1a;用于连接两个字符串。 CONCAT(Oraok, .com) -- Result: Oraok.com ceil&#xff1a;小数点向上取整。 secect ceil(7.3) from dual --Result: 8 dual表是oracle系统为计算设计的一张临时表 select sysdate as 系统日期 from dual…

基于寄生捕食算法优化概率神经网络PNN的分类预测 - 附代码

基于寄生捕食算法优化概率神经网络PNN的分类预测 - 附代码 文章目录 基于寄生捕食算法优化概率神经网络PNN的分类预测 - 附代码1.PNN网络概述2.变压器故障诊街系统相关背景2.1 模型建立 3.基于寄生捕食优化的PNN网络5.测试结果6.参考文献7.Matlab代码 摘要&#xff1a;针对PNN神…

我的创作纪念日——365天

机缘 最开始我写博客没有什么特别的原因&#xff0c;主要是因为以下几点&#xff1a; 练习自己的语言组织能力 记录自己学习生活中学到的知识 主要还是想找一个好的保存 Markdown 笔记的平台。 最终我选择了 CSDN&#xff0c;一来是因为 CSDN 对 Markdown 语法的支持较为全面…

NSSCTF第13页(2)

[HNCTF 2022 Week1]Challenge__rce 提示?hint 访问看到了源码 <?php error_reporting(0); if (isset($_GET[hint])) { highlight_file(__FILE__); } if (isset($_POST[rce])) { $rce $_POST[rce]; if (strlen($rce) < 120) { if (is_string($rce…

图片降噪软件 Topaz DeNoise AI mac中文版功能

Topaz DeNoise AI for Mac是一款专业的Mac图片降噪软件。如果你有噪点的相片&#xff0c;可以通过AI智能的方式来处理掉噪点&#xff0c;让照片的噪点降到最 低。有了Topaz DeNoise AI mac版处理图片更方便&#xff0c;更简单。 Topaz DeNoise AI mac软件功能 无任何预约即可在…

基于阿基米德优化算法优化概率神经网络PNN的分类预测 - 附代码

基于阿基米德优化算法优化概率神经网络PNN的分类预测 - 附代码 文章目录 基于阿基米德优化算法优化概率神经网络PNN的分类预测 - 附代码1.PNN网络概述2.变压器故障诊街系统相关背景2.1 模型建立 3.基于阿基米德优化优化的PNN网络5.测试结果6.参考文献7.Matlab代码 摘要&#xf…

IntelliJ IDEA 2023 v2023.2.5

IntelliJ IDEA 2023是一款功能强大的集成开发环境&#xff08;IDE&#xff09;&#xff0c;为开发人员提供了许多特色功能&#xff0c;以下是其特色介绍&#xff1a; 新增语言支持&#xff1a;IntelliJ IDEA 2023新增对多种编程语言的支持&#xff0c;包括Kotlin、TypeScript、…

Windows网络「SSL错误问题」及解决方案

文章目录 问题方案 问题 当我们使用了神秘力量加持网络后&#xff0c;可能会和国内的镜像源网站的之间发生冲突&#xff0c;典型的有 Python 从网络中安装包&#xff0c;如执行 pip install pingouin 时&#xff0c;受网络影响导致无法完成安装的情况&#xff1a; pip config…

【飞控调试】DJIF450机架+Pixhawk6c mini+v1.13.3固件+好盈Platinium 40A电调无人机调试

1 背景 由于使用了一种新的航电设备组合&#xff0c;在调试无人机起飞的时候遇到了之前没有遇到的问题。之前用的飞控&#xff08;Pixhawk 6c&#xff09;和电调&#xff08;Hobbywing X-Rotor 40A&#xff09;&#xff0c;在QGC里按默认参数配置来基本就能平稳飞行&#xff0…

Nginx的核心配置文件

Nginx的核心配置文件 学习Nginx首先需要对它的核心配置文件有一定的认识&#xff0c;这个文件位于Nginx的安装目录/usr/local/nginx/conf目录下&#xff0c;名字为nginx.conf 详细配置&#xff0c;可以参考resources目录下的<<nginx配置中文详解.conf>> Nginx的核…

JavaScript实现飞机发射子弹详解(内含源码)

JavaScript实现飞机发射子弹 前言实现过程源码展示源码讲解HTML结构CSS结构js结构 前言 文本主要讲解如何利用JavaScript实现飞机发射子弹&#xff0c;实现过程以及源码讲解。实现效果图如下&#xff1a; 实现过程 首先&#xff0c;找到飞机和子弹的UI图&#xff0c;gif图最…

局域网内Ubuntu上搭建Git服务器

1.在局域网内选定一台Ubuntu电脑作为Git服务端&#xff1a; (1).新建用户如为fbc&#xff0c;执行如下命令&#xff1a;需设置密码&#xff0c;此为fbc sudo adduser fbc (2).切换到fbc用户&#xff1a;需密码&#xff0c;此前设置为fbc su fbc (3).建一个空目录作为仓…