您的位置:首页 > 其它

Quartz的触发器使用

2016-04-19 19:24 253 查看
触发器是quartz赖以触发任务的关键组件,它的使用直接关系到Job的执行。

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启动之后,仍可以添加新的调度任务的。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: