有一整套 Actor 模型框架专注于最大限度地提高程序定义的吞吐量……呃……动作(或者我应该说动作)。
哪些实现允许我限制吞吐量,即保证某个 Actor 每分钟执行次数不超过 N 次?另一个要求是必须“尽快”执行该操作,直到不超过阈值。
有一整套 Actor 模型框架专注于最大限度地提高程序定义的吞吐量……呃……动作(或者我应该说动作)。
哪些实现允许我限制吞吐量,即保证某个 Actor 每分钟执行次数不超过 N 次?另一个要求是必须“尽快”执行该操作,直到不超过阈值。
与在 Actor 模型中一样,actor 只有在邮箱中有消息要处理时才会执行,您可以使用节流机制来限制它在短时间内执行的次数。这篇博客文章展示了如何使用 Akka 完成:http: //letitcrash.com/post/28901663062/throttling-messages-in-akka-2