我可以在春季批处理中将FlatfileItemReader与Taskexecutor一起使用吗？
我已经用ThreadPoolTaskExecutor实现了FlatFileItemReader。当我在ItemProcessor中打印记录时，没有得到一致的结果，即不是所有记录都被打印，有时其中一个记录被打印多次。这使我想到一个事实，即FlatFileItemReader不是线程安全的，并且在spring文档中也是如此，但是我看到一些博客说可以在Task Executor中使用FlatFileItemReader。
所以我的问题是：是否可以将FlatfileItemReader与Task Executor一起使用？
@Bean
@StepScope
public FlatFileItemReader<DataLifeCycleEvent> csvFileReader(
@Value("#{stepExecution}") StepExecution stepExecution) {
Resource inputResource;
FlatFileItemReader<DataLifeCycleEvent> itemReader = new FlatFileItemReader<>();
itemReader.setLineMapper(new OnboardingLineMapper(stepExecution));
itemReader.setLinesToSkip(1);
itemReader.setSaveState(false);
itemReader.setSkippedLinesCallback(new OnboardingHeaderMapper(stepExecution));
String inputResourceString = stepExecution.getJobParameters().getString("inputResource");
inputResource = new FileSystemResource(inputFileLocation + ApplicationConstant.SLASH + inputResourceString);
itemReader.setResource(inputResource);
stepExecution.getJobExecution().getExecutionContext().putInt(ApplicationConstant.ERROR_COUNT, 0);
return itemReader;
}
FlatFileItemReader扩展AbstractItemCountingItemStreamItemReader这是不是线程安全的。因此，如果在多线程步骤中使用它，则需要对其进行同步。
您可以将其包装在中SynchronizedItemStreamReader。这是一个简单的示例：
@Bean
public SynchronizedItemStreamReader<DataLifeCycleEvent> itemReader() {
FlatFileItemReader<DataLifeCycleEvent> itemReader = ... // your item reader
SynchronizedItemStreamReader<DataLifeCycleEvent> synchronizedItemStreamReader = new SynchronizedItemStreamReader<>();
synchronizedItemStreamReader.setDelegate(itemReader);
return synchronizedItemStreamReader;
}
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句