multithreading - 处理Akka actor的receive方法中的异步调用的最佳方法

Question

我正在尝试将数据持久保存到数据库中。我的persist方法是异步的。

class MyActor(persistenceFactory:PersistenceFactory) extends Actor {
  def receive: Receive = {
    case record: Record =>
      // this method is asynchronous, immediate return Future[Int]
      persistenceFactory.persist(record) 
  }
}

当应用程序在增加的负载下运行时，瓶颈就在这里，要么是我们内存不足，要么是没有可用的线程。

那么，在Akka actor的receive方法内部处理异步调用的最佳方法是什么？

Answer 1

这是一个很好的示例，说明何时应该让一个 Actor 创建另一个 Actor 来处理交互。从本质上讲，流程是这样的，并且如果可以使您更轻松，也可以使用FSM(有限状态机)。

父 Actor 收到消息

父 Actor 创建子事务 Actor

父级向 child 发送原始消息

子级调用异步方法并存储Future

Child使用begin()更改其行为，以等待将来完成。有很多方法可以做到这一点，包括FSM。

子schedules periodic messages to itself检查将来的

child 的新行为会检查Future是否在每次接收

时完成

当Future完成时， child 可以将结果与父或原始发件人进行答复(如果 parent 与原始发件人一起发送了该消息)。