碼上歡樂
相關內容    簡體    繁體

Quartz-中斷正在執行的任務

本文轉載自   查看原文   2019-03-21 14:35   866    quartz

轉：

Quartz-中斷正在執行的任務

2017年11月15日 21:19:17 閱讀數：6715更多
所屬專欄： Quartz手札
 
版權聲明：【show me the code ,change the world】 https://blog.csdn.net/yangshangwei/article/details/78545158

概述

由於業務需要，停止Quartz中正在執行的任務

  1. 任務類只需要實現InterruptableJob類，然后實現interrupt()方法。

  2. 在這個方法中進行標記的改變，在執行中進行這個標記判斷，就可實現中斷任務了

  3. 另外在調度器上調用方法：sched.interrupt(job.getKey())

示例

job類

package com.xgj.quartz.quartzItself.interruptableJob; import java.text.SimpleDateFormat; import java.util.Date; import org.quartz.InterruptableJob; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.quartz.JobKey; import org.quartz.UnableToInterruptJobException; /** * * * @ClassName: DumbInterruptableJob * * @Description: 個可執行的中斷可執行程序，用於單元測試。 * * @author: Mr.Yang * * @date: 2017年11月15日 上午9:26:36 */ 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; } }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76

調度類

package com.xgj.quartz.quartzItself.interruptableJob; import static org.quartz.DateBuilder.nextGivenSecondDate; import static org.quartz.JobBuilder.newJob; import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.TriggerBuilder.newTrigger; import java.text.SimpleDateFormat; import java.util.Date; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerFactory; import org.quartz.SchedulerMetaData; import org.quartz.SimpleTrigger; import org.quartz.impl.StdSchedulerFactory; /** * * * @ClassName: InterruptExample * * @Description: 調度類 * * @author: Mr.Yang * * @date: 2017年11月15日 上午9:28:21 */ 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(); } }
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92

運行結果

------- 初始化 ----------------------
INFO  StdSchedulerFactory - Using default implementation for ThreadExecutor INFO SimpleThreadPool - Job execution threads will use class loader of thread: main INFO SchedulerSignalerImpl - Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl INFO QuartzScheduler - Quartz Scheduler v.2.2.3 created. INFO RAMJobStore - RAMJobStore initialized. INFO QuartzScheduler - Scheduler meta-data: Quartz Scheduler (v2.2.3) 'DefaultQuartzScheduler' with instanceId 'NON_CLUSTERED' Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally. NOT STARTED. Currently in standby mode. Number of jobs executed: 0 Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads. Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered. INFO StdSchedulerFactory - Quartz scheduler 'DefaultQuartzScheduler' initialized from default resource file in Quartz package: 'quartz.properties' INFO StdSchedulerFactory - Quartz scheduler version: 2.2.3 group1.interruptableJob1 將運行於：2017-11-15 09:29:45 並重復：-1 次，間隔 5 秒 INFO QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED started. ------- 開始調度 (調用.start()方法) ---------------- ------- 每7秒鍾啟動一次中斷任務（10次中斷） ---------- 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:29:45 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 1 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:29:49 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:29:50 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:29:54 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:29:55 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 2 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:29:56 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:00 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 3 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:03 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:05 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:09 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:10 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:14 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:15 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 4 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:17 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:20 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 5 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:24 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:25 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:29 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:30 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 6 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:31 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:35 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 7 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:38 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:40 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:44 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:45 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:49 【開始執行】任務Key：group1.interruptableJob1，執行時間： 2017-11-15 09:30:50 —————— 【中斷】外界正在調用調度器停止這個任務key：group1.interruptableJob1 ———————— ------- 關閉調度 --------------------- INFO QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutting down. INFO QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED paused. 被外界因素停止了這個任務key：group1.interruptableJob1,中斷累計次數: 8 【完成任務】key：group1.interruptableJob1 完成時間：2017-11-15 09:30:52 INFO QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutdown complete. ------- 關閉調度器完成 ----------------- ~~~~~~~~~~ 執行了 14 個 jobs.
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87

示例源碼

代碼已托管到Github—> https://github.com/yangshangwei/SpringMaster


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 quartz2.3.0（七）調度器中斷任務執行，手動處理任務中斷事件 quartz終止正在運行的任務 基於 Quartz.NET 實現可中斷的任務 查看Oracle正在執行的任務 查看Oracle正在執行的任務 怎么用quartz控制任務的執行順序 Quartz-作業調度框架 mysql查看正在執行的sql任務 用Quartz處理定時執行的任務 Quartz任務執行一段時間后停止，不再執行
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM