自己写基于线程的调度程序易出错,Quartz是任务调度领域著名的开源框架。Spring集成了Quartz的功能。
任务调度有基于时间的调度、资源上的调度等等。
任务调度涉及到:多线程并发、运行时间规则制定及解析、运行现场保持与恢复、线程池维护等工作。
Quartz快速进阶
SimpleTrigger
Quartz对任务调度领域的问题进行了高度抽象,提出了调度器、任务和触发器三个核心概念。
例1:写个简单任务
-- SimpleJob.java
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class SimpleJob implements Job {
public void execute(JobExecutionContext jobCtx)
throws JobExecutionException {
System.out.println(jobCtx.getTrigger()
+ " triggered. time is:" + (new Date()));
}
}
例2:简单调度
-- SimpleTriggerRunner.java
该类会每隔2s运行一次,运行100次,每次都是执行SimpleJob任务。
import java.util.Date;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.JobDetailImpl;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.triggers.SimpleTriggerImpl;
public class SimpleTriggerRunner {
public static void main(String[] args) {
try {
// 任务,指定job在本调度中的名称和所属组,SimpleJob是自己写的一个简单任务类
JobDetail jobDetail = new JobDetailImpl("job1_1", "jgroup1",SimpleJob.class);
// 触发器
SimpleTrigger simpleTrigger = new SimpleTriggerImpl("trigger1_1","tgroup1");
((SimpleTriggerImpl) simpleTrigger).setStartTime(new Date());
((SimpleTriggerImpl) simpleTrigger).setRepeatInterval(2000);
((SimpleTriggerImpl) simpleTrigger).setRepeatCount(100);
// 调度安排
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
scheduler.scheduleJob(jobDetail, simpleTrigger);
scheduler.start();
} catch (Exception e) {
e.printStackTrace();
}
}
}
在构造Trigger实例时,可考虑用org.quartz.TriggerUtils工具类,该类提供了许多好用的方法
CronTrigger
(Cron代表一百万年,时间单位)
Cron表达式:
Cron表达式时间字段依次是:秒 分钟 小时 日期(几号) 月份 星期 年(可选)
例子:
import org.quartz.CronExpression;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.impl.JobDetailImpl;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.triggers.CronTriggerImpl;
public class CronTriggerRunner {
public static void main(String[] args) {
try{
JobDetail jobDetail = new JobDetailImpl("job1_2", "jgroup1",SimpleJob.class);
CronTrigger cronTrigger = new CronTriggerImpl("trigger1_2", "tgroup1");
// 每隔5秒触发SimpleJob一次
CronExpression cexp = new CronExpression("0/5 * * * * ?");
((CronTriggerImpl) cronTrigger).setCronExpression(cexp);
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
scheduler.scheduleJob(jobDetail, cronTrigger);
scheduler.start();
} catch(Exception e){
e.printStackTrace();
}
}
}
详情见书本P434