如何通过线程池运行spring-batch作业？

Question

我正在使用joblauncher.run()启动spring-batch作业。问题：我如何线程化这些调用？以便最多有4个作业线程可以并发运行，而任何其他作业都只是排队？

    @Autowired
    private JobRegistry registry;

    @Autowired
    private JobLauncher launcher;

Job job = registry.getJob("jobname");
launcher.run(job, params); //immediately starts the job

Answer 1

您可以将ThreadPoolTaskExecutor设置为SimpleJobLauncher（实际启动作业的类）使用的任务执行器。这个执行器有一些您可以设置的属性，特别是MaxPoolSize。

public JobLauncher createJobLauncher() {
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setCorePoolSize(4);
    taskExecutor.setMaxPoolSize(4);
    taskExecutor.afterPropertiesSet();

    SimpleJobLauncher launcher = (SimpleJobLauncher) super.createJobLauncher();
    launcher.setTaskExecutor(taskExecutor);
    return launcher;
}