如何控制平行Spring批量作业的数量

Question

我有一个报告生成应用程序。由于这类报告的准备是重量级的，因此它们是用Spring Batch异步准备的。对此类报告的请求是通过使用HTTP的REST接口创建的。

目标是REST资源只需对报告执行进行排队并完成（如文档中所述）。因此，为JobLauncher提供了一个TaskExecutor：

    <bean id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
        <property name="jobRepository" ref="jobRepository" />
        <property name="taskExecutor">
        <bean class="org.springframework.core.task.SimpleAsyncTaskExecutor"/>
    </property>
</bean>

由于报告确实是重量级的，在给定的时间内只能生成特定数量的报告。为了能够将Spring Batch配置为一次只生成2个实例，指定了concurrencyLimit：

    <bean id="jobLauncher" class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
        <property name="jobRepository" ref="jobRepository" />
        <property name="taskExecutor">
        <bean class="org.springframework.core.task.SimpleAsyncTaskExecutor">
            <property name="concurrencyLimit" value="2" />
        </bean>
    </property>
</bean>

谢谢f

Answer 1

SimpleAsynctaskExecutor不建议大量使用，因为它为每个任务生成一个新线程。它也不支持更健壮的概念，如线程池和任务队列。

如果您看一下ThreadPoolTaskExecutor，它支持一种更健壮的任务执行范例，比如任务排队和使用线程池而不是产生随机的、未重用的线程。

您可以在以下位置阅读有关javadoc中ThreadPooltaskExecutor的更多信息：http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/schedulation/concurrent/threadPooltaskExecutor.html