如何查找任何以前运行的作业/任务没有在spring Batch中运行？我尝试了一些代码，但不确定

Question

我面临的问题是，有时可能有大量的数据，这可能需要工作执行超过10分钟。在这种情况下，我希望检测是否有任何作业已经在运行？如果没有，那么只有我会重新运行一个新的作业实例。如果该作业已经在运行，那么我将跳过“新作业实例调用”。我写了一些代码，如下所示。

Job job = (Job) context.getBean("job");

JobExplorer explorer = (JobExplorer) context.getBean("jobExplorer");

// Fetching all job instances.
List<JobInstance> jobInstances = explorer.findJobInstancesByJobName(
        job.getName(), 0, explorer.getJobInstanceCount(job.getName()));

// Fetching the last job instance.
JobInstance lastJobInstance = jobInstances.get(0);

//Obtain all executions for last job instance.
List<JobExecution> executions = explorer.getJobExecutions(lastJobInstance);

// fetching last job execution
JobExecution lastJobExecution = executions.get(0);

System.out.println("Is my last Job running? \nAns:"+lastJobExecution.isRunning());

一些事情，这段代码是检查以前所有正在运行的作业。我所假设的是，如果我启动服务器，那么在服务器启动之前不会有其他作业在运行，如果我在检查之前的作业是否在运行之后运行一个作业，我假设在我的调度程序代码中不会调用其他作业。

我想知道这是正确的做法吗？我的意思是要确保您在同一时间为同一作业只运行一个作业实例，并且在完成对同一作业的任何先前运行之后也是如此。

p.s作业实例、jObExplorer和jobLauncher被注入到调度器中。这只是一个类似的代码，因此使用上下文获取bean。

谢谢你的阅读。

Answer 1

如果您使用的是调度程序，那么您可能应该有一个JobLauncherDetails类，可以在其中添加参数，如

JobParameters jobParameters = getJobParametersFromJobMap(jobDataMap);

其中一个paramter可以是您的最后一个运行时，向该映射添加一个dateTime param，并使用JobCompletionReader的实例

jobCompletionReader.getLastCompleteDate()

与10分钟前比较，看看你是否完成了“10分钟前的工作”。像这样的东西应该对你有用。