Создание планировщика / таймера внутри актера, набранного akka

Question

Я пытаюсь создать планировщик в моем akka, набранном только для его проверки, например, запускать каждые x секунд.

def start(): Behavior[ClientMsg] = Behaviors.setup { ctx =>
    ctx.log.info("start() called")

  ctx.system.scheduler.scheduleAtFixedRate(30.seconds, 5000.millis) { () =>
    ctx.self ! TestMessage(""""this is pretty cool"""")
  }  
}

Я получаю сообщение об ошибке, говорящее, что неявный контекст выполнения не scope.

Где мне взять контекст выполнения, когда он находится внутри типизированного субъекта? Кроме того, это, как я должен настроить планировщик / таймер?

Answer 1

Обратите внимание, что использование Behaviors.withTimers { timers => ... } должно быть предпочтительнее прямого использования системного планировщика, поскольку он обрабатывает удаление запланированных отправок, если актеры прекращают работу, и т. Д. c.

Answer 2

В нетипизированном Akka по умолчанию ExecutionContext - это объект dispatcher в system объекте:

implicit val executionContext: ExecutionContext = ctx.system.dispatcher

Я помещаю это в базовый класс, который я использую для всех актеров, наряду с со значениями по умолчанию для Timeout и ActorMaterializer.