scala - 在一定时间内运行一个akka类

Question

我正在使用 Scala 中的 akka.io。我需要运行一些演员的课程，以便在一段时间后“持续”运行，比如说每 2 分钟。

akka 中有没有特殊的方法可以做到这一点？

Answer 1

您可以在 Actor 类中使用 Akka Scheduler 接口，如下所示：

//Use the system's dispatcher as ExecutionContext
import system.dispatcher

//Schedules to send the "foo"-message to the someActor after 2 minutes
system.scheduler.scheduleOnce(120 seconds, testActor, "foo")

你可以在这里找到 Akka 文档。