java - 在 Actor 中停止 Akka Actor

Question

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

    actor {
       def receieve => longRunningJob()
    }

如何调试这个 actor 的杀戮？

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

    context.stop(childActor)

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

Answer 1

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

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

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