脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java多线程定时器Timer

Java多线程定时器Timer原理及实现

 更新时间：2017年11月14日 16:25:06   作者：五月的仓颉  
这篇文章主要介绍了Java多线程定时器Timer原理及实现，涉及Timer的schedule的使用，定时器Timer的schedule等相关内容以及代码示例，具有一定参考价值，需要的朋友可以了解下。

前言

定时/计划功能在Java应用的各个领域都使用得非常多，比方说Web层面，可能一个项目要定时采集话单、定时更新某些缓存、定时清理一批不活跃用户等等。定时计划任务功能在Java中主要使用的就是Timer对象，它在内部使用多线程方式进行处理，所以它和多线程技术关联还是相当大的。那和ThreadLocal一样，还是先讲原理再讲使用，Timer的实现原理不难，就简单扫一下就好了。

Timer的schedule(TimeTask task, Date time)的使用

该方法的作用是在执行的日期执行一次任务

1、执行任务的时间晚于当前时间：未来执行

private static Timer timer = new Timer();
static public class MyTask extends TimerTask
{
  public void run()
  {
    System.out.println("运行了！时间为：" + new Date());
  }
}
public static void main(String[] args) throws Exception
{
  MyTask task = new MyTask();
  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String dateString = "2015-10-6 12:14:00";
  Date dateRef = sdf.parse(dateString);
  System.out.println("字符串时间：" + dateRef.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  timer.schedule(task, dateRef);
}

看一下运行效果：

字符串时间：2015-10-6 12:14:00 当前时间：2015-10-6 12:13:23
运行了！时间为：Tue Oct 06 12:14:00 CST 2015

执行时间和但前时间不一致，而是和dateRef的时间一直，证明了未来执行。任务虽然执行完了，但进程没有销毁，控制台上的方框可以看到还是红色的，看下Timer的源代码：

public Timer() {
  this("Timer-" + serialNumber());
}
public Timer(String name) {
  thread.setName(name);
  thread.start();
}

所以，启动一个Timer就是启动一个新线程，但是这个新线程并不是守护线程，所以它会一直运行。要运行完就让进程停止的话，设置Timer为守护线程就好了，有专门的构造函数可以设置：

public Timer(boolean isDaemon) {
  this("Timer-" + serialNumber(), isDaemon);
}
public Timer(String name, boolean isDaemon) {
  thread.setName(name);
  thread.setDaemon(isDaemon);
  thread.start();
}

2、计划时间早于当前时间：立即执行

如果执行任务的时间早于当前时间，那么立即执行task的任务：

private static Timer timer = new Timer();
static public class MyTask extends TimerTask
{
  public void run()
  {
    System.out.println("运行了！时间为：" + new Date());
  }
}
public static void main(String[] args) throws Exception
{
  MyTask task = new MyTask();
  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String dateString = "2014-10-6 12:14:00";
  Date dateRef = sdf.parse(dateString);
  System.out.println("字符串时间：" + dateRef.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  timer.schedule(task, dateRef);
}

看一下运行效果：

字符串时间：2014-10-6 12:14:00 当前时间：2015-10-6 12:20:10
运行了！时间为：Tue Oct 06 12:20:10 CST 2015

执行时间和当前时间一致，证明了立即执行

3、多个TimerTask任务执行

Timer中允许有多个任务：

private static Timer timer = new Timer();
static public class MyTask extends TimerTask
{
  public void run()
  {
    System.out.println("运行了！时间为：" + new Date());
  }
}
public static void main(String[] args) throws Exception
{
  MyTask task1 = new MyTask();
  MyTask task2 = new MyTask();
  SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String dateString1 = "2015-10-6 12:26:00";
  String dateString2 = "2015-10-6 12:27:00";
  Date dateRef1 = sdf1.parse(dateString1);
  Date dateRef2 = sdf2.parse(dateString2);
  System.out.println("字符串时间：" + dateRef1.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  System.out.println("字符串时间：" + dateRef2.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  timer.schedule(task1, dateRef1);
  timer.schedule(task2, dateRef2);
}

看一下运行结果：

字符串时间：2015-10-612:26:00当前时间：2015-10-612:25:38

字符串时间：2015-10-612:27:00当前时间：2015-10-612:25:38

运行了！时间为：TueOct0612:26:00CST2015

运行了！时间为：TueOct0612:27:00CST2015

可以看到，运行时间和设置的时间一致，证明了未来可以执行多个任务。另外注意，Task是以队列的方式一个一个被顺序执行的，所以执行的时间有可能和预期的时间不一致，因为前面的任务可能消耗过长，后面任务的运行时间也有可能被延迟。

代码就不写了，举个例子，任务1计划12:00:00被执行，任务2计划12:00:10被执行，结果任务1执行了30秒，那么任务2将在12:00:30被执行，因为Task是被放入队列中的，因此必须一个一个顺序运行。

Timer的schedule(TimerTasktask,DatefirstTime,longperiod)

该方法的作用是在指定的日期之后，按指定的间隔周期性地无限循环地执行某一人物

1、计划时间晚于当前时间：未来执行

static public class MyTask extends TimerTask
{
  public void run()
  {
    System.out.println("运行了！时间为：" + new Date());
  }
}
public static void main(String[] args) throws Exception
{
  MyTask task = new MyTask();
  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String dateString = "2015-10-6 18:00:00";
  Timer timer = new Timer();
  Date dateRef = sdf.parse(dateString);
  System.out.println("字符串时间：" + dateRef.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  timer.schedule(task, dateRef, 4000);
}

看一下运行结果：

字符串时间：2015-10-6 18:01:00 当前时间：2015-10-6 18:00:15
运行了！时间为：Tue Oct 06 18:01:00 CST 2015
运行了！时间为：Tue Oct 06 18:01:04 CST 2015
运行了！时间为：Tue Oct 06 18:01:08 CST 2015
运行了！时间为：Tue Oct 06 18:01:12 CST 2015
...

看到从设定的时间开始，每隔4秒打印一次，无限打印下去

2、计划时间早于当前时间：立即执行

static public class MyTask extends TimerTask
{
  public void run()
  {
    System.out.println("运行了！时间为：" + new Date());
  }
}
public static void main(String[] args) throws Exception
{
  MyTask task = new MyTask();
  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String dateString = "2014-10-6 18:01:00";
  Timer timer = new Timer();
  Date dateRef = sdf.parse(dateString);
  System.out.println("字符串时间：" + dateRef.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  timer.schedule(task, dateRef, 4000);
}

看一下运行结果：

字符串时间：2014-10-6 18:01:00 当前时间：2015-10-6 18:02:46
运行了！时间为：Tue Oct 06 18:02:46 CST 2015
运行了！时间为：Tue Oct 06 18:02:50 CST 2015
运行了！时间为：Tue Oct 06 18:02:54 CST 2015
运行了！时间为：Tue Oct 06 18:02:58 CST 2015
运行了！时间为：Tue Oct 06 18:03:02 CST 2015
...

看到运行时间比当前时间早，从当前时间开始，每隔4秒打印一次，无限循环下去

TimerTask的cancel()方法

TimerTask的cancel()方法的作用是将自身从任务队列中清除：

static public class MyTaskA extends TimerTask
{
  public void run()
  {
    System.out.println("A运行了！时间为：" + new Date());
    this.cancel();
  }
}
  
static public class MyTaskB extends TimerTask
{
  public void run()
  {
    System.out.println("B运行了！时间为：" + new Date());
  }
}
  
public static void main(String[] args) throws Exception
{
  MyTaskA taskA = new MyTaskA();
  MyTaskB taskB = new MyTaskB();
  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String dateString = "2015-10-6 18:10:00";
  Timer timer = new Timer();
  Date dateRef = sdf.parse(dateString);
  System.out.println("字符串时间：" + dateRef.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  timer.schedule(taskA, dateRef, 4000);
  timer.schedule(taskB, dateRef, 4000);  
}

看一下运行结果：

字符串时间：2015-10-6 18:10:00 当前时间：2015-10-6 18:09:47
A运行了！时间为：Tue Oct 06 18:10:00 CST 2015
B运行了！时间为：Tue Oct 06 18:10:00 CST 2015
B运行了！时间为：Tue Oct 06 18:10:04 CST 2015
B运行了！时间为：Tue Oct 06 18:10:08 CST 2015
B运行了！时间为：Tue Oct 06 18:10:12 CST 2015
...

看到TimeTask的cancel()方法是将自身从任务队列中被移除，其他任务不受影响

Timer的cancel()方法

把上面代码改动一下：

private static Timer timer = new Timer();
  
static public class MyTaskA extends TimerTask
{
  public void run()
  {
    System.out.println("A运行了！时间为：" + new Date());
    timer.cancel();
  }
}
  
static public class MyTaskB extends TimerTask
{
  public void run()
  {
    System.out.println("B运行了！时间为：" + new Date());
  }
}
  
public static void main(String[] args) throws Exception
{
  MyTaskA taskA = new MyTaskA();
  MyTaskB taskB = new MyTaskB();
  SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  String dateString = "2015-10-6 18:10:00";
  Date dateRef = sdf.parse(dateString);
  System.out.println("字符串时间：" + dateRef.toLocaleString() + " 当前时间：" + new Date().toLocaleString());
  timer.schedule(taskA, dateRef, 4000);
  timer.schedule(taskB, dateRef, 4000);
}

看一下运行结果：

字符串时间：2015-10-618:10:00当前时间：2015-10-618:14:15

A运行了！时间为：TueOct0618:14:15CST2015

全部任务都被清除，并且进程被销毁。不过注意一下，cancel()方法未必一定会停止执行计划任务，可能正常执行，因为cancel()方法会尝试去获取queue锁，如果并没有获取到queue锁的话，TimerTask类中的任务继续执行也是完全有可能的

其他方法

再列举一些Timer中的其他schedule的重载方法的作用，就不提供证明的代码了，可以自己尝试一下：

1、schedule(TimerTasktask,longdelay)

以当前时间为参考，在此时间基础上延迟指定的毫秒数后执行一次TimerTask任务

2、schedule(TimerTasktask,longdelay,longperiod)

以当前时间为参考，在此时间基础上延迟指定的毫秒数后，以period为循环周期，循环执行TimerTask任务

3、scheduleAtFixedRate(TimerTasktask,DatefirstTime,longperiod)

在延时的场景下，schedule方法和scheduleAtFixedRate方法没有区别，它们的区别只是在非延时上。如果执行任务的时间没有被延时，对于schedule方法来说，下一次任务执行的时间参考的是上一次任务的开始时间来计算的；对于scheduleAtFixedRate方法来说，下一次任务执行的时间参考的是上一次任务的结束时间来计算的

总结

以上就是本文关于Java多线程定时器Timer原理及实现的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站：

java多线程编程实例

浅谈Java多线程的优点及代码示例

Java多线程之readwritelock读写分离的实现代码

如有不足之处，欢迎留言指出。

您可能感兴趣的文章:

相关文章

  • Java Valhalla Project项目介绍

    Java Valhalla Project项目介绍

    这篇文章主要介绍了Java Valhalla Project项目介绍，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下
    2022-09-09
  • 关于Mybatis实体别名支持通配符扫描问题小结

    关于Mybatis实体别名支持通配符扫描问题小结

    MyBatis可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录，这篇文章主要介绍了Mybatis实体别名支持通配符扫描的问题,需要的朋友可以参考下
    2022-01-01
  • Java操作minio删除文件夹及其文件方法(MinIO基本使用)

    Java操作minio删除文件夹及其文件方法(MinIO基本使用)

    MinIO是一个高性能、无限扩展的开源对象存储服务器,它以对象的形式存储数据,并兼容Amazon S3接口,它适用于大规模数据存储、大数据分析、文件共享和备份等应用场景,这篇文章主要介绍了java操作minio删除文件夹及其文件方法,需要的朋友可以参考下
    2024-02-02
  • SSM项目中配置LOG4J日志的方法

    SSM项目中配置LOG4J日志的方法

    本篇文章主要介绍了SSM项目中配置LOG4J日志的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-09-09
  • Java8新特性之lambda的作用_动力节点Java学院整理

    Java8新特性之lambda的作用_动力节点Java学院整理

    我们期待了很久lambda为java带来闭包的概念，但是如果我们不在集合中使用它的话，就损失了很大价值。现有接口迁移成为lambda风格的问题已经通过default methods解决了，在这篇文章将深入解析Java集合里面的批量数据操作解开lambda最强作用的神秘面纱。
    2017-06-06
  • 全面解析Java中的HashMap类

    全面解析Java中的HashMap类

    HashMap类为Java提供了键值对应的map类型,本文将从源码角度全面解析Java中的HashMap类,同时包括其各种常用操作方法等,欢迎参考与借鉴
    2016-05-05
  • Java高级特性基础之反射五连问

    Java高级特性基础之反射五连问

    反射赋予了我们在运行时分析类以及执行类中方法的能力。通过反射你可以获取任意一个类的所有属性和方法，你还可以调用这些方法和属性。本文就来和大家详细聊聊Java中的反射，感兴趣的可以了解一下
    2023-01-01
  • MyBatis-Plus中的逻辑删除使用详解

    MyBatis-Plus中的逻辑删除使用详解

    开发系统时，有时候在实现功能时，删除操作需要实现逻辑删除就是将数据标记为删除，而并非真的物理删除（非DELETE操作），查询时需要携带状态条件，确保被标记的数据不被查询到。这样做的目的就是避免数据被真正的删除
    2022-12-12
  • java中gc算法实例用法

    java中gc算法实例用法

    在本篇文章里小编给大家整理了一篇关于java中gc算法实例用法，有兴趣的朋友们可以参考学习下。
    2021-01-01
  • Java中如何编写一个数的n次方（幂运算）?

    Java中如何编写一个数的n次方（幂运算）?

    本文介绍了使用pow函数和自定义for循环计算幂的O(n)时间复杂度方法,然后重点讲解了快速幂算法的分治思想,以及从二进制角度的解释,包括如何通过位运算和循环迭代实现高效计算,给出了Java代码实现
    2024-07-07

最新评论