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

宁波在线制作网站西安网络科技有限公司

宁波在线制作网站,西安网络科技有限公司,服装设计公司名称大全,网站百度云目录 一 什么是定时器? 二 标准库中的定时器 三 自定义实现定时器 一 什么是定时器? 定时器是一种用于在指定时间或以固定间隔执行任务的工具。 为什么需要定时器? 提高代码效率和可维护性。实现自动化任务调度。 二 标准库中的定时器 1.标准库中提供了一个Timer类&…

目录

一 什么是定时器?

二 标准库中的定时器 

三 自定义实现定时器 


一 什么是定时器?

定时器是一种用于在指定时间或以固定间隔执行任务的工具。

为什么需要定时器?

  • 提高代码效率和可维护性。
  • 实现自动化任务调度。

二 标准库中的定时器 

1.标准库中提供了一个Timer类,Timer类的核心方法为schedule;

2.schedule包含两个参数,第一个参数为即将要执行的任务代码,第二个参数为指定多长时间之后执行(单位为毫秒)。

import java.util.Timer;
import java.util.TimerTask;public class Demo2 {public static void main(String[] args) {Timer timer = new Timer();timer.schedule(new TimerTask() {@Overridepublic void run() {System.out.println("3000");}}, 3000);}    
}

三 自定义实现定时器 

要自定义一个定时器,我们需要满足两个条件:

  1. 被调度的任务可以按照指定时间执行;
  2. 一个定时器可以调度多个任务,并按照最初约定的时间执行它们。

1.被调度的任务可以按照指定时间执行

要实现第一个条件,我们可以创建一个扫描线程来扫描任务列表,检查每个任务是否到达指定的执行时间。如果任务到达了预定的执行时间,就执行相应的代码;如果没有达到预定的执行时间,就不执行任务。

2.一个定时器可以调度多个任务,并按照最初约定的时间执行它们。

针对第二个条件,我们可以使用一个优先级队列(PriorityQueue),这个队列可以根据任务的执行时间进行排序,使得时间最早的任务位于队列的前端,即最先要执行的任务。这样,在第一个条件中描述的扫描线程只需要检查队列的首元素即可,而不需要遍历整个任务列表。

 这里还需要处理一个小问题,就是我们如何描述一个任务?我们可以定义一个MyTimerTask 类实现了一个任务对象,用于封装任务的执行逻辑(Runnable)和执行时间(time)。 

// 定义一个任务类,用于封装任务的执行逻辑和执行时间
class MyTimerTask implements Comparable<MyTimerTask> {// 任务的执行逻辑,使用 Runnable 接口表示private Runnable runnable;// 任务的执行时间(以毫秒为单位)private long time;/*** 构造函数,用于创建一个任务对象* * @param runnable 任务的执行逻辑* @param delay    任务的延迟时间(以毫秒为单位)*/public MyTimerTask(Runnable runnable, long delay) {this.runnable = runnable; // 设置任务的执行逻辑this.time = System.currentTimeMillis() + delay; // 计算任务的执行时间(当前时间 + 延迟时间)}/*** 实现 Comparable 接口的 compareTo 方法,用于比较两个任务的执行时间* * @param o 另一个 MyTimerTask 对象* @return 负数表示当前任务先执行,正数表示当前任务后执行,0 表示同时执行*/@Overridepublic int compareTo(MyTimerTask o) {// 比较两个任务的执行时间,返回差值return (int)(this.time - o.time);}/*** 获取任务的执行时间* * @return 任务的执行时间(以毫秒为单位)*/public long getTime() {return time;}/*** 获取任务的执行逻辑* * @return Runnable 对象,表示任务的具体操作*/public Runnable getRunnable() {return runnable;}
}

按照上述两个条件我们可以写出下述的代码:

import java.util.PriorityQueue;class MyTimer {// 优先队列,用于存储任务,按任务的执行时间排序private PriorityQueue<MyTimerTask> queue = new PriorityQueue<>();// 锁对象,用于线程同步private Object locker = new Object();/*** 添加一个一次性任务到定时器中** @param runnable 任务的执行逻辑* @param delay    任务的延迟时间(以毫秒为单位)*/public void schedule(Runnable runnable, long delay) {synchronized (locker) { // 加锁,确保线程安全queue.offer(new MyTimerTask(runnable, delay)); // 将任务加入队列locker.notify(); // 唤醒调度线程,检查是否有新任务需要执行}}/*** 构造函数,启动一个后台线程用于调度任务*/public MyTimer() {// 创建并启动调度线程Thread 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()) {// 当前时间已达到或超过任务的执行时间task.getRunnable().run(); // 执行任务queue.poll(); // 从队列中移除任务} else {}}} catch (InterruptedException e) {e.printStackTrace(); // 捕获线程中断异常并打印堆栈信息}}});t.start(); // 启动调度线程}
}

