多线程——定时器

定时器在日常开发中常用到的组件工具,类似于“闹钟”
设定一个时间,到了时间定时器就会自动去执行某个逻辑

Java标准库,也提供了定时器的实现

Timer timer = new Timer( );

代码演示:

public class Test14 {public static void main(String[] args) {Timer timer = new Timer();timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("三秒");}},3000);timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("两秒");}},2000);timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("一秒");}},1000);System.out.println("main");}
}

运行结果:

main
一秒
两秒
三秒

由此可见,定时器不是按照代码的先后顺序执行的,而是按照给定时间的先后顺序执行的

如何手动实现定时器?

手动实现的MyTimer里面要包含哪些内容
1.需要一个线程,负责掐时间,等到任务到了执行时间,该线程就会负责执行
2.还需要一个队列/数组,能够保存所有的schedule进来的任务
每个任务都带有等待时间delay,所以使用优先级队列,等待时间delay短的先执行

首先要创建一个类,用来描述一个任务
该类中要有执行时间和要执行的代码

class MyTimerTask implements Comparable<MyTimerTask> {// 在什么时间点来执行这个任务.// 此处约定这个 time 是一个 ms 级别的时间戳.private long time;// 实际任务要执行的代码.private Runnable runnable;public long getTime() {return time;}// delay 期望是一个 "相对时间"public MyTimerTask(Runnable runnable, long delay) {this.runnable = runnable;// 计算一下真正要执行任务的绝对时间. (使用绝对时间, 方便判定任务是否到达时间的)this.time = System.currentTimeMillis() + delay;}public void run() {runnable.run();}@Overridepublic int compareTo(MyTimerTask o) {return (int) (this.time - o.time);// return (int) (o.time - this.time);}
}

然后把每个任务都放进优先级队列里面进行比较,任务等待时间短的先执行

