- 浏览: 797196 次
- 性别:
- 来自: 杭州
文章分类
最新评论
-
huan19900606:
像haskell这些脚本语言很容易定义DSL,实现对应的词法语 ...
DSL的基本介绍(groovy来进行构建) -
express_wind:
https://yq.aliyun.com/album/130 ...
qlexpress规则引擎初探 -
readxuxuegang:
博主你好。如果groovy的代码是保存在数据库里,不是文件,这 ...
在java中使用groovy怎么搞 (java and groovy) -
express_wind:
hi,兄弟,有没有兴趣来阿里巴巴专门做这方面的研究,https ...
qlexpress规则引擎初探 -
langcaiye:
有2个问题请教:1. 这里的base32算法为什么需要以负数的 ...
【原】geohash算法详解
前几看了一下《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(); } } }
下面是执行返回的结果
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的核心概念
表示一个工作,要执行的具体内容。此接口中只有一个方法
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能够实现的一个简单功能是,定时程序可以通过后台页面点击触发,能够制定集群中的一台机器来运行,具体原理介绍一下。
综合上面的一些结论,受到的一些启发:
(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
发表评论
-
系统分布式情况下最终一致性方案梳理
2015-09-05 19:34 40808前言 目前的应用系 ... -
Storm核心概念剖析
2015-03-20 20:42 3179最近团队中有分析的场 ... -
池和流的两种数据处理方式
2014-11-19 22:59 1322在抽象层面,想了一下,目前很多的数据处理形式,一般分为池和流 ... -
关于CodeReview(java)
2014-10-29 20:42 1837关于codereview,在平时的开发中,经常忽略的环节,参 ... -
java中各种各样的数据结构
2014-07-13 20:26 2399在java中,有非常丰富的数据结构,可能是因为大多数的软件 ... -
关于JVM的ClassLoader(笔记)
2014-07-13 12:19 1795众所周知,java是编译型的语言,写的是java文 ... -
关于事务的几个概念介绍
2014-06-06 22:22 1893啥是事务? 有一组操 ... -
开发中遇到的编码问题
2014-05-22 19:39 17921、说到编码,最大的问题就是乱码了,为啥会有乱码呢 ? 因 ... -
ThreadLocal源代码解析
2014-04-24 17:54 2359最开始的时候,理解的ThreadLocal,我的理解是这样的 ... -
关于单例模式(代码篇)
2014-04-23 10:47 2369很早的时候,转发过一篇单例模式的文章:http://iamz ... -
今天遇到的两个spring相关的两个问题
2014-04-18 21:56 2493今天在项目中写代码,遇到两个Spring的问题,记录一下。再 ... -
Activiti中的命令模式解析
2014-04-11 13:10 3087最近在看Activiti的源代码,发现是基于命令模式进行的开 ... -
关于java中的本地缓存-总结概述
2014-03-31 19:00 18291java中的本地缓存,工作后陆续用到,一直想写,一直无从下 ... -
使用guava中的EventBus构建内存级别的事件引擎
2014-03-25 19:27 6319这个EventBus是guava中比较给力的一个类,从字面 ... -
DSL的基本介绍(groovy来进行构建)
2014-03-04 23:32 16930什么是DSL? 领域特定 ... -
qlexpress规则引擎初探
2014-02-25 22:28 24861qlexpress是啥? 这个是阿里内部的一个开源的jav ... -
在java中使用groovy怎么搞 (java and groovy)
2014-01-15 23:17 10850什么是groovy? 一种基于Java虚拟机的动态语言, ... -
java中记录方法调用时间,结果按照方法的层级树状的输出
2013-12-21 17:36 4624 在java中,最常用的埋点时间的方法就 ... -
一次CMS GC问题排查过程(理解原理+读懂GC日志)
2013-12-14 22:21 41221这个是之前处理过的一个线上问题,处理过程断断续续,经历了两 ... -
令牌桶算法和漏桶算法以及流量控制浅谈
2013-11-27 23:20 20705 在双十一等大促环节,系统需要限流,外部 ...
相关推荐
JAVA定时器,只要服务开启,就能指定某些代码在某个时刻执行,例如:监狱里罪犯的余刑天数,每天都要减少,就可以设置一个定时器在每天的23:59:59来执行减少余刑天数的天。
JAVA定时器JAVA定时器.pdf
java定时器
java 定时器(Timer) java 定时器(Timer) java 定时器(Timer)
实例助解java定时器设置及停止的方法
Java定时器的使用 Java程序 Java写的一个定时器
讲解Java定时器开发
java定时器,import java.util.Calendar; import java.util.Date; import java.util.Timer; import java.util.TimerTask; 规定每天几点执行一次
Java后台定时器代码Java后台定时器代码Java后台定时器代码Java后台定时器代码Java后台定时器代码
Java定时器简例
java定时器,timer类操作详解 java定时器,timer类操作详解
java定时器 spring定时器:包括spring定时器的详细配置以及说明 包含所需的jar包
Java定时器.pdf
java web 定时器例子
在应用开发中,经常需要一些周期性的操作,比如每5分钟执行某一操作等。 对于这样的操作最方便、高效的实现方式就是使用java.util.Timer工具类。
java定时器例子,使用 java.util.TimerTask 类来实现定时执行
java定时器说明与应用
比较全面的定时器,里面有例子,照着例子就可以学会spring和java定时器。
有助于你快速的查找您要使用的类对象及其方法。