定时器Timer

http://www.cnblogs.com/xrq730/p/4856985.html

前言

定 时/计划功能在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-6 12:26:00 当前时间：2015-10-6 12:25:38
字符串时间：2015-10-6 12:27:00 当前时间：2015-10-6 12:25:38
运行了！时间为：Tue Oct 06 12:26:00 CST 2015
运行了！时间为：Tue Oct 06 12:27:00 CST 2015

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

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

Timer的schedule(TimerTask task, Date firstTime, long period)

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

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-6 18:10:00 当前时间：2015-10-6 18:14:15
A运行了！时间为：Tue Oct 06 18:14:15 CST 2015

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

其他方法

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

1、schedule(TimerTask task, long delay)

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

2、schedule(TimerTask task, long delay, long period)

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

3、scheduleAtFixedRate(TimerTask task, Date firstTime, long period)

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

时间： 2024-10-20 16:00:50

定时器Timer的相关文章

qt中定时器Timer的使用

qt中定时器Timer的使用,布布扣,bubuko.com

《React-Native系列》18、 RN之定时器Timer

在web开发中,我们通常需要使用定时器功能,使用setTimeout和setInterval函数. 那么在ReactNative中,是否也提供了定时器的功能呢? 答案是肯定的. 我们还是先看看官网怎么说的. 定时器是一个应用中非常重要的部分.React Native实现了和浏览器一致的定时器Timer. 提供的方法如下: setTimeout, clearTimeout setInterval, clearInterval setImmediate, clearImmediate request

C#创建windows服务搭配定时器Timer使用实例（用代码做，截图版）

功能说明:C#创建一个windows服务,服务启动时D:\mcWindowsService.txt写入数据,服务运行期间每隔两秒写入当前时间.      原理这些就不说了,三语两语说不清楚,直接贴一个实例.不能贴图片!!那个压缩文里面是word文档!!有图有真相 1．建立空白项目 2.添加创建windows服务需要的引用,选择System.ServiceProcess.   3．创建服务类,继承ServiceBase,类的源代码在后面. 4. 添加windows服务的安装类. (1)在类名或者解

storm定时器timer源码分析-timer.clj

storm定时器与java.util.Timer定时器比较相似.java.util.Timer定时器实际上是个线程,定时调度所拥有的TimerTasks:storm定时器也有一个线程负责调度所拥有的"定时任务".storm定时器的"定时任务"是一个vector类型的数据[time, callback, uuid],内有会有三个值,分别是时间.函数.和uuid,很好理解,时间表示该定时任务什么时候执行,函数表示要执行的函数,uuid用于标识该"定时任务&qu

PHP框架Swoole的一个定时器Timer特性

在各种业务型系统中,往往需要服务器在后台扫描相关数据,触发相应的统计.通知等操作. 比如对于一个项目管理系统,需要每天的特定时间内,统计每项任务的执行.到期情况.整个项目的进度等等,根据统计情况,做相应通知处理: 这样一个场景,如何编程实现? 用一般的编程方式,是无法实现自动触发与统计的.当然,简单的思路,是利于系统的cron job机制.但这种方式,对于配置及可靠性方面,需要比较多的人为操作因素. Swoole是一个使用c开发的php扩展,通过php就可以实现高性能web服务器,同时,还内置了

Swoole定时器Timer特性分析与使用

Swoole是一个使用c开发的php扩展,通过php就可以实现高性能web服务器,同时,还内置了定时器Timer.任务队列Task特性.这样,基于swoole,你可以在程序层面控制实现方式,减少对外部工具 - 独立的消息队列服务器.定时任务管理工具等的依赖性. swoole的强大之处就在与其进程模型的设计,既解决了异步问题,又解决了并行.用法如下: swoole_server_addtimer($serv, 10); 第二个参数是定时器的间隔时间,单位为秒.swoole定时器的最小颗粒是1秒.支

JAVA多线程提高一:传统线程技术&传统定时器Timer

前面我们已经对多线程的基础知识有了一定的了解,那么接下来我们将要对多线程进一步深入的学习:但在学习之前我们还是要对传统的技术进行一次回顾,本章我们回顾的则是:传统线程技术和传统的定时器实现. 一.传统线程技术 1.创建方式 1.继承thread类 Thread t = new Thread(){ @Override public void run() { } }; t.start(); 2.实现Runnable接口 Thread t1 = new Thread(new Runnable() {

Python之路(第四十五篇)线程Event事件、 条件Condition、定时器Timer、线程queue

一.事件Event Event(事件):事件处理的机制:全局定义了一个内置标志Flag,如果Flag值为 False,那么当程序执行 event.wait方法时就会阻塞,如果Flag值为True,那么event.wait 方法时便不再阻塞. Event其实就是一个简化版的 Condition.Event没有锁,无法使线程进入同步阻塞状态. Event() set(): 将标志设为True,并通知所有处于等待阻塞状态的线程恢复运行状态. clear(): 将标志设为False. wait(time

C# 定时器Timer

static void Main(string[] args) { #region 定时器 TimerDemo td = new TimerDemo("TimerDemo", 1000); td.Enabled = true; td.TickEvent += TestHandler; Thread timer = new Thread(td.Run); timer.Start(); #endregion Console.ReadLine(); } /// <summary>

定时器Timer的使用

定时的功能我们在手机上见得比较多,比如定时清理垃圾,闹钟,等等.定时功能在java中主要使用的就是Timer对象,他在内部使用的就是多线程的技术. Time类主要负责完成定时计划任务的功能,就是在指定的时间的开始执行某个任务. Timer类的作用是设置计划任务,而封装任务内容的类是TimerTask类.此类是一个抽象类,继承需要实现一个run方法. 通过查文档我们看到Timer有以下几个构造函数: Timer的方法以下这么多: 下面我们通过定时器来完成一个简单功能,就是在运行项目三秒后,在控制台