关于actor系统和akka流的干净关闭

问题描述 投票:0回答:0

我们希望在 akka 流关闭时完成以下任务

  1. 源已停止,
  2. 流中的元素在超时点之前已完成
  3. 然后流/Actor系统关闭

我们有以下代码用于关闭我们的 Actor 系统(Akka 2.4)。

    try {
      Await.ready(actorSystem.terminate(), sleepSeconds.seconds)
    } catch {
      case ex: Throwable => log.error("Failed to terminate actor system", ex)
    }

我正在尝试理解 akka 文档,但我不清楚我们是否需要单独关闭物化器(对于我们的 akka 流)?我们在这里有一个关于物化器的方法和一个关于 Actor 系统的方法。

或者换句话说,我们应该采取什么惯用的操作步骤来干净/优雅地关闭我们的 akka 流。

scala akka akka-stream
© www.soinside.com 2019 - 2024. All rights reserved.