我有一份 Spring 批处理工作,可以通过其他URL来解决。我想确保只允许运行一个作业实例。如果另一个实例已经在运行,则不要启动另一个实例。即使参数不同。
我搜索后,没有发现任何开箱即用的解决方案。扩展SimpleJobLauncher的想法。检查作业的任何实例是否在运行。
最佳答案
您可以尝试intercept the job execution,实现JobExecutionListener接口(interface):
public class MyJobExecutionListener extends JobExecutionListener {
//active JobExecution, used as a lock.
private JobExecution _active;
public void beforeJob(JobExecution jobExecution) {
//create a lock
synchronized(jobExecution) {
if(_active!=null && _active.isRunning()) {
jobExecution.stop();
} else {
_active=jobExecution;
}
}
}
public void afterJob(JobExecution jobExecution) {
//release the lock
synchronized(jobExecution) {
if(jobExecution==_active) {
_active=null;
}
}
}
}
然后,注入(inject)Job定义:
<job id="myJobConfig">
<listeners>
<listener ref="myListener"/>
</listeners>
</job>