如何在满足条件之前阻止操作

本文关键字:操作 条件 满足 | 更新日期: 2023-09-27 18:36:40

我正在运行这段代码,它使用了相当数量的CPU,即使它大部分时间什么都不做。

while (this.IsListening)
{
    while (this.RecievedMessageBuffer.Count > 0)
    {
        lock (this.RecievedMessageBuffer)
        {
            this.RecievedMessageBuffer[0].Reconstruct();
            this.RecievedMessageBuffer[0].HandleMessage(messageHandler);
            this.RecievedMessageBuffer.RemoveAt(0);
        }
    }
}

满足条件之前阻止的最佳方法是什么?

如何在满足条件之前阻止操作

使用WaitHandle

WaitHandle waitHandle = new AutoResetEvent();
// In your thread.
waitHandle.WaitOne();
// In another thread signal that the condition is met.
waitHandle.Set();

您还可以考虑更改类的接口,以便在有新数据要读取时引发事件。然后,可以将代码放在事件处理程序中。

假设你使用的是.NET 4,我建议RecievedMessageBuffer切换为BlockingCollection。 当您将消息放入其中时,请调用它的 Add 方法。 如果要检索消息,请调用它 Take 或 TryTake 方法。 Take 将阻止读取线程,直到消息可用,而不会像原始示例那样刻录 CPU。

// Somewhere else
BlockingCollection<SomethingLikeAMessage> RecievedMessageBuffer = new BlockingCollection<SomethingLikeAMessage>();

// Something like this where your example was
while (this.IsListening)
{
    SomethingLikeAMessage message;
    if (RecievedMessageBuffer.TryTake(out message, 5000);
    {
        message.Reconstruct();
        message.HandleMessage(messageHandler);
    }
}

上面的代码行,特别是AutoResetEvent在3.5版本中可用。因此,像上面这样简单的代码经过一些小的更正是非常有效的,因为它可以工作并且接近基础API。更正应为

自动重置事件等待句柄 = 新的自动重置事件(假);带有参数 false 的构造函数使 WaitOne() 等待,因为 AutoResetEven 未重置 (false)。使用接口 WaitHandle 没有太大优势,所以我只会使用 AutoResetEvent,因为它公开了方法 Set,在这种情况下,WaitOne 非常冗长。最重要的是,构造函数参数应该是假的。