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