南通网站建设哪家好,wordpress模板wiki,模块化局域网网站建设软件,南京网站排名前言 定时器也是软件开发中的一个重要组件. 类似于一个 “闹钟”。 达到一个设定的时间之后#xff0c;就执行某个指定好的代码#xff0c;比如#xff1a; 在受上述场景中#xff0c;当客户端发出去请求之后#xff0c; 就要等待响应#xff0c;如果服务器迟迟没有响应就执行某个指定好的代码比如 在受上述场景中当客户端发出去请求之后 就要等待响应如果服务器迟迟没有响应也不清楚,这个请求就没发过去? 响应丢了?服务器出问题了? 对于客户端来说,不能无限的等需要有一个最大的期限到达这个最大的期限之后是重新再发一遍还是彻底放弃,还是什么其他的方式。 类似于以上场景就需要用到定时器。 一、标准库中的定时器 在标准库中提供了一个 Timer 类它的核心方法为 schedule 。 schedule方法 包含两个参数 第一个参数指定即将要执行的任务代码第二个参数指定多长时间之后执行 (单位为毫秒)。 参考代码如下
Timer timer new Timer();
timer.schedule(new TimerTask() {Overridepublic void run() {System.out.println(hello);}
}, 3000);二、实现一个定时器
在实现一个定时器Timer前我们需要考虑三个问题 Timer 中需要有一个线程扫描任务是否到时间可以执行了需要有一个数据结构把所有的任务都保存起来还需要创建–人类通过类的对象来描述一个任务(至少要包含任务内容和时间) 2.1 定时器的构成
1. 一个带优先级的阻塞队列 为社么要带优先级呢? 因为阻塞队列中的任务都有各自的执行时刻 (delay)。最先执行的任务一定是 delay 最小的。使用带优先级的队列就可以高效的把这个 delay 最小的任务找出来。 2. 队列中的每个元素是一个 Task 对象
3.Task 中带有一个时间属性, 队首元素就是即将要执行的对象
4. 同时有一个 worker 线程一直扫描队首元素, 看队首元素是否需要执行。
2.2实现过程
定时器的完整实现代码
package Timer9;import java.util.PriorityQueue;/*** author Zhang* date 2024/5/1016:43* Description:*/
//通过这个类描述了一个任务
class MyTimerTak implements ComparableMyTimerTak{//要有一个要执行的任务private Runnable runnable;//执行任务的时间private long time;// 此处的delay就是schedule方法传入的相对时间public MyTimerTak(Runnable runnable, long delay ) {this.runnable runnable;this.time System.currentTimeMillis()delay;}Overridepublic int compareTo(MyTimerTak o) {//这样写就是让队首元素是最小时间的值return (int)(this.time - o.time);}public long getTime(){return time;}public Runnable getRunnable(){return runnable;}
}//自己的定时器
class MyTimer{//使用一个数据结构保存所有要安排的任务PriorityQueueMyTimerTak queue new PriorityQueue();//使用这个ui想作为锁对象private Object locker new Object();public void schedule(Runnable runnable,long delay){synchronized (locker){queue.offer(new MyTimerTak(runnable, delay));}}//扫描线程public MyTimer(){//创建一个线程Thread t new Thread(()-{while (true){try{synchronized (locker){//不要使用if 作为wait的判定条件应该使用while//使用 while 的目的是为了在 wait被唤醒的时候再次确认一下条件while(queue.isEmpty()){//使用wait等待//这里的wait需要另外的线程唤醒//添加了新任务就会被唤醒locker.wait();}MyTimerTak tak queue.peek();//比较当前的队首是否可以执行元素long curTime System.currentTimeMillis();if (curTime tak.getTime()){//当前时间已经达到了人物事件就可以执行任务了tak.getRunnable().run();//任务执行结束就可以从队列中删除了queue.poll();}else {//当前时间还没达到任务时间暂时不执行任务locker.wait(tak.getTime() - curTime);}}} catch(InterruptedException e){e.printStackTrace();}}});t.start();}}定时器的调用和演示
public class Demo2 {public static void main(String[] args) {MyTimer timer new MyTimer();timer.schedule(new Runnable() {Overridepublic void run() {System.out.println(3000);}},3000);timer.schedule(new Runnable() {Overridepublic void run() {System.out.println(2000);}},2000);timer.schedule(new Runnable() {Overridepublic void run() {System.out.println(1000);}},1000);}
}总结 以上就是今天要讲的内容本文仅仅简单介绍定时器的使用场景标准库中的定时器定时器的实现代码。
