java - 在 Actor 中停止 Akka Actor

标签 java scala akka actor

我有一个 actor 打算做一个长时间运行的工作并且不再接收任何消息:

    actor {
       def receieve => longRunningJob()
    }

如何调试这个 actor 的杀戮?

我遵循了“在 Actor 中,您可以通过使用上下文引用来停止子 Actor :”的文档:

    context.stop(childActor)

我也曾尝试向 child 发送一条 Kill 消息、一条 Stop 消息和一条 PoisonPill 消息,但在长时间运行的作业进行到一半时,没有什么能阻止它。

最佳答案

这并不是说停止 Actor 是失败的,因为 Actor 从未有机会处理与停止它相关的消息。 Actor 在设计上是单线程的,应该构造成在消息循环中尽可能少地阻塞。

在这种情况下,您真正​​要问的是“如何中断线程”,因为longRunningJob 似乎是一个单线程、阻塞、时间密集型任务,并且答案是,确实没有什么好办法

进入“处理长时间运行的作业”状态的 Actor 应该在不阻塞消息循环本身的情况下这样做,或者通过让作业本身是异步的(如果 Actor 停止了)或者工作本身由许多小步骤组成,每个步骤都会触发下一步并返回一条消息给自己,这样a)你可以收到其他消息和b)有机会在中间中断工作- 通过。

关于java - 在 Actor 中停止 Akka Actor,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32910838/

相关文章:

testing - 什么被认为是 "best practice"来测试 akka 中的语义竞争条件?

java - 使用单线程 ForkJoinPool 在 Future 内运行 Future.map

java - Akka的事件总线是否保证消息顺序?

java - MySQL从存储引擎读取自增值失败

java - 如何提取 .txt 文件的内容

java - Android Studio 无法识别字体

scala - Apache Toree 和 Spark Scala 在 Jupyter 中不起作用

java - 如何在收到用户输入后执行打印语句

scala - 为什么以及如何将案例类迁移到 Scala 中的提取器

scala - Scala的语义可遍历,可迭代,序列,流和 View ?