Spring Batch FlowJobBuilder：“JobStep”类型步骤的并行和顺序执行

Question

我有一份由不同的工作组成的工作。我希望在其他作业步骤完成后，一起触发一批这些作业步骤(JobStep1、JobStep2、JobStep3)（在不同的线程中与AsyncTaskExecutor一起运行）和最后一个作业步骤(JobStep4)。因此，我为每个JobStep创建了不同的流，并用AsyncTaskExecutor将它们放在一个流中。我还为最后一个JobStep做了一个单独的流。

完成工作时的工作步骤1工作步骤2工作步骤3工作步骤4

 Flow flowJob1= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep1).end(); 

 Flow flowJob2= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep2).end(); 

Flow flowJob3= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep3).end(); 

Flow flowJob4= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep4).end(); 

 Flow splitFlow = new FlowBuilder<Flow>("splitflow").split(new SimpleAsyncTaskExecutor()).add(flowJob1,flowJob2,flowJob3).build(); 

JobFlowBuilder jobFlowBuilder = jobBuilderFactory.get(jobName).repository(jobRepository)
                .start((Flow)splitFlow);

            jobFlowBuilder.next(flowJob4);
        FlowJobBuilder flowJobBuilder= jobFlowBuilder.build();
        Job parentJob = flowJobBuilder.build();
        return parentJob;

问题是：主作业没有等待所有作业步骤（在不同的线程中）完成，然后运行下一个作业步骤。有没有我应该做的spring batch配置来解决这个问题？

Answer 1

您需要将JobStep1-3组合成一个flowStep。然后使用常规的SimpleJobBuilder构建作业。

Flow flowJob1= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep1).end(); 

Flow flowJob2= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep2).end(); 

Flow flowJob3= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep3).end(); 

// Don't need this
// Flow flowJob4= new FlowBuilder<Flow>(jobStep.getName()).from((JobStep)jobStep4).end(); 

Flow splitFlow = new FlowBuilder<Flow>("splitflow").split(new SimpleAsyncTaskExecutor()).add(flowJob1,flowJob2,flowJob3).build();

FlowStep flowStep = new FlowStep(splitFlow);

SimpleJobBuilder jobBuilder = new JobBuilder(yourJobName).start(flowStep);

jobBuilder.next(jobStep4);