class MyTimer {// 负责扫描任务队列, 执行任务的线程.private Thread t = null;// 任务队列private PriorityQueue<MyTimerTask> queue = new PriorityQueue<>();public void schedule(Runnable runnable, long delay) {MyTimerTask task = new MyTimerTask(runnable, delay);queue.offer(task);}}

取出队头,使用线程去执行

public MyTimer() {t = new Thread(() -> {// 扫描线程就需要循环的反复的扫描队首元素, 然后判定队首元素是不是时间到了.// 如果时间没到, 啥都不干// 如果时间到了, 就执行这个任务并且把这个任务从队列中删除掉.while (true) {try {while (queue.isEmpty()) {// 暂时先不处理}MyTimerTask task = queue.peek();// 获取到当前时间long curTime = System.currentTimeMillis();if (curTime >= task.getTime()) {// 当前时间已经达到了任务时间, 就可以执行任务了.queue.poll();task.run();} else {// 当前时间还没到, 暂时先不执行// 不能使用 sleep. 会错过新的任务, 也无法释放锁.// Thread.sleep(task.getTime() - curTime);}}} catch (InterruptedException e) {e.printStackTrace();}}});// 要记得 start !!!!t.start();}

代码还存在线程安全问题,对代码进行优化:
完整代码:

import java.util.PriorityQueue;// 通过这个类, 来描述一个任务
class MyTimerTask implements Comparable<MyTimerTask> {// 在什么时间点来执行这个任务.// 此处约定这个 time 是一个 ms 级别的时间戳.private long time;// 实际任务要执行的代码.private Runnable runnable;public long getTime() {return time;}// delay 期望是一个 "相对时间"public MyTimerTask(Runnable runnable, long delay) {this.runnable = runnable;// 计算一下真正要执行任务的绝对时间. (使用绝对时间, 方便判定任务是否到达时间的)this.time = System.currentTimeMillis() + delay;}public void run() {runnable.run();}@Overridepublic int compareTo(MyTimerTask o) {return (int) (this.time - o.time);// return (int) (o.time - this.time);}
}// 通过这个类, 来表示一个定时器
class MyTimer {// 负责扫描任务队列, 执行任务的线程.private Thread t = null;// 任务队列private PriorityQueue<MyTimerTask> queue = new PriorityQueue<>();// 搞个锁对象, 此处使用 this 也可以.private Object locker = new Object();public void schedule(Runnable runnable, long delay) {synchronized (locker) {MyTimerTask task = new MyTimerTask(runnable, delay);queue.offer(task);// 添加新的元素之后, 就可以唤醒扫描线程的 wait 了.locker.notify();}}public void cancel() {// 结束 t 线程即可// interrupt}// 构造方法. 创建扫描线程, 让扫描线程来完成判定和执行.public MyTimer() {t = new Thread(() -> {// 扫描线程就需要循环的反复的扫描队首元素, 然后判定队首元素是不是时间到了.// 如果时间没到, 啥都不干// 如果时间到了, 就执行这个任务并且把这个任务从队列中删除掉.while (true) {try {synchronized (locker) {while (queue.isEmpty()) {// 暂时先不处理locker.wait();}MyTimerTask task = queue.peek();// 获取到当前时间long curTime = System.currentTimeMillis();if (curTime >= task.getTime()) {// 当前时间已经达到了任务时间, 就可以执行任务了.queue.poll();task.run();} else {// 当前时间还没到, 暂时先不执行// 不能使用 sleep. 会错过新的任务, 也无法释放锁.// Thread.sleep(task.getTime() - curTime);locker.wait(task.getTime() - curTime);}}} catch (InterruptedException e) {e.printStackTrace();}}});// 要记得 start !!!!t.start();}
}public class ThreadDemo31 {public static void main(String[] args) {MyTimer timer = new MyTimer();timer.schedule(new Runnable() {@Overridepublic void run() {System.out.println("hello 3000");}}, 3000);timer.schedule(new Runnable() {@Overridepublic void run() {System.out.println("hello 2000");}}, 2000);timer.schedule(new Runnable() {@Overridepublic void run() {System.out.println("hello 1000");}}, 1000);}
}

运行结果:

hello 1000
hello 2000
hello 3000

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

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

相关文章

第二证券:旅游股大涨 “预热”春节黄金周

在淄博烧烤热、哈尔滨冰雪热火爆出圈后&#xff0c;希望能接住文旅下一波“泼天富贵”的各地文旅局各出奇招并“卷”出新高度&#xff0c;被各地网友谈论“杀疯了”。 其间&#xff0c;A股游览概念股迎来一波集体上涨&#xff0c;成为不少出资者的重视热点&#xff0c;而行将到…

模拟日光AR汽车HUD的光学特性太阳光模拟器

AR HUD 的光学特性 几何光学可描述物体、透镜和成像之间的关系。将物体放在透镜及其焦点之间将会形成放大且离实际物体有一定距离的虚像[4]。这便是 HUD 生成虚像的方法。源物体&#xff08;在这里是散射屏或 TFT 面板&#xff09;在 HUD 反光镜光学系统的焦距内。这使相应虚像…

test0116测试

欢迎关注博主 Mindtechnist 或加入【Linux C/C/Python社区】一起探讨和分享Linux C/C/Python/Shell编程、机器人技术、机器学习、机器视觉、嵌入式AI相关领域的知识和技术。 磁盘满的本质分析 专栏&#xff1a;《Linux从小白到大神》 | 系统学习Linux开发、VIM/GCC/GDB/Make工具…

网络安全ctf比赛/学习资源整理,【解题工具、比赛时间、解题思路、实战靶场、学习路线】推荐收藏!

对于想学习或者参加CTF比赛的朋友来说&#xff0c;CTF工具、练习靶场必不可少&#xff0c;今天给大家分享自己收藏的CTF资源&#xff0c;希望能对各位有所帮助。 CTF在线工具 首先给大家推荐我自己常用的3个CTF在线工具网站&#xff0c;内容齐全&#xff0c;收藏备用。 1、C…

Androidmanifest文件加固和对抗

前言 恶意软件为了不让我们很容易反编译一个apk&#xff0c;会对androidmanifest文件进行魔改加固&#xff0c;本文探索androidmanifest加固的常见手法以及对抗方法。这里提供一个恶意样本的androidmanifest.xml文件&#xff0c;我们学完之后可以动手实践。 1、Androidmanife…

2. goLand安装及外配置参数通用用法

目录 概述测试代码解决外配置参数结束 概述 选择版本安装 go 安装的版本 1.go安装及相关配置 goLand 对于 习惯 idea 系列使用的人&#xff0c;还是很友好的。 测试代码 package mainimport ("flag""fmt""os" )func main() {name : flag.St…

Jenkins之pipeline

安装插件 Pipeline Pipeline: Stage View Plugin 创建任务 配置 demo 开始实践 拉取git仓库代码 checkout scmGit(branches: [[name: */main]], extensions: [], userRemoteConfigs: [[url: http://178.119.30.133:8929/root/mytest.git]])通过SonarQube做质量检测 sh …

RabbitMQ交换机(2)-Direct

1.Direct 直连(路由)交换机,生产者将消息发送到交换机&#xff0c;并指定消息的Routing Key&#xff08;路由键&#xff09;。交换机会将Routing Key与队列绑定进行匹配&#xff0c;如果匹配成功&#xff0c;则将该消息路由到对应的队列中。如果没有匹配成功&#xff0c;该消息…

Python不同数据对象的空值校验

更多Python学习内容&#xff1a;ipengtao.com 空值校验在数据处理和应用程序开发中是一个非常重要的任务。Python提供了多种方式来检查不同数据对象&#xff08;如字符串、列表、字典、集合等&#xff09;是否为空或包含空值。本文将详细介绍Python中对不同数据对象进行空值校验…

患者需要定期复查吗?

发作性睡病是一种慢性睡眠障碍性疾病&#xff0c;需要长期治疗和管理。因此&#xff0c;患者需要定期进行复查&#xff0c;以便医生了解患者的病情变化和治疗效果&#xff0c;及时调整治疗方案。 定期复查可以帮助医生评估患者的睡眠状况、猝倒等症状的改善情况&#xff0c;以…

Android 捕获native异常

11.使用google官方提供的breakpad 地址&#xff1a;Android 捕获native异常 https://github.com/google/breakpad 2.编译breakpad的so文件 2.1设置需要编译的架构 3.编译完&#xff0c;在build\intermediates\cmake\debug\obj目录下获取对应架构的so包 4.编译一个错误的so包…

3.3.3 使用集线器的星形拓扑

3.3.3 使用集线器的星形拓扑 集线器的一些特点 3.3.4 以太网的信道利用率 多个站在以太网上同时工作就可能会发生碰撞当发生碰撞时&#xff0c;信道资源实际上是被浪费了。因此&#xff0c;当扣除碰撞所造成的信道损失后&#xff0c;以太网总的信道利用率并不能达到100% 3.…

企业在数据中台上该怎么选择

随着数字化时代的到来&#xff0c;数据已经成为企业的核心资产之一。而数据中台作为数据管理和利用的核心平台&#xff0c;对于企业的发展起着至关重要的作用。然而&#xff0c;面对市场上琳琅满目的数据中台解决方案&#xff0c;企业应该如何选择合适的方案呢&#xff1f;下面…

创意交融:集成自定义报表和仪表盘设计器,实现图标替换

前言 在现代数据分析领域&#xff0c;随着对报表和数据分析的需求不断增长&#xff0c;市场上涌现了许多嵌入式报表工具。这些工具能够与企业现有的OA、ERP、MES、CRM等应用系统深度集成&#xff0c;实现对业务数据的自助式分析。然而&#xff0c;在实际应用中&#xff0c;不同…

在java中为什么重写equals要重写hashcode

为什么重写equals要重写hashcode 在Java中&#xff0c;当我们重写equals方法时&#xff0c;通常也需要重写hashCode方法。这是因为&#xff1a; 一致性&#xff1a;如果两个对象相等&#xff08;即equals方法返回true&#xff09;&#xff0c;那么它们的哈希码&#xff08;has…

PyQt5 QFileDialog 详解

PyQt5 QFileDialog 详解 QFileDialog 是 PyQt5 中用于显示文件和文件夹选择对话框的类。它提供了一种方便的方式&#xff0c;让用户在应用程序中选择文件、文件夹或多个文件。QFileDialog 类位于 QtWidgets 模块中。 下面是关于 QFileDialog 的一些详解&#xff1a; 创建和显…

发作性睡病是否会遗传给下一代?

发作性睡病是一种慢性睡眠障碍性疾病&#xff0c;具有一定的遗传性&#xff0c;因此有可能会遗传给下一代。 研究表明&#xff0c;发作性睡病与遗传因素密切相关&#xff0c;大约有60%的患者有家族遗传史。也就是说&#xff0c;如果父母双方或一方患有发作性睡病&#xff0c;子…

招生官怒批ChatGPT文书质量“缺少灵魂”

ChatGPT无疑是最近两年留学届的热门话题&#xff0c;也成为了不少留学生再也离不开的万能工具&#xff0c;从总结文献、润色论文、给教授写email似乎无所不能。甚至还有不少同学在考虑直接提交ChatGPT生成的文书。 那么ChatGPT生成的文书质量高吗&#xff1f;各大高校对于学生…

Oracle AWR报告的生成和解读

Oracle AWR报告的生成和解读 一、AWR报告概念及原理 Oracle10g以后&#xff0c;Oracle提供了一个性能检测的工具&#xff1a;AWR&#xff08;Automatic Workload Repository 自动工作负载库&#xff09;这个工具可以自动采集Oracle运行中的负载信息&#xff0c;并生成与性能相…

C# 消息队列、多线程、回滚、并行编程、异步编程、反射

消息队列 消息队列是一种在应用程序之间传递消息的异步通信机制。它可以使应用程序解耦并提高系统的可伸缩性和可靠性。在 C# 中&#xff0c;你可以使用多个消息队列技术&#xff0c;其中一种广泛使用的技术是 RabbitMQ。 RabbitMQ 是一个开源的消息代理&#xff0c;实现了高…