斯卡拉 – 阿卡调度模式

class WordCountWorker extends Actor {

  def receive = {
    case FileToCount(fileName:String) =>
      val count = countWords(fileName)
      sender ! WordCount(fileName,count)
  }
}

class WordCountMaster extends Actor {
  def receive = {
    case StartCounting(docRoot) => // sending each file to worker
      val workers = createWorkers()
      fileNames = scanFiles(docRoot)
      sendToWorkers(fileNames,workers)
    case WordCount(fileName,count) => // aggregating results
      ...

  }
}

但我希望按计划运行此字数统计程序(例如每1分钟),提供不同的扫描目录.

而Akka为调度消息传递提供了很好的方法：

system.scheduler.schedule(0.seconds,1.minute,wordCountMaster,StartCounting(directoryName))

但是上述调度程序的问题在调度程序通过tick发送新消息时启动,但之前的消息尚未处理(例如我发送消息扫描一些大目录,1秒后我发送另一条消息来扫描另一个目录,因此操作第一个目录的处理尚未完成).因此,我的WordCountMaster将从处理不同目录的工作人员收到WordCount消息.

作为一种解决方法而不是安排消息发送,我可以安排执行某些代码块,每次创建新的WordCountMaster时都会创建.即一个目录=一个WordCountMaster.但我认为它效率低下,而且我还需要关心为WordCountMaster提供唯一的名称以避免InvalidActorNameException.

所以我的问题是：我是否应该像上面提到的那样为每个刻度创建新的WordCountMaster？或者有一些更好的想法/模式如何重新设计该程序以支持调度？

一些更新：
如果每个目录创建一个主演员,我有一些问题：

>命名演员的问题

InvalidActorNameException: actor name [WordCountMaster] is not unique!

和

InvalidActorNameException: actor name [WordCountWorker ] is not
unique!

我可以克服这个问题而不提供演员姓名.但在这种情况下,我的演员会收到自动生成的名字,比如$a,$b等.这对我来说并不好.

>配置问题：

我想将我的路由器的配置排除在application.conf之外.即我想为每个WordCountWorker路由器提供相同的配置.但由于我不控制演员姓名,所以我不能使用下面的配置,因为我不知道演员姓名：

/wordCountWorker{
    router = smallest-mailbox-pool
    nr-of-instances = 5
    dispatcher = word-counter-dispatcher
  }