完成后，分区工作不能自行停止？ 春批

我写了两个步骤的作业，其中两个步骤之一是分区步骤。 分区步骤使用TaskExecutorPartitionHandler并在线程中运行5个从属步骤。 该作业在main（）方法中启动。 但是在每个从属ItemReader返回null（结束符号）之后它不会停止。 即使程序运行了main（）方法中的最后一行代码（即System.out.println（“Finished”）），程序进程也不会停止，挂在内存中并且什么都不做。 我必须按下Eclipse面板上的停止按钮才能停止程序。

以下是JobLauncher.run（）返回的JobExecution的内容，表示作业运行的成功状态。

JobExecution：id = 0，version = 2，startTime = Fri Nov 27 06:05:23 CST 2015，endTime = Fri Nov 27 06:05:39 CST 2015，lastUpdated = Fri Nov 27 06:05:39 CST 2015，status = COMPLETED，exitStatus = exitCode = COMPLETED; exitDescription =，job = [JobInstance：id = 0，version = 0，Job = [jobCensoredPages]]，jobParameters = [{}]

7217
成品

为什么运行成功的Spring Batch程序仍然挂起？ 请指出我在哪里工作。 我怀疑Spring Batch管理的multithreading部分没有停止..

简单的工作运行代码

Job job = (Job) context.getBean("jobPages"); try { JobParameters p=new JobParametersBuilder() .toJobParameters(); JobExecution result = launcher.run(job, new JobParameters()); System.out.println(result.toString()); } catch (Exception e) { e.printStackTrace(); } context.getBean("idSet"); AtomicInteger n=(AtomicInteger) context.getBean("pageCount"); System.out.println(n.get()); System.out.println("Finished"); 

对Patitioner和PatitionHandler的配置

  @Bean @Autowired public PartitionHandler beanPartitionHandler( TaskExecutor beanTaskExecutor, @Qualifier("beanStepSlave") Step beanStepSlave ) throws Exception { TaskExecutorPartitionHandler h=new TaskExecutorPartitionHandler(); h.setGridSize(5); h.setTaskExecutor(beanTaskExecutor); h.setStep(beanStepSlave); h.afterPropertiesSet(); return h; } @Bean public TaskExecutor beanTaskExecutor() { ThreadPoolTaskExecutor e = new ThreadPoolTaskExecutor(); e.setMaxPoolSize(5); e.setCorePoolSize(5); e.afterPropertiesSet(); return e; } 

唯一的一步，它是奴隶的一步

 @Bean public Step beanStepMaster( Step beanStepSlave, Partitioner beanPartitioner, PartitionHandler beanPartitionHandler ) throws Exception { return stepBuilderFactory().get("stepMaster") .partitioner(beanStepSlave) .partitioner("stepSlave", beanPartitioner) .partitionHandler(partitionHandler) .build(); } @Bean @Autowired public Step beanStepSlave( ItemReader beanReaderTest, ItemProcessor beanProcessorTest, ItemWriter beanWriterTest) throws Exception{ return stepBuilderFactory().get("stepSlave") .chunk(1) .reader(beanReaderTest) .processor(beanProcessorTest) .writer(beanWriterTest) .build(); } 

我的pom.xml文件

   junit junit RELEASE test   org.springframework spring-core 4.2.3.RELEASE   org.springframework spring-context 4.2.3.RELEASE   org.springframework spring-tx 4.2.3.RELEASE   org.springframework.batch spring-batch-core RELEASE   org.springframework.retry spring-retry 1.1.2.RELEASE   org.springframework spring-beans RELEASE  

Answer 1

当我使用ThreadPoolTask​​Executor时，我在分区的Spring批处理应用程序挂起时也遇到了困难。 另外，我看到执行程序不允许完成所有分区的工作。

我找到了解决这些问题的两种方法。

第一种解决方案是使用SimpleAsyncTaskExecutor而不是ThreadPoolTask​​Executor。 如果您不介意重新创建线程的额外开销，这是一个简单的修复。

第二个解决方案是创建一个JobExecutionListener，它在ThreadPoolTask​​Executor上调用shutdown。

我创建了一个JobExecutionListener，如下所示：

 @Bean public JobExecutionListener jobExecutionListener(ThreadPoolTaskExecutor executor) { return new JobExecutionListener() { private ThreadPoolTaskExecutor taskExecutor = executor; @Override public void beforeJob(JobExecution jobExecution) { } @Override public void afterJob(JobExecution jobExecution) { taskExecutor.shutdown(); } }; } 

并将其添加到我的Job定义中，如下所示：

 @Bean public Job partitionedJob(){ return jobBuilders.get("partitionedJob") .listener(jobExecutionListener(taskExecutor())) .start(partitionedStep()) .build(); } 

Answer 2

虽然我不知道原因，但有两种解决方案可以解决您的问题。

首先，您可以使用CommandLineJobRunner来启动Job 。 请参阅此处的文档 该类在作业结束时自动退出程序，并将ExitStatus转换为返回代码（ COMPLETED = 0， FAILED = 1 …）。 默认返回码由SimpleJvmExitCodeMapper提供。

第二种解决方案是在JobLauncher.run()之后手动调用System.exit()指令。 您也可以手动转换Job的ExitStatus并在手动退出中使用它：

 // Create Job JobLauncher jobLauncher = (JobLauncher) context.getBean("jobLauncher"); Job job = (Job) context.getBean(jobName); // Create return codes mapper SimpleJvmExitCodeMapper mapper = new SimpleJvmExitCodeMapper(); // Start Job JobExecution execution = jobLauncher.run(job, new JobParameters()); // Close context context.close(); // Map codes and exit String status = execution.getExitStatus().getExitCode(); Integer returnCode = mapper.intValue(status); System.exit(returnCode);