13.1 任务调度和异步执行器

时间:2022-05-25 19:59:40

自己写基于线程的调度程序易出错,Quartz是任务调度领域著名的开源框架。Spring集成了Quartz的功能。
任务调度有基于时间的调度、资源上的调度等等。
任务调度涉及到:多线程并发、运行时间规则制定及解析、运行现场保持与恢复、线程池维护等工作。
13.1 任务调度和异步执行器

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

13.1 任务调度和异步执行器

(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