11

我试图了解在条件变量中使用互斥锁时会发生什么。

在以下示例中，取自cppreference

int main()
{
    std::queue<int> produced_nums;
    std::mutex m;
    std::condition_variable cond_var;
    bool done = false;
    bool notified = false;

    std::thread producer([&]() {
        for (int i = 0; i < 5; ++i) {
            std::this_thread::sleep_for(std::chrono::seconds(1));
            std::unique_lock<std::mutex> lock(m);
            std::cout << "producing " << i << '\n';
            produced_nums.push(i);
            notified = true;
            cond_var.notify_one();
        }   

        done = true;
        cond_var.notify_one();
    }); 

    std::thread consumer([&]() {
        std::unique_lock<std::mutex> lock(m);
        while (!done) {
            while (!notified) {  // loop to avoid spurious wakeups
                cond_var.wait(lock);
            }   
            while (!produced_nums.empty()) {
                std::cout << "consuming " << produced_nums.front() << '\n';
                produced_nums.pop();
            }   
            notified = false;
        }   
    }); 

    producer.join();
    consumer.join();
}

生产者线程cond_var.notify_one()在互斥锁解锁之前调用。调用 notify 时互斥锁是否m解锁，还是仅在互斥锁解锁时才出现通知？

4

3 回答 3

11

通知不会解锁互斥锁。您可以（间接地）告诉您，因为您没有notify_one()像您那样将锁传递给wait()，这确实在等待时释放了互斥锁。

另一方面，被通知的线程被“立即”通知。但他们不一定会wait()立即返回。在他们可以从那里返回之前，wait()他们必须首先重新获取互斥锁，因此他们将在那里阻塞，直到通知线程释放它。

于 2012-10-22T20:38:23.793 回答
3

锁在构造函数中被获取并在析构函数中释放std::unique_lock。从这些信息中，您可以推断生产者在调用notify_one()完成后释放了锁。

于 2012-10-24T20:14:26.350 回答
0

出于性能原因，我建议在通知其他线程之前解锁互斥锁。

于 2017-01-03T16:42:03.193 回答