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

news2024/9/24 23:33:14

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()方法里使用线程池去执行，即可解决上述问题

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

度加创作工具 演示

度加创作工具 演示

度加创作工具 功能图功能测试文比润色测试经验分享测试测试输出测试输出工具地址功能图 功能测试 文比润色测试 经验分享测试 测试输出 在人工智能领域，我们一直在追求一个终极目标：让机器能够像人类一样，能够理解、学习和解决各种复杂问题。而要实现这个目标，我们需要将…
阅读更多...
设计模式常见面试题

设计模式常见面试题

简单梳理下二十三种设计模式&#xff0c;在使用设计模式的时候&#xff0c;不仅要对其分类了然于胸&#xff0c;还要了解每个设计模式的应用场景、设计与实现&#xff0c;以及其优缺点。同时&#xff0c;还要能区分功能相近的设计模式&#xff0c;避免出现误用的情况。 什么是…
阅读更多...
麒麟系统安装找不到安装源！！！！设置基础软件仓库时出错

麒麟系统安装找不到安装源！！！！设置基础软件仓库时出错

记录--华为RH2288 V3服务器安装麒麟系统遇到的问题 1.遇到的问题--“设置基础软件仓库时出错”报错导致无法继续安装 没办法下一步 先说结论&#xff1a;系统bug 该问题在CentOS、Rocky Linux最新版中均存在 解决&#xff1a; &#xff08;一&#xff09;、如果是外网直接配…
阅读更多...
【机器学习基础】决策树（Decision Tree）

【机器学习基础】决策树（Decision Tree）

&#x1f680;个人主页&#xff1a;为梦而生~ 关注我一起学习吧&#xff01; &#x1f4a1;专栏&#xff1a;机器学习 欢迎订阅&#xff01;后面的内容会越来越有意思~ ⭐特别提醒&#xff1a;针对机器学习&#xff0c;特别开始专栏&#xff1a;机器学习python实战 欢迎订阅&am…
阅读更多...
metinfo 5.0.4 文件包含漏洞复现

metinfo 5.0.4 文件包含漏洞复现

metinfo 5.0.4 文件包含漏洞 漏洞环境 metinfo cms 版本 5.0.4 代码审计 在metinfo下的about/index.php代码中发现动态调用 上面没有赋值但是是有具体值的说明在上一个文件包含赋值了 查看这个文件的源代码 可以看到这里做了初始化但是是在fmodule不等于7的时候那假设等…
阅读更多...
深入解析具名导入es6规范中的具名导入是在做解构吗

深入解析具名导入es6规范中的具名导入是在做解构吗

先说答案&#xff0c;不是 尽管es6的具名导入和语法非常相似 es6赋值解构 const obj {a: 1,f() {this.a}}const { a, f } objes6具名导入 //导出文件代码export let a 1export function f() {a}export default {a,f}//导入文件代码import { a, f } from ./tsVolution可以看出…
阅读更多...
【Go入门】Web工作方式

【Go入门】Web工作方式

【Go入门】 Web工作方式 我们平时浏览网页的时候,会打开浏览器&#xff0c;输入网址后按下回车键&#xff0c;然后就会显示出你想要浏览的内容。在这个看似简单的用户行为背后&#xff0c;到底隐藏了些什么呢&#xff1f; 对于普通的上网过程&#xff0c;系统其实是这样做的&…
阅读更多...
gd32关于IO引脚配置的一些问题

gd32关于IO引脚配置的一些问题

一、gd32f103的PA15问题 1、 #define GPIO_SWJ_NONJTRST_REMAP ((uint32_t)0x00300100U) /*!< full SWJ(JTAG-DP SW-DP),but without NJTRST */ #define GPIO_SWJ_SWDPENABLE_REMAP ((uint32_t)0x00300200U) /*!< JTAG-DP disabled and SW-DP enab…
阅读更多...
【C++】——阶段性测验（帮助巩固C++前半部分知识）

【C++】——阶段性测验（帮助巩固C++前半部分知识）

&#x1f383;个人专栏&#xff1a; &#x1f42c; 算法设计与分析&#xff1a;算法设计与分析_IT闫的博客-CSDN博客 &#x1f433;Java基础&#xff1a;Java基础_IT闫的博客-CSDN博客 &#x1f40b;c语言&#xff1a;c语言_IT闫的博客-CSDN博客 &#x1f41f;MySQL&#xff1a…
阅读更多...
安装2023最新版PyCharm来开发Python应用程序

安装2023最新版PyCharm来开发Python应用程序

安装2023最新版PyCharm来开发Python应用程序 Install the Latest JetBrains PyCharm Community to Develop Python Applications Python 3.12.0最新版已经由其官网python.org发布&#xff0c;这也是2023年底的最新的版本。 0. PyCharm与Python 自从1991年2月20日&#xff0…
阅读更多...
Python---练习：封装一个函数，用于生成指定长度的验证码

Python---练习：封装一个函数，用于生成指定长度的验证码

