如何在弹簧批次中设置多线程？

multithreading java spring spring-batch

2022-09-04 01:54:16

我已经成功地设置了一个教程Spring Batch项目。我真的很想知道是否有可能在“春季级别”使其多线程化。

我想要的基本思想是列出任务或任务步骤，让它们被独立线程拾取和处理，理想情况下是从限制为“n”个线程的池中取出。

这可能吗？如果是这样，如何？有人能从我现在所处的位置引导我到那个地步吗？

我拥有的简单项目来自本教程。它基本上具有不同的任务，这些任务将消息打印到屏幕上。

以下是我当前的 simpleJob.xml 文件，其中包含作业详细信息：

<import resource="applicationContext.xml"/>

    <bean id="hello" class="helloworld.PrintTasklet">
        <property name="message" value="Hello"/>
    </bean>

    <bean id="space" class="helloworld.PrintTasklet">
        <property name="message" value=" "/>
    </bean>

    <bean id="world" class="helloworld.PrintTasklet">
        <property name="message" value="World!\n"/>
    </bean>

    <bean id="taskletStep" class="org.springframework.batch.core.step.tasklet.TaskletStep" >
        <property name="jobRepository" ref="jobRepository"/>
        <property name="transactionManager" ref="transactionManager"/>
    </bean>

    <bean id="simpleJob" class="org.springframework.batch.core.job.SimpleJob">
        <property name="name" value="simpleJob" />
        <property name="steps">
            <list>
                <bean parent="taskletStep">
                    <property name="tasklet" ref="hello"/>
                </bean>
                <bean parent="taskletStep">
                    <property name="tasklet" ref="space"/>
                </bean>
                <bean parent="taskletStep">
                    <property name="tasklet" ref="world"/>
                </bean>
            </list>
        </property>
        <property name="jobRepository" ref="jobRepository"/>
    </bean>

我的 appContext 包含作业存储库 Bean （）、事务管理器（）和作业启动器（）。如果需要，我也可以提供此代码，我只是不想用大量的XML来困扰这篇文章。SimpleJobRepositoryResourceLessTransactionManagerSimpleJobLauncher

非常感谢您的任何帮助！

答案 1

创建拆分，您将能够在不同分支之间使用多线程。使用任务执行器定义并行性策略。

请参阅多线程步骤

如果要使用多线程和MapJobRepository（在最新版本之前，此JobRepository不是线程安全的），请确保使用最新版本的Spring Batch。

答案 2

看看Jean的答案'。一个简单的方法是创建一个 SimpleAsyncTaskExecutor 的 bean，并关联一个 tasklet 来使用这个 bean，就像这样。

<bean id="simpleTaskExecutor"
    class="org.springframework.core.task.SimpleAsyncTaskExecutor">
    <property name="concurrencyLimit" value="10"/>
</bean>

<batch:job id="jobTest">
    <batch:step id="step1">
    <!-- throttle-limit default is 4. Increase this to ensure that a thread pool is fully utilized -->
        <batch:tasklet task-executor="simpleTaskExecutor" throttle-limit="20">
            <batch:chunk />
        </batch:tasklet>
    </batch:step>
</batch:job>