付着した石英のジョブを回復する

Question

私は、例えば永遠に接続しようとするなど、固まった石英の仕事に直面しています。私は、彼らのトリガーが過去に次のファイアウォールを持っているので、これらのスタックされたジョブを検出できるというアイデアがあるスキームを使用しています。その後、私はそれらを中断してこれらのスレッドを停止しようとします。しかし、割り込みが機能していないようで、threadはnextFiretimeが更新されることなく実行されます。 どうすればそれらを正しく中断できますか？

求人コード：

protected AtomicReference<Thread> runningThread = null; 

/* 
* (non-Javadoc) 
* 
* @see org.quartz.Job#execute(org.quartz.JobExecutionContext) 
*/ 
@Override 
public void execute(JobExecutionContext context) 
     throws JobExecutionException 
{ 
    runningThread = new AtomicReference<Thread>(); 
    try { 
     this.runningThread.set(Thread.currentThread()); 
    } finally { 
     runningThread.set(null); 
    } 
} 

/* 
* (non-Javadoc) 
* 
* @see org.quartz.InterruptableJob#interrupt() 
*/ 
@Override 
public void interrupt() throws UnableToInterruptJobException 
{ 
    Thread thread = runningThread.getAndSet(null); 
    if (thread != null) 
     thread.interrupt(); 
} 

遮断するための実際のjobschedulerのコード：

public int interruptLongRunningJobs(int ms) { 
    int jobsInterrupted = 0; 
    String jobsInterruptedList = ""; 

    Date limitInThePast = new Date(System.currentTimeMillis() - ms); 

    Scheduler scheduler = this.getJobScheduler(); 
    // All scheduled jobs 
    try { 
     for (String groupName : scheduler.getJobGroupNames()) { 
      for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))) { 
       JobDetail jobDetail = scheduler.getJobDetail(jobKey); 
       final List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey); 

       Date nextFireTime = null; 
       if (triggers.size() > 0) 
       { 
        nextFireTime = triggers.get(0).getNextFireTime(); 

        if(nextFireTime != null) { 
         if(nextFireTime.before(limitInThePast)) { 
          String jobString = jobDetail.getKey() + "@" + jobDetail.getJobClass().getSimpleName(); 
          logger.debug("JobScheduler::interruptLongRunningJobs interrupting: " + jobString); 

          scheduler.interrupt(jobDetail.getKey()); 

          if(!jobsInterruptedList.isEmpty()) { 
           jobsInterruptedList += ", "; 
          } 
          jobsInterruptedList += jobString; 
          ++jobsInterrupted; 
         } 
        } 
       } 
      } 
     } 
    } catch (SchedulerException e) { 
     logger.debug("JobScheduler::interruptLongRunningJobs failed: " + e.getMessage()); 
    } 

    if(jobsInterrupted>0) { 
     logger.debug("JobScheduler::interruptLongRunningJobs interrupted jobs#= " + jobsInterrupted); 

     emailSomething("JobScheduler::interruptLongRunningJobs interrupted jobs#= " + jobsInterrupted, 
       "These jobs have been interrupted and canceled because they exceeded the maximum running time as detected by triggers with nextFireTime in the past:\r\n" + 
       jobsInterruptedList 
     ); 
    } 
    return jobsInterrupted; 
} 

Answer 1

問題は、私は（コピー＆ペースト）のみのサブクラスの一部でpublic void executeで見つかったロジックを実装しました、当時の焦点だった。 public void executeのコードを変更して、すべてのサブクラスでロジックを使用するのが簡単になりました。

@Override 
public void execute(JobExecutionContext context) 
     throws JobExecutionException 
{ 
    runningThread = new AtomicReference<Thread>(); 
    try { 
     this.runningThread.set(Thread.currentThread()); 
     reallyExecute(context); 
    } finally { 
     runningThread.set(null); 
    } 
}