【Java多线程案例】定时器

1. 定时器简介

定时器：想必大家一定对定时器这个概念不陌生！因为它经常出现在我们的日常生活和编程学习中，定时器就好比是一个"闹钟"，会在指定时间处理某件事（例如响铃），而在编程世界中，定时器可以实现到达设定时候时执行对应代码逻辑的功能！

2. 标准库中的定时器

Java标准库中提供了 定时器 的实现，即类Timer，并且提供了schedule方法可以安排需要处理的代码，并需要提供参数delay表示多少时间后执行，下面我们就通过代码来演示Java标准库中Timer类的使用方法：

/*** 测试Java标准库提供的Timer类*/
public class TestTimer {public static void main(String[] args) {// 1. 创建定时器Timer timer = new Timer();// 2. 安排任务并在3s后执行timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("timer 3000");}}, 3000);// 3. 安排任务并在2s后执行timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("timer 2000");}}, 2000);// 4. 安排任务并在1s后执行timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("timer 1000");}}, 1000);System.out.println("timer main");}
}

运行效果：
image.png
可以看到，程序启动后，分别在1s，2s，3s时刻打印timer 1000、timer 2000、timer 3000，并且分线程是一个 前台线程 ，如果用户不强制停止主线程运行，分线程不会结束，会一直等待任务的加入！

3. 自定义定时器

3.1 前置准备

现在我们想要自己来模拟实现Java标准库中的定时器，应该准备哪些内容呢？

  1. 首先我们需要设计一个数据结构用来保存需要处理的逻辑业务以及对应执行的时间，即标准库中提供的 TimerTask 类
  2. 其次Timer类内部需要有一个数据结构来保存多个TimerTask对象，并且我们需要尽快的找到最先执行的任务（PS：如果时间最早的任务都不需要执行，那么后续的任务都不需要考虑执行），因此我们考虑使用 优先级队列 这样的数据结构进行保存
  3. 最后由于Timer内部需要不断判断当前时间是否达到某个任务的执行时间，因此内部一定有一个 分线程 不断扫描优先级队列进行判断操作

3.2 基本实现

3.2.1 实现MyTimerTask类

现在我们先来自定义数据结构MyTimerTask用来模拟Java标准库中的TimerTask类，该类的主要功能就是保存需要处理执行的业务逻辑代码以及对应执行的时间：
TimerTask：

/*** 自定义TimerTask类*/
public class MyTimerTask {private Runnable runnable; // 需要执行的代码private long executeTime; // 执行时间public MyTimerTask(Runnable runnable, long delay) {this.executeTime = System.currentTimeMillis() + delay;this.runnable = runnable;}public void run() {runnable.run();}public long getExecuteTime() {return executeTime;}
}

我们定义了成员变量runnable用于表示需要处理执行的业务逻辑代码，executeTime表示该任务预计执行时间（当前系统时间+延迟时间delay），并且提供构造方法初始化这两个成员变量

注意：仔细思考一下，这个代码其实有个致命的问题！因为我们在设计之初就规定好Timer类内部有一个优先级队列保存多个TimerTask任务，但是并不是所有类的实例都可以成为优先级队列的元素的，只有实现比较器重写比较方法的类才可以成为优先级队列的元素！！！

实现比较器，重写比较方法主要有如下两种方式：

