异步处理器

异步处理器帮助你扩展项目处理。在异步处理器使用场景中,一个异步项目处理器作为调度器,执行 的逻辑 这ItemProcessor对于新线程上的某个项目。一旦该项目完成,前途是 传给异步项目写手待书写。spring-doc.cadn.net.cn

因此,通过使用异步项目处理,基本上可以提升性能,实现分叉-连接场景。 这异步项目写手收集结果在所有结果可用时立即写回该块。spring-doc.cadn.net.cn

以下示例展示了如何配置异步项目处理器在爪哇语中:spring-doc.cadn.net.cn

Java 配置
@Bean
public AsyncItemProcessor processor(ItemProcessor itemProcessor, TaskExecutor taskExecutor) {
    AsyncItemProcessor asyncItemProcessor = new AsyncItemProcessor();
    asyncItemProcessor.setTaskExecutor(taskExecutor);
    asyncItemProcessor.setDelegate(itemProcessor);
    return asyncItemProcessor;
}

以下示例展示了如何配置异步项目处理器以XML形式表示:spring-doc.cadn.net.cn

XML 配置
<bean id="processor"
    class="org.springframework.batch.integration.async.AsyncItemProcessor">
  <property name="delegate">
    <bean class="your.ItemProcessor"/>
  </property>
  <property name="taskExecutor">
    <bean class="org.springframework.core.task.SimpleAsyncTaskExecutor"/>
  </property>
</bean>

委托财产指的是你的ItemProcessor豆子,以及任务执行者属性指的是任务执行者由你选择。spring-doc.cadn.net.cn

以下示例展示了如何配置异步项目写手在爪哇语中:spring-doc.cadn.net.cn

Java 配置
@Bean
public AsyncItemWriter writer(ItemWriter itemWriter) {
    AsyncItemWriter asyncItemWriter = new AsyncItemWriter();
    asyncItemWriter.setDelegate(itemWriter);
    return asyncItemWriter;
}

以下示例展示了如何配置异步项目写手以XML形式表示:spring-doc.cadn.net.cn

XML 配置
<bean id="itemWriter"
    class="org.springframework.batch.integration.async.AsyncItemWriter">
  <property name="delegate">
    <bean id="itemWriter" class="your.ItemWriter"/>
  </property>
</bean>

再说一次,委托属性是实际上是对你ItemWriter豆。spring-doc.cadn.net.cn