在Java中Timer是java.util包中的一个工具类，提供了定时器的功能。我们可以创建一个Timer对象，然后调用其schedule方法在某个特定的时间去执行一个特定的任务。并且你可以让其以特定频率一直执行某个任务，这个任务是用TimerTask来描述的，我们只需要将要进行的操作写在TimerTask类的run方法中即可。先附上两个小例子一遍让读者了解什么是定时器。接着再分析其中的一些源码实现。

第一个小例子：

package com.zkn.newlearn.thread; 
 
import java.util.Timer; 
import java.util.TimerTask; 
 
/** 
 * 传统的定时器 
 * Created by zkn on 2016/11/1. 
 */ 
public class TraditionalTimerTest01 { 
 
  public static void main(String[] args){ 
    //TimerTask是Runnable接口的一个实现类是，它是一个抽像类 
    //schedule是一个重载方法：第一个参数TimerTask的实现类。 
    // 第二个参数是第一次执行的时间。 
    // 第三个参数是间隔时间 
    new Timer().schedule(new TimerTask() { 
      @Override 
      public void run() { 
 
        System.out.println("这是一个定时器任务!"); 
      } 
    },1000,2000); 
  } 
} 

第二个小例子：让任务1每隔4秒执行，让任务2每隔2秒执行。依次反复。

package com.zkn.newlearn.thread; 
 
import java.util.Timer; 
import java.util.TimerTask; 
 
/** 
 * Created by zkn on 2016/11/1. 
 */ 
public class TraditionalTimerTest02 { 
 
  public static void main(String[] args){ 
 
    new Timer().schedule(new MyTimerTask01(),4000); 
  } 
 
  private static class MyTimerTask01 extends TimerTask{ 
 
    @Override 
    public void run() { 
      System.out.println("我是TimerTask1，我被执行了!"); 
      new Timer().schedule(new MyTimerTask02(),2000); 
    } 
  } 
 
  private static class MyTimerTask02 extends TimerTask { 
 
    @Override 
    public void run() { 
      System.out.println("我是TimerTask2，我被执行了!"); 
      new Timer().schedule(new MyTimerTask01(),4000); 
    } 
  } 
} 

大家一定会很好奇定时器是怎么执行的？接下来我们来看一下Timer中的主要代码。

private final TaskQueue queue = new TaskQueue(); 
 
/** 
 * The timer thread. 
 */ 
private final TimerThread thread = new TimerThread(queue); 

注意着两段代码是很重要的两段代码。TaskQueue和TimerThread都是Timer的内部类。TaskQueue是一个执行任务的优先队列。TimerThread是一个继承了Thread的线程类。他们两个在定时器中起着至关重要的作用，定时器基本上就是靠这两个类支撑的。 接下来我们来一下Timer的构造方法：

public Timer(String name) { 
  thread.setName(name); 
  thread.start(); 
} 

public Timer() { 
  this("Timer-" + serialNumber()); 
} 

无参的这个构造函数会调用这个有参的构造函数，在这个有参的构造函数中你看到了什么？thread.start()看着是不是很眼熟啊？没错，在new Timer()的时候，就是启动了一个线程。而启动这个线程的对象就是上面的TimerThread！接下来我们来看一下TimerThread的run方法中干了些什么：

public void run() { 
  try { 
    mainLoop(); 
  } finally { 
    // Someone killed this Thread, behave as if Timer cancelled 
    synchronized(queue) { 
      newTasksMayBeScheduled = false; 
      queue.clear(); // Eliminate obsolete references 
    } 
  } 
} 

这个run方法中主要是干了两件事：一：调用mainLoop()这个死循环的方法，我们在下面会详细分析；二：finally代码块终止定时任务。终止定时任务的这个没什么说的，我们主要来看一下mainLoop()这个方法。

private void mainLoop() { 
  while (true) { // 开始死循环 
    try { 
      TimerTask task; 
      boolean taskFired; 
      synchronized(queue) { 
        // 如果任务队列中为空并且定时任务没有被取消话，线程被挂起 等待执行任务的到来 
        while (queue.isEmpty() && newTasksMayBeScheduled) 
          queue.wait(); 
        if (queue.isEmpty()) 
          break; // 如果任务队列中没有任务了，则结束循环结束任务 
 
        // 如果队列中有执行任务的话，接着往下走 
        long currentTime, executionTime; 
        task = queue.getMin(); 
        synchronized(task.lock) { 
          if (task.state == TimerTask.CANCELLED) { 
            queue.removeMin(); 
            continue; // 如果执行任务被取消的话 则移除当前任务。这里会重新排队列里的任务执行顺序 
          } 
          currentTime = System.currentTimeMillis(); 
          executionTime = task.nextExecutionTime; 
          if (taskFired = (executionTime<=currentTime)) { 
            if (task.period == 0) { // 如果只执行一次的话，则在执行完之后，结束执行任务 
              queue.removeMin(); 
              task.state = TimerTask.EXECUTED; 
            } else { // 如果是固定频率执行任务的话，则计算下次执行的时间 
              queue.rescheduleMin( 
               task.period<0 ? currentTime  - task.period 
                      : executionTime + task.period); 
            } 
          } 
        } 
        if (!taskFired) // 不到任务执行的时候 等待线程调用 
          queue.wait(executionTime - currentTime); 
      } 
      if (taskFired) // 任务执行时间到，调用任务的run方法，执行任务 
        task.run(); 
    } catch(InterruptedException e) { 
    } 
  } 
} 

