Akka 经典中的定时行为?
Timed behaviors in Akka classic?
我正在使用 Akka classic,并且必须设置定时行为 - 在 Akka typed 中,我可以使用 Behaviors.withTimers
我如何在 Akka classic 中完成此操作?看来我们可以使用
在 Akka 中创建一个演员
public static Props props() {
return Props.create(actor.class, () -> new actor());
}
如何在这种初始化中使用计时器?
查看定时器文档:https://doc.akka.io/docs/akka/current/actors.html#timers-scheduled-messages
简而言之,混入 Timers 特性。然后你可以使用 timers
访问 API。您将收到响应计时器触发的消息。
class MyActor extends Actor with Timers {
import MyActor._
timers.startSingleTimer(TickKey, FirstTick, 500.millis)
def receive = {
case FirstTick =>
// do something useful here
timers.startTimerWithFixedDelay(TickKey, Tick, 1.second)
case Tick =>
// do something useful here
}
}
我正在使用 Akka classic,并且必须设置定时行为 - 在 Akka typed 中,我可以使用 Behaviors.withTimers
我如何在 Akka classic 中完成此操作?看来我们可以使用
public static Props props() {
return Props.create(actor.class, () -> new actor());
}
如何在这种初始化中使用计时器?
查看定时器文档:https://doc.akka.io/docs/akka/current/actors.html#timers-scheduled-messages
简而言之,混入 Timers 特性。然后你可以使用 timers
访问 API。您将收到响应计时器触发的消息。
class MyActor extends Actor with Timers {
import MyActor._
timers.startSingleTimer(TickKey, FirstTick, 500.millis)
def receive = {
case FirstTick =>
// do something useful here
timers.startTimerWithFixedDelay(TickKey, Tick, 1.second)
case Tick =>
// do something useful here
}
}