我正在使用 Akka 构建多智能体模拟，因此希望以比实时更快的速度运行模拟。具体来说，我想配置 Akka 调度程序，以便调度程序从一个调度事件推进到下一个调度事件，而不是按某个底层固定时间步长推进（这显然可能涉及事件之间的显着不同的时间步长）。
稍微不同的是，我希望调度程序表现得好像它是一种优先级队列，其中优先级由事件的模拟时间戳给出。
这清楚吗？如果是这样，我想使用 Actor 系统的默认调度程序来实现吗？如果这是不可能的，那么我将如何使用现有的 Akka 组件来滚动我自己的调度程序来完成这项任务。
【问题讨论】：
我认为这对于 akka 调度程序是不可能的。来自documentation（强调我的）：
有时需要让事情在未来发生，并且 那你去哪里看？没有比 ActorSystem 更进一步的了！你在那里 找到返回实例的调度程序方法 akka.actor.Scheduler，这个实例对于每个 ActorSystem 都是唯一的，并且是 在内部用于安排在特定时间发生的事情 及时。
但是，您始终可以使用递归函数完成相同的任务。假设您的“实时”功能如下所示：
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)
}
此代码现在将根据配置设置调用正确类型的循环（定时或尽可能快）。
【讨论】：