这个类比较长，具体的执行操作我在注释里都标注了。这个类基本上干了这样几件事：循环调用任务队列中的任务，执行队列中的任务。执行任务是什么时候放到执行队列中的呢?在schedule方法。我们来看看schedule的实现：

public void schedule(TimerTask task, long delay, long period) { 
  if (delay < 0) // 如果第一次执行的时间小于0 抛出异常 
    throw new IllegalArgumentException("Negative delay."); 
  if (period <= 0) //间隔时间小于等于 0 抛出异常 
    throw new IllegalArgumentException("Non-positive period."); 
  sched(task, System.currentTimeMillis()+delay, -period); 
} 

private void sched(TimerTask task, long time, long period) { 
  if (time < 0) 
    throw new IllegalArgumentException("Illegal execution time."); 
 
  // Constrain value of period sufficiently to prevent numeric 
  // overflow while still being effectively infinitely large.这个间隔时间到死基本上也执行不到 
  if (Math.abs(period) > (Long.MAX_VALUE >> 1)) 
    period >>= 1; 
 
  synchronized(queue) { 
    if (!thread.newTasksMayBeScheduled) //在任务的执行方法中 如果定时任务已经被取消的话 则抛出异常 
      throw new IllegalStateException("Timer already cancelled."); 
 
    synchronized(task.lock) { //object对象锁 
      if (task.state != TimerTask.VIRGIN) // 刚开是执行任务的时候 任务的状态应该是0的 
        throw new IllegalStateException( 
          "Task already scheduled or cancelled"); 
      task.nextExecutionTime = time; //下次执行时间 在上面的mainLoop方法中有用到 
      task.period = period; //设置任务的间隔时间，在上面的mainLoop方法中有用到 
      task.state = TimerTask.SCHEDULED; // 调度方法被调用 设置定时任务的状态为 已调度未执行 
    } 
 
    queue.add(task); //把执行任务加入到任务队列中 
    if (queue.getMin() == task) 
      queue.notify(); // 如果任务队列中的第一个任务为当前任务的话，则把当前任务放入到等锁池中 等待执行 
  } 
} 

shedule这个方法做的事情比较简单。最主要的作用是把TimerTask放到任务队列中。

下面我们大致看一下TaskQueue的代码：

  class TaskQueue { 
  //定义一个TimerTask的堆数组 <span style="white-space:pre">  </span> 
  private TimerTask[] queue = new TimerTask[128]; 
 
  //任务队列中的任务数<span style="white-space:pre"> </span> 
  private int size = 0; 
 
 
  int size() { 
    return size; 
  } 
 
  //添加任务到优先队列中 如果数组的长度不够的话会扩展数组 
  void add(TimerTask task) { 
    // Grow backing store if necessary 
    if (size + 1 == queue.length) 
      queue = Arrays.copyOf(queue, 2*queue.length); 
 
    queue[++size] = task; 
    fixUp(size); 
  } 
 
  //获取优先执行的任务 
  TimerTask getMin() { 
    return queue[1]; 
  } 
 
   
  TimerTask get(int i) { 
    return queue[i]; 
  } 
  //移除掉排在第一位的不能执行的任务 
  void removeMin() { 
    queue[1] = queue[size]; 
    queue[size--] = null; // Drop extra reference to prevent memory leak 把对象置空 等待gc回收 
    fixDown(1); 
  } 
 
  //删除任务队列队列中的任务 这里用来一个断言 来判断 i 不能大于 size 
  void quickRemove(int i) { 
    assert i <= size; 
 
    queue[i] = queue[size]; 
    queue[size--] = null; // Drop extra ref to prevent memory leak 
  } 
 
  //重新设置优先执行任务的执行时间 并对任务队列进行重新排序 以确保最优先的任务 优先被执行 
  void rescheduleMin(long newTime) { 
    queue[1].nextExecutionTime = newTime; 
    fixDown(1); 
  } 
 
 
  boolean isEmpty() { 
    return size==0; 
  } 
 
  //清空任务队列 定时任务结束  
  void clear() { 
    // Null out task references to prevent memory leak 
    for (int i=1; i<=size; i++) 
      queue[i] = null; 
 
    size = 0; 
  } 
 
  //两个堆排序 选出最优先的执行任务 
  private void fixUp(int k) { 
    while (k > 1) { 
      int j = k >> 1; 
      if (queue[j].nextExecutionTime <= queue[k].nextExecutionTime) 
        break; 
      TimerTask tmp = queue[j]; queue[j] = queue[k]; queue[k] = tmp; 
      k = j; 
    } 
  } 
 
  private void fixDown(int k) { 
    int j; 
    while ((j = k << 1) <= size && j > 0) { 
      if (j < size && 
        queue[j].nextExecutionTime > queue[j+1].nextExecutionTime) 
        j++; // j indexes smallest kid 
      if (queue[k].nextExecutionTime <= queue[j].nextExecutionTime) 
        break; 
      TimerTask tmp = queue[j]; queue[j] = queue[k]; queue[k] = tmp; 
      k = j; 
    } 
  } 
 
  void heapify() { 
    for (int i = size/2; i >= 1; i--) 
      fixDown(i); 
  } 
} 

