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

简单学习 --＞定时器

news 2026/5/12 20:57:53

定时器 (常见的组件)

定时器作用:例如: (定时发邮件) , 像一个闹钟一样.

例如:客户端向服务器请求,如果服务器不响应就 , 等 , 等到最大时间过了,就不等.

这里的等待的最长时间, 就是通过计时器来实现.

Timer (java中的计时器)

Timer , 在util包里

schedule() 方法

两个参数 , 一个描写了时间到了要做什么事情 , 一个是任务多少ms 时间后执行 ;

main主线程调用 schedule () , 方法 , 把任务给 Timer 对象中 , Timer 对象中有一个线程 "扫描线程" , 会扫描时间是否到了,一旦时间到了 ,就会执行刚才安排的任务 .
因为Timer里也有一个线程 , 所以执行刚才的代码 , 程序并没有停止 ; 因为主线程走完了,但是还有一个Timer的扫描线程

public static void main(String[] args) { Timer timer = new Timer(); timer.schedule(new TimerTask() { @Override public void run() { System.out.println("时间到执行任务"); } }, 2000 ) ; System.out.println("计时器开始执行"); } 输出了 计时器开始执行 时间到执行任务

Timer里可以安排多个任务 , 去执行 ;

public static void main(String[] args) { Timer timer = new Timer(); timer.schedule(new TimerTask() { @Override public void run() { System.out.println("2000时间到执行任务"); } }, 2000 ) ; timer.schedule(new TimerTask() { @Override public void run() { System.out.println("3000时间到,执行任务"); } } , 3000); timer.schedule(new TimerTask() { @Override public void run() { System.out.println("1000时间到,执行任务"); } } , 1000); System.out.println("计时器开始执行"); } 输出 计时器开始执行 1000时间到,执行任务 2000时间到执行任务 3000时间到,执行任务

实现一个简单的计时器

步骤:

1.有一个扫描线程 , 来看时间是否到了 , 要执行任务

如果时间到了 ,就执行任务, 如果时间没到就不执行 ;

2.需要一个数据结构, 来存放我们的任务

类似于阻塞队列 ,如果是空 ,就wait , 如果不空notify

3.还要有一个类 , 类方法来描述一个任务 (方法里要有任务内容和时间)

这个类里放任务属性 , 时间 , 作为我们数据结构的参数,来使用;

实现代码

import java.util.PriorityQueue;  // 一个类 , 类里有 任务 ,有时间 , 用来 描述一个任务(带任务,和时间) class MyTimerTask implements Comparable<MyTimerTask>{ // 用 runnable 是任务 private Runnable runnable; // long 类型的时间戳 private long time ; // delay 传入的 时间就是 一个 相对的时间 , 获取 现在的绝对时间 + delay 就是 任务执行的时间 public MyTimerTask(Runnable runnable, long delay) { this.runnable = runnable; this.time = System.currentTimeMillis() + delay; } // 实现comparable , 用时间做比较 @Override public int compareTo(MyTimerTask o) { return (int) (this.time - o.time); }  // 获取时间 public long getTime(){ return time; } // 获取 任务 public Runnable getRunnable(){ return runnable; } }  class MyTimer{ // 用优先级队列 来 , 存储 任务 ; private PriorityQueue<MyTimerTask> priorityQueue = new PriorityQueue<>();  public void schedule(Runnable runnable , long delay){ // 定义锁 让线程安全 synchronized(locker){ priorityQueue.offer(new MyTimerTask(runnable, delay)); // 如果不队列不为空就 notify locker.notify(); } } // 定义一个锁 ,让 schedule 方法 ,和扫描线程 ,安全 private Object locker = new Object();  //设置扫描线程 ,让扫描线程 去执行 run; public MyTimer(){ // 扫描线程 来 从 队列中取 元素 , Thread t1 = new Thread(()->{ // while 循环去取元素 while (true){ try{ // 加锁让线程安全 synchronized(locker){ // while 来判断 队列是否是空 , 空就wait while (priorityQueue.isEmpty()){ locker.wait(); } // 如果不为空 就 查看队列顶元素 MyTimerTask task = priorityQueue.peek(); // 查看时间到了没有 ,到时间就执行run方法 //获取现在的时间 long curTime = System.currentTimeMillis(); if(curTime >= task.getTime()){ // 执行run task.getRunnable().run(); // 执行完后就 释放栈顶 priorityQueue.poll(); }else{ // 时间没有到就继续循环 ,等时间到了可以执行run } } }catch (InterruptedException e){ e.printStackTrace(); } } }); // 启动 扫描线程 t1.start(); }  } public class Test2 { public static void main(String[] args) { MyTimer myTimer = new MyTimer(); myTimer.schedule(new Runnable() { @Override public void run() { System.out.println("1000ms的任务"); } }, 1000); myTimer.schedule(new Runnable() { @Override public void run() { System.out.println("2000ms的任务"); } }, 2000); myTimer.schedule(new Runnable() { @Override public void run() { System.out.println("3000ms的任务"); } }, 3000); System.out.println("计时器开始计时"); } }