生产者/消费者-使用高CPU的生产者

Question

我有一个消费者作为生产者消费者模式的一部分：

简化：

public class MessageFileLogger : ILogger
{
    private BlockingCollection<ILogItem> _messageQueue;
    private Thread _worker;
    private bool _enabled = false;
    public MessageFileLogger()
    {
         _worker = new Thread(LogMessage);
         _worker.IsBackground = true;
         _worker.Start();
    }

    private void LogMessage()
    {
        while (_enabled)
        {
            if (_messageQueue.Count > 0)
            {

                itm = _messageQueue.Take();
                processItem(itm);
            }
            else
            {
                Thread.Sleep(1000);
            }
        }
    }
}

如果我移除

Thread.Sleep(1000);

通过将线程设置为睡眠，CPU使用率攀升到极高的水平（13%），而不是0%。

此外，如果我实例化该类的多个实例，则每个实例的CPU使用率都会以13%的增量攀升。

大约每分钟（可能每30秒）都会向BlockingCollection添加一个新的LogItem，并将适用的消息写入文件。

有没有可能线程以某种方式阻止了其他线程的运行，而系统以某种方式需要进行补偿？

更新：更新代码以更好地反映实际代码

Answer 1

您让线程代码运行，因此默认情况下，它在单个逻辑核心上尽可能快地运行该代码（while循环）。由于这大约是13%，我想您的CPU有4个超线程内核，从而产生8个逻辑内核。每个线程在其核心上以尽可能快的速度运行它的while循环，导致另外13%的使用率。真的很简单。

不使用睡眠的副作用是整个系统运行更慢，并且使用/产生明显更多的电池/热量。

一般来说，正确的方法是给_messageQueue另一个方法，比如

bool BlockingCollection::TryTake(type& item, std::chrono::milliseconds time)
{
    DWORD Ret = WaitForSingleObject(event, time.count());
    if (Ret)
        return false;
    item = Take(); //might need to use a shared function instead of calling direct
    return true;
}

那么你的循环就很简单了：

private void LogMessage()
{
    type item;
    while (_enabled)
    {
        if (_messageQueue.Take(item, std::chrono::seconds(1)))
            ;//your origional code makes little sense, but this is roughly the same                
        processItem(itm);
    }
}

这也意味着，如果在阻塞部分的任何一点添加了一个项目，它会立即被执行，而不是一秒钟后。