memory - scala邮箱大小限制

Question

我可以在 Scala 中设置演员邮箱的最大大小吗？

以生产者-消费者问题为例。使用线程，当缓冲区填满时，我可以阻止生产者。我看到了几个用 Scala 编写的生产者-消费者示例，它们都使用带有邮箱作为“缓冲区”的参与者。我可以设置邮箱大小以使生产者等待消费者准备好吗？还有其他优雅的解决方案来避免邮箱无法控制的增长吗？

Answer 1

您可以创建一个参与者，充当生产者和消费者之间的缓冲区。缓冲区将其邮箱签出到其循环数据。当缓冲的产品数量过多时，它会向生产者发送“过载”消息；并在一切恢复正常后发送“明确”消息。如果消息太多，它只会丢弃传入的消息（或最旧的消息）。

消费者主动从缓冲区请求产品，而缓冲区又发回一件产品。如果缓冲区为空，则消费者继续等待输入。

生产者将产品发送到缓冲区参与者。如果它收到“过载”消息，它可以停止生产，或者可以继续生产，因为它知道产品可能会被丢弃。

当然，这个逻辑可以直接实现到生产者或消费者本身，但单独的缓冲区将允许您更轻松地引入多个生产者和/或消费者。

Answer 2

该Actor.mailboxSize方法返回 Actor 邮箱中未决消息的数量。

这可以用于以各种方式限制生产者。

例如，一种可能是，

生产者检查消费者mailboxSize是否大于某个阈值。如果是，那么它会向SpecialMessage消费者发送一个，并阻塞一个信号量。当消费者收到此信号时，SpecialMessage它会释放信号量。生产商现在可以愉快地继续其业务。

这避免了轮询以及任何丢弃的消息。