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/

相关文章:

java - 不想使用无限强度策略文件

java - 如何使用MongodbJobStore(通过文件quartz.properties)连接到项目java webapplication中的mongodb?

java - 添加的Gradle依赖项无法在Java类中导入

java - 马蒂斯还是 Jigloo?

json - 使用 Json.format 没有可用的 MyClass 隐式格式

scala - "def someFun[_] (a:Int) = a",没有警告也没有错误。普通的?

unit-testing - 测试传出 Akka Actor 消息

scala - 分组并在 spark sql 中获取第一个值

akka - 杀死 parent Actor 是否也会杀死 child ?看到一些不同的行为

scala - 有什么方法可以避免在 Akka 伴随对象中定义 props 方法?