OK，到这里定时任务的源码大致分析完毕。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# java多线程定时器  # java  # 多任务定时器  # java定时器执行多线程  # java多线程之定时器Timer的使用详解  # Java多线程定时器Timer原理及实现  # Java多线程之定时器Timer的实现  # Java多线程案例之定时器详解  # Java多线程案例实战之定时器的实现  # 是一个  # 第一个  # 中有  # 执行时间  # 干了  # 我是  # 抛出  # 第二个  # 在上面  # 每隔  # 移除  # 两段  # 都是  # 下次  # 看着  # 我在  # 在这个  # 你可以  # 是怎么  # 不是很 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 谷歌浏览器下载文件时中断怎么办 Google Chrome下载管理修复  php json中文编码为null的解决办法  详解Nginx + Tomcat 反向代理 负载均衡 集群 部署指南  Laravel怎么实现软删除SoftDeletes_Laravel模型回收站功能与数据恢复【步骤】  如何做网站制作流程,*游戏网站怎么搭建？  Laravel中Service Container是做什么的_Laravel服务容器与依赖注入核心概念解析  UC浏览器如何切换小说阅读源_UC浏览器阅读源切换【方法】  香港服务器建站指南：免备案优势与SEO优化技巧全解析  Android中AutoCompleteTextView自动提示  Laravel如何使用Scope本地作用域_Laravel模型常用查询逻辑封装技巧【手册】  打开php文件提示内存不足_怎么调整php内存限制【解决方案】  Laravel如何实现文件上传和存储？（本地与S3配置）  如何在万网利用已有域名快速建站？  Laravel Octane如何提升性能_使用Laravel Octane加速你的应用  手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站？  移动端手机网站制作软件,掌上时代，移动端网站的谷歌SEO该如何做？  Laravel路由怎么定义_Laravel核心路由系统完全入门指南  Laravel如何实现事件和监听器？（Event & Listener实战）  Laravel如何配置.env文件管理环境变量_Laravel环境变量使用与安全管理  如何在腾讯云免费申请建站？  在线教育网站制作平台,山西立德教育官网？  利用vue写todolist单页应用  ,怎么在广州志愿者网站注册？  如何用VPS主机快速搭建个人网站？  Win11怎么查看显卡温度 Win11任务管理器查看GPU温度【技巧】  WEB开发之注册页面验证码倒计时代码的实现  瓜子二手车官方网站在线入口 瓜子二手车网页版官网通道入口  Windows驱动无法加载错误解决方法_驱动签名验证失败处理步骤  如何获取免费开源的自助建站系统源码？  如何在阿里云虚拟服务器快速搭建网站？  深圳网站制作培训,深圳哪些招聘网站比较好？  如何挑选高效建站主机与优质域名？  今日头条微视频如何找选题 今日头条微视频找选题技巧【指南】  php结合redis实现高并发下的抢购、秒杀功能的实例  新三国志曹操传主线渭水交兵攻略  lovemo网页版地址 lovemo官网手机登录  Midjourney怎么调整光影效果_Midjourney光影调整方法【指南】  如何获取上海专业网站定制建站电话？  Laravel的契約(Contracts)是什么_深入理解Laravel Contracts与依赖倒置  如何快速搭建支持数据库操作的智能建站平台？  矢量图网站制作软件,用千图网的一张矢量图做公司app首页，该网站并未说明版权等问题，这样做算不算侵权？应该如何解决？  html5如何实现懒加载图片_ intersectionobserver api用法【教程】  关于BootStrap modal 在IOS9中不能弹出的解决方法(IOS 9 bootstrap modal ios 9 noticework)  Laravel如何理解并使用服务容器（Service Container）_Laravel依赖注入与容器绑定说明  移动端脚本框架Hammer.js  Laravel怎么进行数据库事务处理_Laravel DB Facade事务操作确保数据一致性  Python企业级消息系统教程_KafkaRabbitMQ高并发应用  想要更高端的建设网站，这些原则一定要坚持！  浏览器如何快速切换搜索引擎_在地址栏使用不同搜索引擎【搜索】  Edge浏览器如何截图和滚动截图_微软Edge网页捕获功能使用教程【技巧】