我有一个 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/