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

标签 scala akka-stream

我在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/

相关文章:

mongodb - 使用 Scala 创建嵌套字段并将数据框存储到 MongoDB?

algorithm - 如何修改我的 Akka 流 Prime 筛子以排除对已知素数的模检查?

scala - Akka Stream 和 HTTP Scala : How to send Messages to an Actor from a Route

scala - 你如何处理 Akka Flow 中的 futures 和 mapAsync?

scala - 有没有办法通过 sbt 插件获取项目的所有依赖项?

postgresql - 在表定义时检查字符串是否在列表中

scala - databinder 调度无法正确处理 HTTP 302 和身份验证

scala - 使用大量带有 self 类型的 mixin

scala - Akka 流。分组,聚合一段时间并发出结果

scala - Akka 流 : How to group a list of files in a source by size?