  1. 实现Comparable接口
  2. 实现Comparator接口

我们这里采用第一种方式：
改进后的MyTimerTask：

/*** 自定义TimerTask类*/
public class MyTimerTask implements Comparable<MyTimerTask> {private Runnable runnable; // 需要执行的代码private long executeTime; // 执行时间public MyTimerTask(Runnable runnable, long delay) {this.executeTime = System.currentTimeMillis() + delay;this.runnable = runnable;}public void run() {runnable.run();}public long getExecuteTime() {return executeTime;}@Overridepublic int compareTo(MyTimerTask o) {return (int) (this.executeTime - o.executeTime);}
}

3.2.2 实现MyTimer类

实现MyTimer类主要需要关注schedule方法的实现以及分线程的执行过程

public class MyTimer {private PriorityQueue<MyTimerTask> queue; // 优先级队列private Thread t; // 分线程public MyTimer() {this.queue = new PriorityQueue<>();// 线程this.t = new Thread(() -> {// 不断扫描优先级队列处理while (true) {if (queue.isEmpty()) {// 队列为空不处理continue;}// 取出队头元素MyTimerTask topTask = queue.peek();long curTime = System.currentTimeMillis();if (curTime >= topTask.getExecuteTime()) {// 可以执行topTask.run();queue.poll();}}});t.start(); // 一定要启动分线程}public void schedule(Runnable runnable, long delay) {MyTimerTask timerTask = new MyTimerTask(runnable, delay);queue.offer(timerTask);}
}
  • schedule方法调用后，我们创建出一个TimerTask对象，然后使用将该对象加入优先级队列中
  • 在构造方法中，我们启动分线程，该分线程循环判断当前优先级队列首元素，如果队列为空不处理，不为空就取出队首元素（此时队首元素一定是执行时间最早的），如果当前系统时间已经晚于执行时间就执行对应的任务，如果还没到达指定时间就不处理
3.2.2.1 问题（一）

但是上述代码仍然有一定问题，最明显的问题就是 线程安全问题 ！因为schedule方法中进行了入队列操作，但是并不是t线程负责调用的，而是由main主线程进行调用的，而t线程中负责取出队首元素出队列操作，这样就导致了不同线程修改同一变量的场景，就引发了本章的重点——线程安全问题

对于线程安全问题如何解决呢？其实我们已经轻车熟路了，那就是引入 锁机制 进行加锁处理！
引入锁机制后的MyTimer类：

public class MyTimer {private PriorityQueue<MyTimerTask> queue; // 优先级队列private Thread t; // 分线程private Object locker = new Object();public MyTimer() {this.queue = new PriorityQueue<>();// 线程this.t = new Thread(() -> {// 不断扫描优先级队列处理while (true) {synchronized (locker) {if (queue.isEmpty()) {// 队列为空不处理continue;}// 取出队头元素MyTimerTask topTask = queue.peek();long curTime = System.currentTimeMillis();if (curTime >= topTask.getExecuteTime()) {// 可以执行topTask.run();queue.poll();}}}});t.start(); // 一定要启动分线程}public void schedule(Runnable runnable, long delay) {synchronized (locker) {MyTimerTask timerTask = new MyTimerTask(runnable, delay);queue.offer(timerTask);}}
}

注意：synchronized加锁位置一定需要放在while (true)循环内部！试想一下，如果把加锁位置放在while (true)外部，那么当构造方法一调用，就会尝试给t线程加锁，此时t线程进入死循环判断永远都没有释放锁，这时进行入队列操作的schedule方法没有机会获取到锁对象！

3.2.2.2 问题（二）

但是现有的代码依旧存在问题！如果有小伙伴了解轻量级锁的实现就可以知道当前代码t线程内部使用while循环不断尝试加锁，这种类似于自旋锁的实现方式执行速度非常快，很容易再次获取到锁对象，因此该代码实际上也会导致其他线程饿死！因此我们引入 wait/notify 机制解决该问题：

public class MyTimer {private PriorityQueue<MyTimerTask> queue; // 优先级队列private Thread t; // 分线程private Object locker = new Object();public MyTimer() {this.queue = new PriorityQueue<>();// 线程this.t = new Thread(() -> {// 不断扫描优先级队列处理while (true) {synchronized (locker) {try {while (queue.isEmpty()) {// 队列为空不处理locker.wait();}// 取出队头元素MyTimerTask topTask = queue.peek();long curTime = System.currentTimeMillis();if (curTime >= topTask.getExecuteTime()) {// 可以执行topTask.run();queue.poll();} else {locker.wait(topTask.getExecuteTime() - curTime); // 阻塞等待}} catch (InterruptedException e) {throw new RuntimeException(e);}}}});t.start(); // 一定要启动分线程}public void schedule(Runnable runnable, long delay) {synchronized (locker) {MyTimerTask timerTask = new MyTimerTask(runnable, delay);queue.offer(timerTask);locker.notify(); // 线程唤醒}}
}

由于wait方法执行时阻塞等待并且释放锁，因此可以让其他线程获取到锁对象，于是我们就彻底解决了线程安全问题，我们编写如下测试类：

public class TestMyTimer {public static void main(String[] args) {MyTimer timer = new MyTimer();timer.schedule(new Runnable() {@Overridepublic void run() {System.out.println("timer 3000");}}, 3000);timer.schedule(new Runnable() {@Overridepublic void run() {System.out.println("timer 2000");}}, 2000);timer.schedule(new Runnable() {@Overridepublic void run() {System.out.println("timer 1000");}}, 1000);System.out.println("timer main");}
}

运行结果：
image.png

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

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

相关文章

单html页面使用Vue3和Element-Plus

单html页面使用Vue3和Element-Plus

一、快速入门 使用CDN方式引入Vue3使用CDN方式引入Element-Plus的样式文件和组件库 案例 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, ini…
阅读更多...
随机过程及应用学习笔记（四） 马尔可夫过程

随机过程及应用学习笔记（四） 马尔可夫过程

马尔可夫过程是理论上和实际应用中都十分重要的一类随机过程。 目录 前言 一、马尔可夫过程的概念 二、离散参数马氏链 1 定义 2 齐次马尔可夫链 3 齐次马尔可夫链的性质 三、齐次马尔可夫链状态的分类 四、有限马尔可夫链 五、状态的周期性 六、极限定理 七、生灭过…
阅读更多...
如何将字体添加到 ONLYOFFICE 文档服务器 8.0

如何将字体添加到 ONLYOFFICE 文档服务器 8.0

作者&#xff1a;VincentYoung 阅读本文&#xff0c;了解如何为自己的在线办公软件 ONLYOFFICE 文档服务器的字体库添加字体 ONLYOFFICE 文档是什么 ONLYOFFICE 文档是一个功能强大的文档编辑器&#xff0c;支持处理文本文档、电子表格、演示文稿、可填写表单、PDF 和电子书…
阅读更多...
设计模式巡礼：多板适配案例解析与深度重构

设计模式巡礼：多板适配案例解析与深度重构

theme: cyanosis 月黑风高&#xff0c;好兄弟发给我一个重构需求&#xff0c;咨询我的意见。 一、 场景分析 开发的产品是需要运行到不同的定制Android板子&#xff0c;不同板子有对应的不同SDK提供的API&#xff0c;目前的业务端&#xff0c;业务流程基本是确定的&#xff0…
阅读更多...
统一数据返回格式 及 可能遇到的问题；统一异常处理

统一数据返回格式 及 可能遇到的问题；统一异常处理

统一数据返回格式 统一数据返回格式就像我们寄快递一样&#xff0c;不管你需要寄的东西具体是什么都需要将它打包到统一的快递箱中。 此时我们需要一个“快递箱”用来将返回的数据“装”在里面。这个类是根据业务情况来自行定义的。 Data public class Resp<T> {//200…
阅读更多...
arkTS开发鸿蒙OS个人商城案例【2024最新 新年限定开发案例QAQ】

arkTS开发鸿蒙OS个人商城案例【2024最新 新年限定开发案例QAQ】

龙年前述 源码获取>文章下方二维码&#xff0c;回复关键字“鸿蒙OS商场源码” 前言 arkTS是华为自己研发的一套前端语言&#xff0c;是在js和ts技术的基础上又进行了升级而成&#xff01; 本篇文章会带领大家通过arkTSnode.jsmongoDB来完成一个鸿蒙OS版本的商城案例&…
阅读更多...
vue3 之 商城项目—支付

vue3 之 商城项目—支付

支付模版 pay/index.vue <script setup> const payInfo {} </script> <template><div class"xtx-pay-page"><div class"container"><!-- 付款信息 --><div class"pay-info"><span class"ic…
阅读更多...
《Linux 简易速速上手小册》第4章: 包管理与软件安装（2024 最新版）

《Linux 简易速速上手小册》第4章: 包管理与软件安装（2024 最新版）

文章目录 4.1 包管理基础4.1.1 重点基础知识4.1.2 重点案例&#xff1a;在 Ubuntu 上安装和管理软件4.1.3 拓展案例 1&#xff1a;添加软件仓库4.1.4 拓展案例 2&#xff1a;回滚软件到旧版本 4.2 使用 APT 与 YUM4.2.1 重点基础知识4.2.2 重点案例&#xff1a;在 Ubuntu 上配置…
阅读更多...
C# winfrom实例:四路激光测距雷达数据采集和波形图绘制

C# winfrom实例:四路激光测距雷达数据采集和波形图绘制

1.所述产品 产品型号&#xff1a;TFmini Plus 相关资料下载地址&#xff1a;http://www.benewake.com/download 产品名称&#xff1a;TFmini Plus激光雷达模组制造商公司&#xff1a;北醒&#xff08;北京&#xff09;光子科技有限公司 2.产品功能&#xff1a;TFmini Plus是基…
阅读更多...
MySQL篇----第十四篇

MySQL篇----第十四篇

系列文章目录 文章目录 系列文章目录前言一、MySQL 数据库作发布系统的存储，一天五万条以上的增量，预计运维三年,怎么优化？二、锁的优化策略三、索引的底层实现原理和优化四、什么情况下设置了索引但无法使用前言 前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽…
阅读更多...
Android之Android.bp文件格式语法(一百八十六)

Android之Android.bp文件格式语法(一百八十六)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 优质专栏&#xff1a;多媒…
阅读更多...
Docker 在window 2024版笔记 下载 安装 操作 配置

Docker 在window 2024版笔记 下载 安装 操作 配置

---Docker 前言--- Docker windows版官方版是一款专业开源的应用容器引擎&#xff0c;可以加快用户构建、共享和运行现代应用程序的速度&#xff0c;支持运行Linux和Windows Docker容器。 Docker 在容器的基础上&#xff0c;进行了进一步的封装&#xff0c;从文件系统、网络互…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023