Quartz 定时任务使用 —— 中断正在执行的任务（九）

由于业务需要，停止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.