练习涉及相关链接&#xff1a;Python---练习&#xff1a;编写一段Python代码&#xff0c;生成一个随机的4位验证码-CSDN博客 Python----函数中的说明文档-CSDN博客Python---return返回值-CSDN博客 代码&#xff1a; # 定义一个generate_code()函数 def generate_code(num): …
阅读更多...
语聚AI：无代码开发的API连接新选择，助力电商平台客户服务提升

语聚AI：无代码开发的API连接新选择，助力电商平台客户服务提升

无代码开发&#xff1a;语聚AI的新选择 在企业运营中&#xff0c;客户服务扮演着重要的角色。然而&#xff0c;许多企业在日常的客服管理中面临着重复咨询、人工接待成本高、缺乏知识库支持以及客服渠道分散等问题。如何提高客服的效率和质量&#xff0c;成为了企业急需解决的…
阅读更多...
最全的接口自动化测试思路和实战：【推荐】混合测试自动化框架(关键字+数据驱动)

最全的接口自动化测试思路和实战：【推荐】混合测试自动化框架(关键字+数据驱动)

混合测试自动化框架(关键字数据驱动) 关键字驱动或表驱动的测试框架 这个框架需要开发数据表和关键字。这些数据表和关键字独立于执行它们的测试自动化工具&#xff0c;并可以用来“驱动&#xff02;待测应用程序和数据的测试脚本代码&#xff0c;关键字驱动测试看上去与手工测…
阅读更多...
asp.net mvc点餐系统餐厅管理系统

asp.net mvc点餐系统餐厅管理系统

1. 主要功能 ①　管理员、收银员、厨师的登录 ②　管理员查看、添加、删除菜品类型 ③　管理员查看、添加、删除菜品&#xff0c;对菜品信息进行简介和封面的修改 ④　收银员浏览、搜索菜品&#xff0c;加入购物车后进行结算&#xff0c;生成订单 ⑤　厨师查看待完成菜品信息…
阅读更多...
4 redis的HyperLogLog入门原理

4 redis的HyperLogLog入门原理

一、HyperLogLog&#xff08;字符串类型&#xff09; 需求&#xff1a;大型网站(不在大厂基本上用不到) 每个网页每天的 UV 数据(独立访客)&#xff0c;统计如何实现&#xff1f;(尽量少的占用存储空间) Redis 提供了 HyperLogLog 数据结构就是用来解决这种统计问题的。Hyper…
阅读更多...
Spring cloud - Hystrix服务限流、熔断及降级

Spring cloud - Hystrix服务限流、熔断及降级

Hystrix的作用 Hystrix的主要作用是在微服务环境下防止服务雪崩&#xff0c;确保服务弹性及可用性。 具体来说&#xff0c;Hystrix可以实现&#xff1a; 服务降级&#xff1a;通过fallback实现服务不可达情况下的服务降级作用。熔断&#xff1a;服务不可达的情况下在设定时间…
阅读更多...
股东入股可用的出资形式主要有哪些

股东入股可用的出资形式主要有哪些

股东入股&#xff0c;可用的出资形式主要包括货币以及实物、知识产权、土地使用权等可以用货币估价并可以依法转让的非货币财产。 第一&#xff0c;货币。设立公司必然需要一定数量的流动资金。以支付创建公司时的开支和启动公司运营。因此&#xff0c;股东可以用货币出资。 第…
阅读更多...
【LeetCode刷题-树】--1367.二叉树中的链表

【LeetCode刷题-树】--1367.二叉树中的链表

1367.二叉树中的链表 方法&#xff1a;枚举 枚举二叉树中的每个节点为起点往下的路径是否与链表相匹配的路径&#xff0c;为了判断是否匹配设计了一个递归函数dfs(root,head),其中root表示当前匹配到的二叉树节点&#xff0c;head表示当前匹配到的链表节点&#xff0c;整个函数…
阅读更多...
实战项目：VB龟兔赛跑游戏+猜数字游戏

实战项目：VB龟兔赛跑游戏+猜数字游戏

文章目录&#xff1a; 一&#xff1a;效果演示 二&#xff1a;实现思路 三&#xff1a;代码实现 form1 效果图 代码 form2 效果图 代码 form3 效果图 代码 一&#xff1a;效果演示 效果图◕‿◕✌✌✌ 代码下载 二&#xff1a;实现思路 窗口1&#xff1a;龟兔赛…
阅读更多...
2023上海初中生古诗文大会复赛12月2日举行，关键事项为您划重点

2023上海初中生古诗文大会复赛12月2日举行，关键事项为您划重点

今天中午12点&#xff0c;古诗文大会官微发布消息&#xff1a;2023上海中学生古诗文大会&#xff08;初中组&#xff09;复选将于12月2日举行。 具体安排和注意事项、常见问题&#xff0c;六分成长为您整理如下。 一、2023年初中生古诗文大会复赛日期和时间 12月2日&#xff…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023