Spring批处理单例读取器和多线程处理器
我必须使用Spring Batch配置一个作业。是否可以有一个单线程的项目阅读器，但多线程处理器？
在这种情况下，ItemReader将通过从数据库中读取工作项（通过执行预定义的查询）来创建要处理的工作项，每个处理器将并行处理项/块。
共有1个答案
看看spring-batch-integration模块中的AsyncitemProcessor和AsyncitemWriter。它们所做的是AsyncitemProcessor在另一个线程中执行，返回Future。然后，AsynciteMWriter展开Future并写入结果。您可以在以下文档中了解更多关于这一点的信息：https://docs.spring.io/spring-batch/apidocs/org/springframework/batch/integration/async/asyncitemprocessor.html
-
我正在尝试使用多个处理器类在处理器步骤中处理记录。这些类可以并行工作。目前我已经编写了一个多线程步骤，其中我 设置处理器类的输入和输出行 提交给遗嘱执行人服务 获取所有未来对象并收集最终输出
-
我有一个批处理步骤 读取器和处理器流程如何工作？读取器是读取块并等待处理器处理它，还是一次读取所有块。
-
null 我更新了我的步骤并添加了一个ThreadPoolTaskExecutor，如下所示 在此之后，我的处理器将被多个线程调用，但使用相同的源数据。我还有什么需要做的吗？
-
我刚开始使用Spring批处理，我有一个特殊问题。我希望使用从3个不同的jpa查询中获取结果，并分别处理它们，然后使用将它们写入一个统一的XML文件。 对于eg,生成的XML看起来像是,
-
在Spring批处理中，我试图读取CSV文件，并希望将每一行分配给一个单独的线程并对其进行处理。我试图通过使用TaskExecutor来实现它，但所有线程都在一次拾取同一行。我还尝试使用Partioner实现这个概念，同样的事情也发生了。请参阅下面我的配置Xml。 步骤说明 我尝试过不同类型的任务执行器，但它们的行为方式都是一样的。如何将每一行分配给单独的线程？
-
我目前正在处理一批数据，这些数据来自一个拥有数百万行的大型SQL数据库。 它在处理器中执行一些处理，包括通过带有连接的大型sql查询对从Reader检索到的行进行分组。 编写器将结果写入另一个表。 问题是此Batch存在性能问题，因为Sql选择查询需要大量时间并且步骤不会在多线程中执行。 因此，我希望在多标题中运行它们，但问题是，这些步骤通过计算具有相同类型的所有行的总数来对行进行分组。 因此，如