如何在Akka中使用setReceiveTimeout同步杀死子参与者

Question

背景：我正在使用C#，但我认为这个问题也适用于Java和Scala。我有一个大师级演员，负责传递所有的“工作信息”。这些作业可以同时执行，只要它们不共享“并发id”。为了解决这个问题，我为每个“并发id”生成了一个子角色。然后我用setReceiveTimeout在孩子们空闲时清理他们。

我不明白的是，在没有比赛条件的情况下，我如何做到这一点。这里有两种方法不起作用：1）从字典中删除子项，并告诉子项终止。这不起作用，因为在触发超时时间到父级开始处理消息之前，消息可能已添加到子级队列中，从而导致消息丢失。2） 将孩子从字典中删除，并发送毒药。这不起作用，因为子对象可能会继续处理新工作。如果更多的工作到达父级，父级将创建一个新的子级，这意味着两个具有相同并发id的东西同时运行。3） 从字典中删除孩子，并用信息“询问”孩子。如果消息返回

家长是否有办法询问孩子队列中是否有任何消息？（这不是竞争条件，因为给子级的所有消息都来自父级）

家长是否可以检查孩子的队列是否为空，孩子是否没有处理任何事情？

我是否应该添加新消息并“询问”孩子是否已完成？（这将是安全的，因为我知道父级是唯一发送消息的人，但是如果子级正在处理消息，或者如果调度程序的池中没有可用线程，则这可能会造成阻塞。

我的问题类似于这个问题，但我添加了"并发id"的额外约束，并不担心"僵尸演员"目前正在关闭，只要僵尸没有工作，不会得到更多的工作：获取或创建子Akka演员并确保活性

Answer 1

Akka确保演员邮箱是私有的。一个演员的邮箱不关另一个演员的事。父母检查孩子的邮箱是否是空的是错误的。

你为什么认为ask会阻止你？

一个选择：不要杀死孩子。如果您有一组固定的并发ID，您可以一次又一次地使用，只需让所有参与者保持活动状态即可。参与者不会消耗太多资源。

另一个选择：

When the parent wants to kill the child:
send a PoisonPill to the child and remove him from the Dictionary.

When the parent receives a "job message" with concurrencyID:
if (Dictionary.contains(concurrencyID) {
    send message to child
} else {
    if (parent has child with name concurrencyID) {
        delay message - for example with scheduler // child is terminating
    } else {
        create a child with name concurrencyID
        send message to child
    }
}