2

使用 Akka 1.3 时，我是否需要担心当生成消息的参与者的生成速度超过使用它们的参与者的处理速度时会发生什么？

如果没有任何机制，在长时间运行的过程中，队列大小会增长到消耗所有可用内存。

文档说默认调度程序是 ExecutorBasedEventDrivenDispatcher。

这个调度器有五个队列配置：

  • 有界 LinkedBlockingQueue
  • 无界 LinkedBlockingQueue
  • 有界数组阻塞队列
  • 无界数组阻塞队列
  • 同步队列

和四个过载策略：

  • 来电者运行
  • 中止
  • 丢弃
  • 最老的

这是正确的机制吗？如果是这样，这个调度程序的默认设置是什么？

4

1 回答 1

0

调度程序有一个任务队列。这与你的问题无关。实际上，您希望将尽可能多的邮箱排入队列。

您可能正在寻找的是：http ://doc.akka.io/docs/akka/1.3.1/scala/dispatchers.html#Making_the_Actor_mailbox_bounded

于 2012-10-02T18:46:16.040 回答