在 Actor 中停止 Actor

Question

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

    actor {
       def receieve => longRunningJob()
    }

如何调试这个演员的杀戮？

我已经按照说明 "Within an actor, you can stop a child actor by using the context reference:"

的文档进行操作

    context.stop(childActor)

我也曾尝试向 child 发送一条 Kill 消息、一条 Stop 消息和一条 PoisonPill 消息，但在漫长的运行工作中没有任何东西阻止它。

Answer 1

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

在这种情况下，您真正要问的是 "how to interrupt a thread"，因为 longRunningJob 似乎是一个单线程、阻塞、耗时的任务，并且答案是，实在是没有什么好办法。

进入 "processing a long running job" 状态的 Actor 应该在不阻塞消息循环本身的情况下这样做，要么让作业本身是异步的（使其成为孤儿）并且运行如果 actor 停止了）或者作业本身由许多小步骤组成，每个小步骤都会触发下一步并返回一条消息给自己，这样 a) 你可以收到其他消息 b) 有中途中断工作的机会。

在 Actor 中停止 Actor

Stop an Akka Actor inside Actor

java

scala

actor

akka