控制具有整数号的事件每秒发生次数不超过N次。

Question

我的系统用整数生成事件。从1到10 000件，总共约有10 000件。每次我收到numer的新事件时，我都需要检查我在最后一秒钟中已经收到过多少次这样的事件：

• 如果我在最后一秒钟里收到这个事件超过3到10次，我需要忽略它。
• 否则我需要处理它。

因此，我只需要控制和忽略“洪水”与相同数目的事件。

有两项要求：

• 防洪的开销应该是最小的，因为它在高频交易中使用。
• 同时，我不需要控制“完全”，我只是需要“大概”“防洪”。也就是说，在每秒3到10个事件之间停止接收事件是可以的。

所以我的建议是：

• 创建int10 000数组
• 每秒钟将数组中的所有项刷新为0(数组中的项的刷新操作是原子的，我们也可以在数组上进行迭代，不存在任何问题，也不需要锁定，因为我们不插入或删除项，但是可能有人可以将特殊的函数转换为“零”数组，请注意，我可以同时从另一个线程读取数组)。
• 每次收到新事件时，我们( a) Interlocked.Increment数组中的对应项，并且只有当结果小于阈值(~3)时，我们才会处理它。

因此，防洪将只是一个Intrerlocked.Increment操作和一个比较操作。

你能推荐什么更好的吗？

Answer 1

您的方法的一个问题是，如果您每秒钟清除计数器-它可能是您有洪水在第二个结束，但既然你刚刚清除它，你将继续接受新的事件。

这也许对你来说是可以的，因为你只擅长近似值。

另一种方法可能是有一系列时间戳队列。当一个新事件出现时--从数组中得到相关的队列，并从数组的头上清除过去发生的超过一秒的时间戳。

如果队列大于不执行任何操作的阈值，则检查队列的大小，否则将向队列中输入新的事件时间戳并进行处理。

我意识到，这种方法可能比只增加整数要慢，但它将更准确。

我想您可以运行一些基准测试，找出它有多慢，以及它是否适合您的需要。