java - 具有长时间运行任务的队列的 Actor 设计

Question

我有一堆 actors 正在运行，它们需要将要按顺序处理的任务排入队列，一次处理一个。我需要一个 Actor 来处理队列中的任务。创建一个 Actor 并将对该 Actor 的引用作为参数传递给每个作业(隐式队列)是否可以？例如。

Actor :

class QActor extends Actor{
  def receive = {
    case input => sender ! doSomething(input)
  }
}

发件人

val future = myQActor ? msg
Await.result(future)

Answer 1

使用另一个 actor 和它的邮箱作为队列是可以的，只是不要阻塞发送者。