MyTimer 类通过优先队列(PriorityQueue<MyTimerTask>)按任务的执行时间排序来管理任务,并利用锁对象(locker)确保线程安全。其核心方法 schedule 用于添加一次性任务到定时器中,构造函数则启动一个后台线程持续调度任务。调度线程在队列为空时进入等待状态,当有新任务加入时被唤醒;如果当前时间达到或超过任务的执行时间,则执行任务并将其从队列中移除,否则线程等待至任务的预定执行时间。这里需要注意的是,当使用一个自定义类作为PriorityQueue对象时,记得实现Comparable接口并重写compareTo方法来定义元素的自然顺序。

但是上面的代码还存在一个问题,如果当前任务未到执行时间时,代码会不断重复while循环操作。这种现象被称为"忙等"。为了更有效地利用CPU资源,我们需要使用阻塞式等待而不是忙等。

在这种情况下,我们知道等待的时间比较明确,第一时间想到了使用sleep方法来等待,但是可能会出现问题。例如,如果我们添加了一个比之前添加的任务更早的任务,那么可能会错过新任务的执行时间。
因此,我们可以使用wait方法来实现阻塞式等待更为合适,因为它可以更方便地唤醒线程并重新检查时间。 

import java.util.PriorityQueue;class MyTimer {// 优先队列,用于存储任务,按任务的执行时间排序private PriorityQueue<MyTimerTask> queue = new PriorityQueue<>();// 锁对象,用于线程同步private Object locker = new Object();/*** 添加一个一次性任务到定时器中** @param runnable 任务的执行逻辑* @param delay    任务的延迟时间(以毫秒为单位)*/public void schedule(Runnable runnable, long delay) {synchronized (locker) { // 加锁,确保线程安全queue.offer(new MyTimerTask(runnable, delay)); // 将任务加入队列locker.notify(); // 唤醒调度线程,检查是否有新任务需要执行}}/*** 构造函数,启动一个后台线程用于调度任务*/public MyTimer() {// 创建并启动调度线程Thread 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()) {// 当前时间已达到或超过任务的执行时间task.getRunnable().run(); // 执行任务queue.poll(); // 从队列中移除任务} else {// 当前时间未达到任务的执行时间,线程等待剩余时间locker.wait(task.getTime() - curTime);}}} catch (InterruptedException e) {e.printStackTrace(); // 捕获线程中断异常并打印堆栈信息}}});t.start(); // 启动调度线程}
}

 好了,到这里实现自定义实现定时器代码已经结束了。

http://www.cadmedia.cn/news/2210.html

相关文章:

  • 辽宁 政府网站信息内容建设企业查询官网
  • 一键生成文案的网站拼多多seo怎么优化
  • 网站设计公司域名服务器建设发软文的平台
  • 郑州建网站十大网站广告制作
  • 东莞企业网站费用刷关键词要刷大词吗
  • 如何建立企业网站及企业网站推广热门关键词查询
  • 圆通在线客服系统深圳seo排名优化
  • 搭网站要多少钱优搜云seo
  • 企业官网制作费用山东服务好的seo公司
  • 厦门小型网站建设网络营销专业是学什么的
  • 汇款账号 网站建设软文代写接单平台
  • 网站建设那家公司好重庆发布的最新消息今天
  • 用dede做网站去掉版权企业网站推广有哪些
  • 网站排名靠前方法网络舆情分析
  • 如何做b2c网站百度发布
  • 宁阳网页设计吉林seo技术交流
  • 电子商务网站建设作用保定seo推广外包
  • 济南招聘网武汉seo公司
  • 网络舆情应急预案求好用的seo软件
  • 高校网站建设申请怎么写天津seo优化公司哪家好
  • 提供网站建设案例百度怎么投放广告
  • 互联网App网站建设方案推广的公司
  • 动漫制作专业可以升大专吗厦门网站seo
  • 网站找哪家做较好百度关键词关键词大全
  • 政府网站模板下载整合营销传播的定义
  • 佛山企业快速建站广州网站优化推广
  • 沈阳大型网站建设卡点视频免费制作软件
  • 网站怎么做留言提交功能淘宝指数查询
  • 网站开发趋势好看的web网页
  • 设计网页页面优化大师下载安装免费