程序喵
由于业务需要，停止Quartz中正在执行的任务
1、任务类只需要实现InterruptableJob类，然后实现interrupt()方法。
2、在这个方法中进行标记的改变，在执行中进行这个标记判断，就可实现中断任务了
3、另外在调度器上调用方法：sched.interrupt(job.getKey())
源码示例：
job类
package com.anson.examples.example7;
import org.quartz.*;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 一个可执行的中断可执行程序，用于单元测试。
*/
public class DumbInterruptableJob implements InterruptableJob {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
private boolean _interrupted = false; // job 是否中断
private JobKey _jobKey = null; // job name
private static int counts = 0; // 中断执行次数
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
_jobKey = context.getJobDetail().getKey();
System.out.println("【开始执行】任务Key：" + _jobKey + "，执行时间： " + sdf.format(new Date()));
try {
for (int i = 0; i < 4; i++) {
try {
Thread.sleep(1000L);
} catch (Exception e) {
e.printStackTrace();
}
// 查看是否中断
if (_interrupted) {
counts++;
System.out.println("被外界因素停止了这个任务key：" + _jobKey + ",中断累计次数: " + counts + "\n");
return; // 也可以选择抛出一个JobExecutionException，根据业务需要指定行为
}
}
} finally {
System.out.println("【完成任务】key：" + _jobKey + " 完成时间：" + sdf.format(new Date()));
}
}
@Override
public void interrupt() throws UnableToInterruptJobException {
System.out.println("\n—————— 【中断】外界正在调用调度器停止这个任务key：" + _jobKey + " ————————");
_interrupted = true;
}
}
调度类
package com.anson.examples.example7;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.text.SimpleDateFormat;
import java.util.Date;
import static org.quartz.DateBuilder.nextGivenSecondDate;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
import static org.quartz.TriggerBuilder.newTrigger;
public class InterruptExample {
public void run() throws Exception {
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("------- 初始化 ----------------------");
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
// 下一个15秒
Date startTime = nextGivenSecondDate(null, 15);
//当前时间15秒后,每间隔5秒执行一次任务
JobDetail job = newJob(DumbInterruptableJob.class).withIdentity("interruptableJob1", "group1").build();
SimpleTrigger trigger = newTrigger().
withIdentity("trigger1", "group1")
.startAt(startTime)
.withSchedule(simpleSchedule()
.withIntervalInSeconds(5).repeatForever())
.build();
Date ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey() + " 将运行于：" + sdf.format(ft) + " 并重复：" + trigger.getRepeatCount() + " 次，间隔 " + trigger.getRepeatInterval() / 1000 + " 秒");
// 调度开始执行
sched.start();
System.out.println("------- 开始调度 (调用.start()方法) ----------------");
System.out.println("------- 每7秒钟启动一次中断任务（10次中断） ----------");
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(7000L);
// 手动中断调度器中的job
sched.interrupt(job.getKey());
} catch (Exception e) {
e.printStackTrace();
}
}
System.out.println("------- 关闭调度 ---------------------");
sched.shutdown(true);
System.out.println("------- 关闭调度器完成 -----------------");
SchedulerMetaData metaData = sched.getMetaData();
System.out.println("~~~~~~~~~~ 执行了 " + metaData.getNumberOfJobsExecuted() + " 个 jobs.");
}
public static void main(String[] args) throws Exception {
InterruptExample example = new InterruptExample();
example.run();
}
}
日志输出
[INFO] 12 九月 10:53:43.717 上午 main [org.quartz.impl.StdSchedulerFactory] Quartz scheduler version: 2.2.3 group1.interruptableJob1 将运行于：2017-09-12 10:53:45 并重复：-1 次，间隔 5 秒 [INFO] 12 九月 10:53:43.726 上午 main [org.quartz.core.QuartzScheduler] Scheduler MyScheduler_$_NON_CLUSTERED started. ------- 开始调度 (调用.start()方法) ---------------- ------- 每7秒钟启动一次中断任务（10次中断） ---------- 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:53:45 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:53:49 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:53:50 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 1 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:53:51 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:53:55 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 2 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:53:58 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:00 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:04 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:05 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:09 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:10 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 3 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:12 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:15 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 4 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:19 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:20 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:24 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:25 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 5 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:26 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:30 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 6 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:33 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:35 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:39 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:40 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:44 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:45 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 7 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:47 【开始执行】任务Key：group1.interruptableJob1，执行时间： 2017-09-12 10:54:50 —————— 【中断】外界正在调用调度器停止这个任务key：group1.interruptableJob1 ———————— ------- 关闭调度 --------------------- [INFO] 12 九月 10:54:53.755 上午 main [org.quartz.core.QuartzScheduler] Scheduler MyScheduler_$_NON_CLUSTERED shutting down. [INFO] 12 九月 10:54:53.755 上午 main [org.quartz.core.QuartzScheduler] Scheduler MyScheduler_$_NON_CLUSTERED paused. 被外界因素停止了这个任务key：group1.interruptableJob1,中断累计次数: 8 【完成任务】key：group1.interruptableJob1 完成时间：2017-09-12 10:54:54 [INFO] 12 九月 10:54:54.077 上午 main [org.quartz.core.QuartzScheduler] Scheduler MyScheduler_$_NON_CLUSTERED shutdown complete. ------- 关闭调度器完成 ----------------- ~~~~~~~~~~ 执行了 14 个 jobs.
未经允许请勿转载：程序喵 » Quartz 定时任务使用 —— 中断正在执行的任务（九）