scala - Akka流-计时器或计划程序(如CRON)

Question

我在Scala上使用Akka Stream。 我想设置一个调度程序，该调度程序每24:00 运行一次。我试图寻找它。但是我找不到我想做的事。你能告诉我怎么写代码吗？

Answer 1

使用Akka Scheduler中的构建，请参阅:
http://doc.akka.io/docs/akka/current/scala/scheduler.html

您可以像这样使用调度程序:

system.scheduler.schedule(
  initialDelay = FiniteDuration(/*offset to next 24:00*/),
  interval = FiniteDuration(24, TimeUnit.HOURS),
  receiver = self,
  message = ScheduleAkkaStream
)

然后在actor中，当收到ScheduleAkkaStream时，运行作业