scala – 模拟时间和Akka调度程序

Sometimes the need for making things happen in the future arises,and
where do you go look then? Look no further than ActorSystem! There you
find the scheduler method that returns an instance of
akka.actor.Scheduler,this instance is unique per ActorSystem and is
used internally for scheduling things to happen at specific points
in time.

但是,您总是可以使用递归函数完成相同的操作.假设您的“实时”功能类似于：

def periodicFunction() : Unit = ???  //whatever you're doing to Agents

//periodicFunction is called every 10 seconds
actorSystem.scheduler().schedule(0 seconds,10 seconds)(periodicFunction())

您的模拟代码可能只是：

@scala.annotation.tailrec
def fasterThanRealTimeLoop(n : Int) = 
  if(n > 0) {
    periodicFunction()

    fasterThanRealTimeLoop(n-1)
  }

然后你可以模拟20次运行

fasterThanRealTimeLoop(20)

可以进一步包装此功能以封装两种可能性：

val realtimeMode : Boolean = ??? //some configuration setting

val periodicArgs : Either[FiniteDuration,Int] = 
  if(realtimeMode) Left(10 Seconds) else Right(20)

periodicArgs.left.foreach { period => 
  actorSystem.scheduler().schedule(0 seconds,period)(periodicFunction())
}

periodicArgs.right.foreach { count => 
  fasterThanRealTimeLoop(count)
}

此代码现在将根据配置设置调用正确类型的循环(定时或尽可能快).