Akka演员工作移交与未来

Question

我试图在akka演员之间建立一个信息传递过程，代表主人给工人一份工作，并密切关注它。我的问题是

1. 我在下面提出的是一个合理的方法，以及
2. 即使不是，我也想知道如何通过期货的组成来正确完成它，为了我的未来教育。

我想要的过程是这样的

1）Master用ask将工作发送给Worker。它希望在5秒内得到回复，否则它认为工人失去了机会，它将不得不再次进入竞标。

import context.dispatcher
implicit val timeout = Timeout(5 seconds)
val workCompletedFuture = (worker ? WorkTicket(work)).mapTo[Future[WorkCompleted]]

2a）如果工人在5秒内没有响应，我希望主人给自己发送一条消息，说明重新分配工作。

self ! WorkAllocationFailed(work, worker)

2b）如果工人确实回复了，那么它会给我们一个未来[工作完成]。我想等待这个未来完成最多，比如，2分钟。

3a）如果未来[工作完成]未能在超时内完成，则重新分配工作

self ! WorkFailed(work, worker)

3b)如果未来[工作完成]成功，则收集结果

我曾尝试创建此逻辑，但嵌套的onComplete让我陷入了困境，我不知道如何在将来[WorkCompleted]执行超时。我试着阅读Akka 2.10期货文档，但找不到解决方案。

Answer 1

总的来说，你有一个将工作交给一群工人的大师，这是一个很好的模式。

另一方面，当你的系统的所有部分都已经是演员时，我不建议使用期货。您可以通过tell发送作品，而不是使用ask提交作品。然后，主服务器可以定期检查超时的作业，并再次重新提交它们。

此外，在Actor的主体中调用on完成是非常危险的，因为它在可能不同的线程上执行。与Actor通信的安全方式是通过消息传递。如果您有一个Future并且您希望在Future完成后在Actor中执行某些事情，最好使用管道模式。

代码段中还有一个小错误。如果您的worker-actor回复为WorkCompleted，那么这就是您真正想要的行：

val workCompletedFuture = (worker ? WorkTicket(work)).mapTo[WorkCompleted]

Answer 2

我同意Endre的回答-所有这些都是非常好的观点。

怎么样：

1） 为自己安排一条超时消息（使用system.Schedule.scheduleOnce）

2）使用常规告诉将工作消息发送给工人

3a)如果已完成的工作在超时消息之前返回，请取消计划的工作，并使用步骤1和2重新分配工作

3b） 如果已完成的工作在超时消息后返回，则忽略它或取消重新分配的工作。

未来可能有帮助的一个地方是在工人身上，特别是如果工作需要很长时间或被阻止。工作人员可以使用将来来完成工作，并保持可用以处理更多传入消息，例如取消工作。