Quartz的触发器使用
2016-04-19 19:24
253 查看
触发器是quartz赖以触发任务的关键组件,它的使用直接关系到Job的执行。
注意:
可见scheduler启动之后,仍可以添加新的调度任务的。
package com.wqw.study.quartz.practice; import static org.quartz.DateBuilder.evenMinuteDate; import static org.quartz.JobBuilder.newJob; import static org.quartz.TriggerBuilder.newTrigger; import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.DateBuilder.futureDate; public class TriggerUse { Logger log = LoggerFactory.getLogger(TriggerUse.class); public static void main(String[] args) throws Exception { //创建一个可用的scheduler 对象 SchedulerFactory schedulerFactory = new StdSchedulerFactory(); Scheduler scheduler = schedulerFactory.getScheduler(); Date runTime = evenMinuteDate(new Date()); JobDetail job = newJob(BaseJob.class).withIdentity("job1", "group1").build(); //trigger的使用:直接触发不重复 Trigger trigger = newTrigger().withIdentity("trigger1", "group1").startAt(runTime).build(); scheduler.scheduleJob(job,trigger); runTime = evenMinuteDate(new Date()); //trigger的使用:直接触发不重复 SimpleTrigger strigger = (SimpleTrigger) newTrigger().withIdentity("trigger2", "group1").startAt(runTime).build(); job = newJob(BaseJob.class).withIdentity("job2", "group1").build(); scheduler.scheduleJob(job,strigger); runTime = evenMinuteDate(new Date()); //trigger的使用:开始时间执行后,按照每10秒执行一次,重复10次 job = newJob(BaseJob.class).withIdentity("job3", "group1").build(); strigger = (SimpleTrigger) newTrigger().withIdentity("trigger3", "group1").startAt(runTime) .withSchedule(simpleSchedule() .withIntervalInSeconds(10) .withRepeatCount(10)).build(); scheduler.scheduleJob(job,strigger); scheduler.start(); TimeUnit.MINUTES.sleep(2); //trigger的使用:2分钟以后开始触发,仅执行一次. job = newJob(BaseJob.class).withIdentity("job4", "group1").build(); strigger = (SimpleTrigger) newTrigger() .withIdentity("trigger4", "group1") .startAt(futureDate(2, IntervalUnit.MINUTE)).build(); scheduler.scheduleJob(job,strigger); } }
注意:
可见scheduler启动之后,仍可以添加新的调度任务的。