代码之家  ›  专栏  ›  技术社区  ›  MaatDeamon

使用分区阶段的Akka流

  •  1
  • MaatDeamon  · 技术社区  · 8 年前

    我试图找到一个例子来说明如何使用Akka流分区功能。我正在尝试优化写一个商店。为此,我想在我选择的一批项目中分组,并立即编写它们,然而,为了利用并行性,我想并行进行。因此,批处理和数据库中的写入将在8个并发线程上进行。

    我可以在8个并行线程上一次更新30条记录。

    但首先,我该如何使用分区。我必须构建GraphBuilder吗?

    1 回复  |  直到 8 年前
        1
  •  3
  •   Stefano Bonetti    8 年前

    的使用示例 Partition 可以找到 here

    Balance 舞台是你需要的。这些文件提供了一个示例 here .

    在这两种情况下,您都需要使用GraphDSL here