Как создать шаг async в Spring-Batch?

Question

У меня есть существующая весенняя партия Step, и я хотел бы реорганизовать ее с помощью процессора Async.

StepBuilderFactory steps; 
steps.get("test").chunk(1000) 
     .reader(new FlatFileItemReader<String>()) 
     .processor(new AsyncItemProcessor<String, String>()) 
     .writer(new AsyncItemWriter<String>()) 
     .build(); 

Это не работает и жалуется на процессор:

The method processor(ItemProcessor<? super Object,? extends Object>) in the type SimpleStepBuilder<Object,Object> is not applicable for the arguments (AsyncItemProcessor<String,String>).

Как сделать шаг с использованием async?

Answer 1

Вам необходимо обернуть вывод процессора в java.util.concurrent.Future для AsyncItemProcessor.

API