当前位置: 首页 > 知识库问答 >
问题:

如何暂时停止Akka演员阅读邮箱邮件

奚晟
2023-03-14

我有一个actor处理消息并通过异步API(ReactiveMongo)存储其结果。IE当计算完成时,actor请求ReactiveMongo存储计算结果,该调用是非阻塞的。

如何停止参与者处理下一个消息,直到上一个ReactiveMongo请求功能完成?此外,邮箱应该能够接收传入的消息。

共有1个答案

尚宏硕
2023-03-14

这是错误的,因为不阻塞内部的演员。

不阻塞解

master\worker模式很好地解决了这个问题:http://letitcrash.com/post/29044669086/balancing-workload-across-nodes-with-akka-2

 类似资料:
  • 我经常发现自己使用一个“主”角色,为子任务创建许多子角色。当子任务完成时,主角也应该停止自己。所以当时,我观察子角色并停止主角色context.children.is。 我经常使用这种模式,但因为我从未读过这方面的文章。我不确定,这是一个好主意还是失败的演员有问题。。。? 我已经读过Akka 2中的关机模式,但是这种方法在Java中似乎比我的解决方案更复杂? 以下是我针对具有两个子任务的主要参与者

  • java.util.concurrent.CompletionException:Akka.Pattern.AskTimeoutException:收件人[Actor[akka:/web_server/user/MyActor#-769383443]]已终止。发送者[null]发送了类型为“com.data.model.request”的消息。 所以我重写了方法,在那里添加了一个log语句。 现在

  • 我想知道如何有效地清理在飞行中创建的akka演员。 要提供一点背景信息: 每个事件创建的演员层次结构。 主管- 在我的应用程序中,主管参与者动态创建其他参与者(在定期事件上)。我想在该事件的处理步骤完成后清理参与者。 所以,一旦处理完成,我想杀死所有的儿童演员。 我在成功完成后以与创建相反的方式传播消息(successfulProcessing)。(1)- 这是主管演员的代码。 这是清理动态创建的

  • 我需要启动Akka(2.0)演员系统,发送一些消息,然后等待它做重举。之后,我需要做一些与那些演员无关的事情。 我试图等待所有参与者停止以下代码: 所有演员通过<代码>自我自杀!PoisonPill。我做错了什么?

  • 我正在尝试创建一个使用EWS服务侦听Exchange room邮箱中的事件的项目。 我们可以通过将邮箱id传递给方法“getUserSettings”来获取组信息。 感谢任何帮助

  • 本文向大家介绍PHP示例演示发送邮件给某个邮箱,包括了PHP示例演示发送邮件给某个邮箱的使用技巧和注意事项,需要的朋友参考一下 首先,建立一个index.html文件,代码如下: 然后新建一个“mail.php”文档把传输的文档进行发送 最后编写一个邮件类“smtp.php” 总结 以上就是这篇文章的全部内容了,希望本文的内容对大家的学习或者工作具有一定的参考学习价值,谢谢大家对呐喊教程的支持。