scala – 如何突然停止akka流Runnable Graph？

发布时间：2020-12-16 10:00:55 所属栏目：安全来源：网络整理

导读：我无法弄清楚如何立即停止akka流Runnable Graph？如何使用killswitch实现这一目标？我开始使用akka流只需要几天时间.在我的情况下,我正在从文件中读取行并在流程中执行一些操作并写入接收器.我想做的是,随时随地停止阅读文件,我希望这可能会停止整个运行图.

我无法弄清楚如何立即停止akka流Runnable Graph？如何使用killswitch实现这一目标？我开始使用akka流只需要几天时间.在我的情况下,我正在从文件中读取行并在流程中执行一些操作并写入接收器.我想做的是,随时随地停止阅读文件,我希望这可能会停止整个运行图.任何有关这方面的想法将不胜感激.

提前致谢.

解决方法

从Akka Streams 2.4.3开始,有一种优雅的方式可以通过 KillSwitch从外面阻止溪流.

请考虑以下示例,该示例在10秒后停止流.

object ExampleStopStream extends App {

  implicit val system = ActorSystem("streams")
  implicit val materializer = ActorMaterializer()

  import system.dispatcher

  val source = Source.
    fromIterator(() => Iterator.continually(Random.nextInt(100))).
    delay(500.millis,DelayOverflowStrategy.dropHead)
  val square = Flow[Int].map(x => x * x)
  val sink = Sink.foreach(println)

  val (killSwitch,done) =
    source.via(square).
    viaMat(KillSwitches.single)(Keep.right).
    toMat(sink)(Keep.both).run()

  system.scheduler.scheduleOnce(10.seconds) {
    println("Shutting down...")
    killSwitch.shutdown()
  }

  done.foreach { _ =>
    println("I'm done")
    Await.result(system.terminate(),1.seconds)
  }

}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!