在你使用調(diào)度器之前,需要借助一些具體的例子去理解它。你可以使用 SchedulerFactory 類來(lái)達(dá)到程序調(diào)度的目的。有一些 Quartz 框架的用戶可能會(huì)將 Factory 的實(shí)例存儲(chǔ)在 JND I中,其他人為了便于舉例子就直接使用 Factory 的實(shí)例。
一旦調(diào)度器實(shí)例化后,它就能夠啟動(dòng),等待執(zhí)行和關(guān)閉。需要注意的是一旦調(diào)度器調(diào)用 了shutdown 方法關(guān)閉后,如果不重新實(shí)例化,它就不會(huì)啟動(dòng)了。觸發(fā)器在調(diào)度器未啟動(dòng)時(shí),或是終止?fàn)顟B(tài)時(shí),都不會(huì)被觸發(fā)。
quartz 的簡(jiǎn)單事例:
public class HelloJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
Object tv1 = context.getTrigger().getJobDataMap().get("t1");
Object tv2 = context.getTrigger().getJobDataMap().get("t2");
Object jv1 = context.getJobDetail().getJobDataMap().get("j1");
Object jv2 = context.getJobDetail().getJobDataMap().get("j2");
Object sv = null;
try {
sv = context.getScheduler().getContext().get("skey");
} catch (SchedulerException e) {
e.printStackTrace();
}
System.out.println(tv1+":"+tv2);
System.out.println(jv1+":"+jv2);
System.out.println(sv);
System.out.println("hello:"+LocalDateTime.now());
}
}
public class Test {
public static void main(String[] args) throws SchedulerException {
//創(chuàng)建一個(gè)scheduler
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
scheduler.getContext().put("skey", "svalue");
//創(chuàng)建一個(gè)Trigger
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1")
.usingJobData("t1", "tv1")
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(3)
.repeatForever()).build();
trigger.getJobDataMap().put("t2", "tv2");
//創(chuàng)建一個(gè)job
JobDetail job = JobBuilder.newJob(HelloJob.class)
.usingJobData("j1", "jv1")
.withIdentity("myjob", "mygroup").build();
job.getJobDataMap().put("j2", "jv2");
//注冊(cè)trigger并啟動(dòng)scheduler
scheduler.scheduleJob(job,trigger);
scheduler.start();
}
}
更多建議: