scala - 使用 Akka 的 Scheduler 调度一个函数每秒运行一次

Question

我想每秒运行一次这个 Scala 函数:

object AuthTasker {
  def cleanTokens() {
    [...]
  }
}

Akka的Scheduler有以下功能: schedule(initialDelay: FiniteDuration, interval: FiniteDuration)(f: ⇒ Unit)
我可以使用那个函数来调用 AuthTasker.cleanToken()每一秒？

Answer 1

回答您的问题:是的，您可以使用 schedule 方法每秒调用一次 AuthTasker.cleanToken() 。我推荐以下内容(包括为您导入的内容):

import scala.concurrent.duration._
import scala.concurrent.ExecutionContext
import ExecutionContext.Implicits.global

val system = akka.actor.ActorSystem("system")
system.scheduler.schedule(0 seconds, 1 seconds)(AuthTasker.cleanTokens)

注意:此更新后的代码每 1 秒调用一次调度方法，而不是每 0 秒调用一次。我在回顾代码时发现了这个错误。