c++ - condition_variable的目的

没有std::condition_variable的应用程序:

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <queue>
#include <chrono>

std::mutex mutex;
std::queue<int> queue;
int counter;

void loadData()
{
    while(true)
    {
        std::unique_lock<std::mutex> lock(mutex);
        queue.push(++counter);
        lock.unlock();
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

void writeData()
{
    while(true)
    {
        std::lock_guard<std::mutex> lock(mutex);
        while(queue.size() > 0)
        {
            std::cout << queue.front() << std::endl;
            queue.pop();
        }
    }
}

int main()
{
    std::thread thread1(loadData);
    std::thread thread2(writeData);
    thread1.join();
    thread2.join();
    return 0;
}

具有std::condition_variable的应用程序:

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <queue>
#include <chrono>

std::mutex mutex;
std::queue<int> queue;
std::condition_variable condition_variable;
int counter;

void loadData()
{
    while(true)
    {
        std::unique_lock<std::mutex> lock(mutex);
        queue.push(++counter);
        lock.unlock();
        condition_variable.notify_one();
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }
}

void writeData()
{
    while(true)
    {
        std::unique_lock<std::mutex> lock(mutex);
        condition_variable.wait(lock, [](){return !queue.empty();});
        std::cout << queue.front() << std::endl;
        queue.pop();
    }
}

int main()
{
    std::thread thread1(loadData);
    std::thread thread2(writeData);
    thread1.join();
    thread2.join();
    return 0;
}

如果我是对的，那么这意味着该应用程序的第二个版本不安全，原因是使用queue.empty()函数，该函数在没有任何同步的情况下使用，因此没有锁。我的问题是:如果condition_variables引起了前面提到的问题，我们应该使用它们吗？

最佳答案

您的第一个示例忙于等待-线程在锁上跳动，检查然后释放锁。当不进行任何处理时，这既增加了互斥锁的争用，又浪费了整个CPU。

第二个示例使等待线程大部分处于睡眠状态。它仅在有数据就绪或“虚假唤醒”(在标准允许的情况下)时唤醒。

唤醒后，它将重新获取互斥量并检查谓词。如果谓词失败，它将释放锁并再次等待条件变量。

这是安全的，因为保证谓词可以在您获取并传递给wait函数的互斥锁中运行。