Akka actor 在等待新消息时仍在工作？

Question

我是 Akka 新手，如果这是一个基本问题，我提前道歉。我不确定如何使用参与者来实现以下场景，或者是否可能（或可取）。

• 我有许多参与者（即生产者）负责同时维护某些状态，所有这些状态在发生更改时都会通知另一个参与者（即消费者）。
• 消费者要重复运行某个任务，该任务需要所有生产者的状态才能启动。当它收到来自生产者的消息时，它还必须响应状态的变化。

在考虑 Akka 之前，我有点推出了自己的简单 Actor 模型，每个 Actor 都在自己的线程中运行。 run() 方法将监视事件队列，因此我可以让使用者不断执行类似的操作：

while not done
    poll the event queue
    if something was polled
        process the event
    if all state is available
        do one step of the long running task

事件队列的连续轮询不太适合我，但它至少在长时间运行的任务上取得了进展事件之间。

有没有最好的方法来使用 Akka 演员来实现这个？我可以实现一个“心跳”，它向消费者发送一条消息（或者自己在内部发送给消费者）来执行另一个步骤长时间运行的任务，但我不喜欢安排它的想法，因为长时间运行的任务中的步骤在持续时间上并不统一。我不想对迭代进行排队，这会让迭代变得太忙，从而无法快速响应来自生产者的消息。但我也不想太频繁地安排它，所以当它可以取得进展时它就处于闲置状态...

或者为此使用并发的数据流模型是否更合适（我只知道准备好了吗？ 在状态全部绑定之前，消费者无法启动，因此根据数据流变量定义流程似乎很自然。但是，如果数据流变量只能绑定一次，那么从消费者那里获取重复的状态更新似乎并不合适。

Answer 1

您可以让产品将更改发布到 Akka EventBus，并让消费者注册来侦听这些事件，然后当它拥有所需的所有数据时，它可以处理完整的块，或者生成一个处理完整块的新参与者。