如何使用worker actor正确实现作业队列

Question

我有一个演员，代表工人为繁重的长时间工作：

class Worker extends Actor{

  override def receive: Receive = {
    case "doJob" =>
      Thread.sleep(999999)
      sender ! "JobResult"
  }

}

如果队列已满，我将限制作业队列并显式拒绝用户。实现此逻辑的最佳实践是什么。我应该使用绑定邮箱还是某个调度程序，即监视作业队列？如下所示：

class Dispatcher(worker:ActorRef) extends Actor{

  val MAX_JOBS = 10

  var jobs = 0

  override def receive: Receive = {
    case "newJob" =>
      if (jobs >= MAX_JOBS) sender ! "Try later"
      jobs+=1
      worker ! "doJob"

    case "JobResult" =>
      jobs-=1
  }

}

在这种情况下，我也不确定如何正确处理故障……

Answer 1

我认为最好的做法是为worker参与者使用一个有限制的邮箱。

然后，您可以在如下配置中配置bounded：

bounded-mailbox {   mailbox-type = "akka.dispatch.BoundedMailbox"  
mailbox-capacity = 1000   mailbox-push-timeout-time = 10s  }

akka.actor.mailbox.requirements {  
"akka.dispatch.BoundedMessageQueueSemantics" = bounded-mailbox 
}

您还可以指定您想要的邮箱类型(从内置类型)或创建自己的自定义邮箱，具有自己的特性和规范。(首先处理哪些消息，等等)

我认为在你的场景中是最好的: 1.创建你自己的邮箱，它有自己的错误机制和自定义的清理/绑定限制。(基于受限邮箱特征) 3.将调度程序附加到您通过配置创建的自定义邮箱。