创建一个新的公司网站做网站 业务流程图
前言
定时器也是软件开发中的一个重要组件. 类似于一个 “闹钟”。 达到一个设定的时间之后，就执行某个指定好的代码，比如：
在受上述场景中，当客户端发出去请求之后， 就要等待响应，如果服务器迟迟没有响应，也不清楚,这个请求就没发过去? 响应丢了?服务器出问题了?
对于客户端来说,不能无限的等，需要有一个最大的期限，到达这个最大的期限之后，是重新再发一遍，还是彻底放弃,还是什么其他的方式。
类似于以上场景就需要用到定时器。
一、标准库中的定时器
在标准库中提供了一个 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 Comparable<MyTimerTak>{//要有一个要执行的任务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{//使用一个数据结构，保存所有要安排的任务PriorityQueue<MyTimerTak> 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);}
}
总结
以上就是今天要讲的内容，本文仅仅简单介绍定时器的使用场景，标准库中的定时器，定时器的实现代码。