多线程应用程序中的日志队列

Question

void LogCoroutine::runLogic()
{
    mBackgroundWorker = std::thread(&LogCoroutine::logic, this);
    mBackgroundWorker.detach();
}

void LogCoroutine::logic()
{
    while (true)
    {
        _serverLogic();
        _senderLogic();

        std::this_thread::sleep_for(std::chrono::milliseconds(10)); // 10ms
    }
}

void LogCoroutine::_senderLogic()
{
    std::lock_guard<std::mutex> lock(mMutex);    

    while (!mMessages.empty() && !mClients.empty())
    {
        std::string nextMessage = mMessages.front();
        mMessages.pop_front();

        _sendMessage(nextMessage);
    }
}

void LogCoroutine::pushMessage(const std::string& message)
{
    std::lock_guard<std::mutex> lock(mMutex);
    mMessages.push_back(message);
}

那么，这种架构的瓶颈在哪里？也许推送每条带有互斥体的消息是个坏主意？

Answer 1

您的方法基本上是以一定间隔（10 ms）轮询日志事件。这种方法（实际上是忙于等待）的性能不是很好，因为即使没有任何日志消息，您也总是消耗一些CPU。另一方面，如果新消息到达，您不会通知等待的线程。

我建议使用某种阻塞队列来解决这两个问题。内部阻塞队列有互斥体和条件变量，这样使用者线程就在等待（而不是忙循环！）而队列为空。我认为您的用例对于阻塞队列来说是非常理想的。您可以真正轻松地基于互斥+条件变量实现自己的队列。

用互斥体推送每个消息不是一个坏主意，无论如何你都要同步它。我只是提议取消投票。