Comment configurer le multi-threading dans Spring Batch?

J'ai réussi à mettre en place un tutoriel Spring Batch projet. J'aimerais vraiment savoir si il est possible de faire du multi-thread au "Printemps".

L'idée de base de ce que je veux, c'est de faire une liste de tâches ou étapes d'une tâche et de les laisser être repris et travaillés par les threads indépendants, idéalement hors d'une réserve limitée à 'n' le nombre de threads.

Est-ce possible? Si oui, comment? Quelqu'un pourrait-il montrer qu'il me guide, à partir de là où je suis actuellement?

Le projet que j'ai, c'est à partir de ce tutoriel ici. Il a fondamentalement différentes tâches d'impression un message à l'écran.

Voici mon actuel simpleJob.xml fichier qui contient les détails de la tâche:

<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>

Mon appContext contient de l'emploi référentiel de haricot (SimpleJobRepository), gestionnaire de transactions (ResourceLessTransactionManager) et de l'emploi lanceur (SimpleJobLauncher). Je peux fournir ce code, si désiré, en même temps, je ne voulais pas ralentir ce post avec des tonnes de XML.

Merci beaucoup pour toute aide!

source d'informationauteur Cuga | 2010-02-24

  1. 10

    Créer une Scission et vous serez en mesure d'utiliser le multithreading entre les différentes branches.
    Utiliser un TaskExecutor à définir votre parallélisme politique.

    Voir Multi-thread Étape

    Assurez-vous d'utiliser la dernière version de Spring Batch si vous souhaitez utiliser le multithreading et la MapJobRepository (avant dernière version, ce JobRepository n'était pas thread-safe).

  2. 4

    Prendre un coup d'oeil à Jean réponses". Un moyen facile est de créer un bean de SimpleAsyncTaskExecutor et d'y associer une tasklet à utiliser ce bean, comme ça.

    <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>