`
iamzhongyong
  • 浏览: 806545 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

【原】java定时器简单了解

    博客分类:
  • java
 
阅读更多

前几看了一下《thinking in java》了解到java原生的Times类有两个问题:

(1)Timer是启动单个线程来处理所有的时间任务,如果一个任务耗时很久,那么如果在执行这个过程中,下个定时任务开始,就会对接下来的任务造成影响;

(2)Timer某一个定时程序在执行过程中抛出运行时异常,那么定时器就会以为终止定时器的运行;

 

首先了解一下Timer类的核心组成

 

Timer有两个核心的属性,一个是TaskQueue对象,用于存储任务队列,一个是TimerThread,用于执行队列中的任务。

 

public class Timer {

    private TaskQueue queue = new TaskQueue();

    private TimerThread thread = new TimerThread(queue);

    。。。。。。

 

 

写代码验证一下,看看是否是这样的。

Timer和TimeTask是java基础中实现定时程序的两个核心类。

A、TimerTask是一个抽象类,内部实现了Runnable接口,同时定义了任务的几个状态;

B、Timer类来负责调度继承TimerTask的具体任务,可是实现定时或者指定周期运行

 

通过打印可以发现,代码是顺序执行的,最简单的代码实现:

public class TimerTest extends TimerTask{

	public static void main(String[] args) {
		Timer timer1 = new Timer("time1");
		
		timer1.schedule(new TimerTest(), 1);
		timer1.schedule(new TimerTest(), 2);
		timer1.schedule(new TimerTest(), 3);
	}

	@Override
	public void run() {
		try {
			System.out.println(Thread.currentThread().getName()+"-线程暂停5秒");
			TimeUnit.SECONDS.sleep(5);
			System.out.println(Thread.currentThread().getName()+"-线程执行结束");
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}

}
  

当代码运行中,第一个任务出现NullPointException时,第二个任务就不会再运行下去。

public class TimerTest extends TimerTask{

	public static void main(String[] args) {
		Timer timer1 = new Timer("time1");		
		timer1.schedule(new TimerTest(), 1);
		timer1.schedule(new TimerTest(), 2);
	}

	@Override
	public void run() {
		try {
			System.out.println(Thread.currentThread().getName()+"-线程暂停5秒");
			TimeUnit.SECONDS.sleep(5);
			System.out.println(Thread.currentThread().getName()+"-线程执行结束");
			String aaa = null;
			System.out.println(aaa.hashCode());
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}

}

 

Timer有三部分组成:

任务单元,任务队列,任务调度器,从下图能够非常直观的看出几个类直接的关系。

 

 

 

TaskQueue任务队列的管理:

 

 

一个具有优先级的时间任务队列,通过下次执行时间来进行排序。实际上就是一个数组,数据里面放着了TimeTask对象。

 

    void add(TimerTask task) {
        if (size + 1 == queue.length)
	    queue = Arrays.copyOf(queue, 2*queue.length);
       	    queue[++size] = task;
        fixUp(size);
    }

 

 上面是TaskQueue中的add方法,添加新的TimeTask的时候,首先判断是否超出了数组长度,初始数组是128,如果超过,就将数组长度加倍。

最后执行fixUp,重新将数组进行排序,TimeTask中nextExecutionTime小的排在数组的最前面,即最近一个要执行的定时任务。

 

 

Timer中重载了这个方法schedule,用来实现不同场景的任务调度,每一个schedule方法中都是用了这个方法sched

 

private void sched(TimerTask task, long time, long period) {
        if (time < 0)
            throw new IllegalArgumentException("Illegal execution time.");

        synchronized(queue) {
            if (!thread.newTasksMayBeScheduled)
                throw new IllegalStateException("Timer already cancelled.");

            synchronized(task.lock) {
                if (task.state != TimerTask.VIRGIN)
                    throw new IllegalStateException(
                        "Task already scheduled or cancelled");
                task.nextExecutionTime = time;
                task.period = period;
                task.state = TimerTask.SCHEDULED;
            }

            queue.add(task);
            if (queue.getMin() == task)
                queue.notify();
        }
    }

 

 从上述代码中可以看出,首先锁住任务队列,如果task符合条件,则直接将任务加入到任务队列中,并设置好任务下次执行时间以及执行周期并设置状态为可以被调度。

 

 

鉴于 Timer 的上述缺陷,Java 5 推出了基于线程池设计的 ScheduledExecutor。其设计思想是,每一个被调度的任务都会由线程池中一个线程去执行,因此任务是并发执行的,相互之间不会受到干扰。

 

java.util.courrent包中有一个定时调度线程的类:ScheduledExecutorService

下面的这个例子,从执行结果来看,两个定时程序是并发执行的,并且一个定时程序执行如果抛出异常,对于下个任务的执行没有啥影响,照样执行下去。


public class CourrentTimer implements Runnable {

	public static void main(String[] args) {
		CourrentTimer timer = new CourrentTimer();
		ScheduledExecutorService executer = Executors.newScheduledThreadPool(2);
                //创建线程池,调用ThreadPoolExecutor来进行创建,通过BlockingQueue来管理任务队列
		executer.submit(timer);
		executer.submit(timer);
                //Timer类实现Runnable接口,从而进入任务队列
	}
	@Override
	public void run() {
		try {
			TimeUnit.SECONDS.sleep(5);
			System.out.println(Thread.currentThread().getName()+"-线程暂停5秒后运行-"+new Date());
			String aa = null;
			System.out.println(aa.hashCode());
		} catch (Exception e) {
			e.printStackTrace();
		}				
	}

}
 

 下面是执行返回的结果

 

pool-1-thread-1-线程暂停5秒后运行-Mon Feb 13 20:54:06 CST 2012
java.lang.NullPointerException
at CourrentTimer.run(CourrentTimer.java:24)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:206)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
pool-1-thread-2-线程暂停5秒后运行-Mon Feb 13 20:54:06 CST 2012
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
java.lang.NullPointerException
at CourrentTimer.run(CourrentTimer.java:24)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:98)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:206)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)

 

 

java的Timer和TimerTask两个类以及java.util.courrent中的ScheduledExecutorService可是实现定时以及周期的执行,但是复杂的定时任务(例如每周二晚上0点到4点执行)就暂时无法满足,需要结果时间工具类,Spring quartz将定时程序作了一个很好的封装,使开发者通过简单的配置就可以实现定时程序的调度。

 

下面介绍几个Quartz的核心概念

 

 主要解决了一个问题:
定时任务调度器,调用什么任务,啥时候去调用。
1、Job
表示一个工作,要执行的具体内容。此接口中只有一个方法
void execute(JobExecutionContext context)

2、JobDetail
JobDetail表示一个具体的可执行的调度程序,Job是这个可执行程调度程序所要执行的内容,另外JobDetail还包含了这个任务调度的方案和策略。

3、Trigger代表一个调度参数的配置,什么时候去调。

4、Scheduler代表一个调度容器,一个调度容器中可以注册多个JobDetail和Trigger。当Trigger与JobDetail组合,就可以被Scheduler容器调度了。
 

 

 

public interface Job {
   //在Trigger配置下通过scheduler来进行调度的具体任务
   
    public void execute(JobExecutionContext context)
            throws JobExecutionException;

     //任务的上下文对象,包含了任务执行细节中的各个情况
}

 

 

Spring和Quartz的整合,可以通过简单扼配置,就能完成负责的时间调度任务,对于应用来说,只需要实现具体的任务即可,时间的调度等等细节交由Quartz来执行。

下面通过一个简单的例子来说明:

 

<!--
定义调用对象和调用对象的方法,这里定义了执行任务的bean以及bean中的方法
-->
<bean id="jobtask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetBeanName">
<value>executerInitCache</value>
</property>
<property name="targetMethod">
<value>load</value>
</property>
</bean>

<!-- 定义触发时间,相当于抽象了任务执行的规则,这个Trigger类需要具体的job以及关联这个job的时间规则 -->
<bean id="doTime" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
<ref bean="jobtask" />
</property>
<property name="cronExpression">
<value>0 30 2 * * ? *</value>
</property>
</bean>

<!-- 总管理类 如果将lazy-init='false'那么容器启动就会执行调度程序 ,任务的调度器 -->
<bean id="startQuertz" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref bean="doTime" />
</list>
</property>
</bean>

 

 

    timeTask俗称TT,是淘宝内部封装的一个时间调度器,Spring Quartz可以快速的完成时间的调度,但是如果应用是在集群环境下,我们就希望有一台机器来完成定时的任务,如果每台机器跑的代码完成一样,那么这个定时器就会在每台机器上都跑一边,如果跑的业务流程是幂等的还好,如果不是,那就会很多问题,TT能够实现的一个简单功能是,定时程序可以通过后台页面点击触发,能够制定集群中的一台机器来运行,具体原理介绍一下。

 

 

综合上面的一些结论,受到的一些启发:

 

 

(1)抽象任务接口,通过实现任务接口,来满足各种各样任务的需要,从而满足业务场景
(2)任务队列,存放实现任务接口的业务任务
(3)任务调度单独抽象,用来调度任务的执行
(4)抽象规则,定时任务有个规则就是定时程序啥时候执行,将这个设置抽象成一个简单的设置,通过一些表达式,来完成,简单高效
 

 

 

 

 

 

参考资料:

http://www.ibm.com/developerworks/cn/java/j-lo-taskschedule/

http://www.ibm.com/developerworks/cn/java/j-lo-timer/

http://xxxxxxxx-rui.iteye.com/blog/998603

 

 

分享到:
评论

相关推荐

    java源码包---java 源码 大量 实例

     Java生成密钥、保存密钥的实例源码,通过本源码可以了解到Java如何产生单钥加密的密钥(myKey)、产生双钥的密钥对(keyPair)、如何保存公钥的字节数组、保存私钥到文件privateKey.dat、如何用Java对象序列化保存私钥...

    java源码包3

     Java生成密钥、保存密钥的实例源码,通过本源码可以了解到Java如何产生单钥加密的密钥(myKey)、产生双钥的密钥对(keyPair)、如何保存公钥的字节数组、保存私钥到文件privateKey.dat、如何用Java对象序列化保存私钥...

    java源码包2

     Java生成密钥、保存密钥的实例源码,通过本源码可以了解到Java如何产生单钥加密的密钥(myKey)、产生双钥的密钥对(keyPair)、如何保存公钥的字节数组、保存私钥到文件privateKey.dat、如何用Java对象序列化保存私钥...

    Java Swing打猎射击游戏

    在游戏逻辑部分,开发者可能使用Java的定时器(java.util.Timer或javax.swing.Timer)来控制游戏的节奏,例如每隔一定时间刷新屏幕、更新猎物位置或添加新的目标。同时,使用ArrayList或其他集合类来管理游戏对象的...

    成百上千个Java 源码DEMO 3(1-4是独立压缩包)

    Java生成密钥的实例 1个目标文件 摘要:Java源码,算法相关,密钥 Java生成密钥、保存密钥的实例源码,通过本源码可以了解到Java如何产生单钥加密的密钥(myKey)、产生双钥的密钥对(keyPair)、如何保存公钥的字节数组、...

    java小游戏(适合初学者)

    通过阅读和理解这样的代码,初学者可以更深入地了解Java编程的底层逻辑。 "把文件夹导入MyEclipse即可运行"这部分,说明了这个游戏是用MyEclipse这个集成开发环境(IDE)编译和运行的。MyEclipse是一款流行的Java...

    成百上千个Java 源码DEMO 4(1-4是独立压缩包)

    Java生成密钥的实例 1个目标文件 摘要:Java源码,算法相关,密钥 Java生成密钥、保存密钥的实例源码,通过本源码可以了解到Java如何产生单钥加密的密钥(myKey)、产生双钥的密钥对(keyPair)、如何保存公钥的字节数组、...

    java版俄罗斯方块

    在深入探讨这个Java项目之前,我们首先了解一下基础的Java编程概念。 Java是一种跨平台的面向对象的编程语言,其“一次编写,到处运行”的特性使得Java程序能够在不同的操作系统上运行。在Java版俄罗斯方块中,...

    java源码包4

     Java生成密钥、保存密钥的实例源码,通过本源码可以了解到Java如何产生单钥加密的密钥(myKey)、产生双钥的密钥对(keyPair)、如何保存公钥的字节数组、保存私钥到文件privateKey.dat、如何用Java对象序列化保存私钥...

    java图片百叶窗,java代码

    首先,我们需要了解Java中的基本图像处理库,如`java.awt.image.BufferedImage`用于存储和操作图像,以及`javax.swing.ImageIcon`用于在GUI组件中显示图像。此外,`java.awt.Graphics2D`类提供了丰富的绘图功能,...

    nachos java walkthrough

    ### Nachos Java Walkthrough ...通过其Java版本的学习,学生不仅可以学习到操作系统的内部工作原理,还能了解到Java编程语言的优势及其在现代软件开发中的应用。这对于培养学生的实践能力和理论素养都具有重要的意义。

    用java编写的一个贪吃蛇的小游戏

    首先,让我们深入了解一下Java编程语言。Java是一种面向对象的、跨平台的编程语言,由Sun Microsystems(现为Oracle公司)于1995年推出。它的设计目标是“一次编写,到处运行”,这意味着编写好的Java程序可以在任何...

    java 语言图片渐显效果随心所俞

    首先,我们需要了解基本的Java图形处理库,如Java AWT(Abstract Window Toolkit)或Swing。这两个库提供了丰富的组件和工具来创建图形用户界面,并支持图像的加载和显示。 1. **加载图片**: 在Java中,我们可以...

    java小程序技能百练

    6. **数据库篇**:在数据库章节,学习者将了解如何使用JDBC(Java Database Connectivity)与各种数据库系统交互,包括连接数据库、执行SQL语句、处理结果集等。同时,也会涉及到事务处理、存储过程和预编译语句的...

    Java Script精彩实例教程

    通过"Java Script精彩实例教程",读者不仅可以了解到这些知识点,还能通过书中提供的实例亲自实践,加深理解,提升编程能力。无论你是完全的初学者还是有一定基础的学习者,这都是一份非常有价值的资源,能帮你扎实...

    Java动画、图形和极富客户端效果开发 英文

    本书不仅适合初学者了解Swing基础,也适合进阶开发者探索更复杂的技术细节。 #### 二、Swing基础与进阶 ##### 1. Swing简介 Swing是Java中用于构建图形用户界面的一个类库。它为开发者提供了丰富的组件集,如按钮、...

    java模拟进程调度算法和进程控制

    Java可以使用定时器和线程池来模拟时间片的切换。 5. **多级反馈队列(MLFQ, Multi-Level Feedback Queue)**: MLFQ结合了前几种策略,将进程分配到多个队列,每个队列有自己的调度策略。新进程通常从优先级最高...

    FlappyBird

    在游戏逻辑方面,Java的定时器(Timer)类扮演了关键角色。它能定期触发事件,使游戏能够持续更新,如小鸟的飞行、管道的移动等。我们还需要编写碰撞检测算法,判断小鸟是否撞到管道或地面,以及分数计算逻辑。 ...

    植物大战僵尸简单SWING界面

    【植物大战僵尸简单SWING界面】是一个基于Java Swing库创建的简易版《植物大战僵尸》游戏界面项目。这个项目可能是为了教学或者个人实践目的而设计的,虽然它被描述为“粗糙”,但仍然能让我们了解到如何用Java ...

    brick-breaker-game:Brick Breaker是一个简单的Java(swingdesktop)应用程序游戏项目

    今天我们要探讨的是一个名为"Brick Breaker"的简单Java桌面游戏,它是基于Java Swing库实现的。Swing是Java标准版(Java SE)的一部分,提供了一组丰富的组件和工具,用于创建美观的图形用户界面(GUI)。 首先,让...

Global site tag (gtag.js) - Google Analytics