我在Scala上使用Akka Stream。 我想设置一个调度程序,该调度程序每24:00 运行一次。我试图寻找它。但是我找不到我想做的事。你能告诉我怎么写代码吗?
最佳答案
使用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时,运行作业
关于scala - Akka流-计时器或计划程序(如CRON),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38475895/