如何阻止操作直到满足条件？

Question

我正在运行此代码,它使用了相当数量的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);
        }
    }
}

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

Answer 1

用一个WaitHandle.

WaitHandle waitHandle = new AutoResetEvent();

// In your thread.
waitHandle.WaitOne();

// In another thread signal that the condition is met.
waitHandle.Set();

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

Answer 2

假设您使用的是.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);
    }
}