c++中如何实现生产者消费者模型_c++多线程条件变量同步

std::mutex 无法实现线程等待条件成立，需配合 std::condition_variable 和 std::unique_lock 使用；后者支持自动释放/重获锁，必须用谓词循环检测防止虚假唤醒。

为什么直接用 std::mutex 不够用

只靠 std::mutex 无法让线程“等某个条件成立”，比如“队列非空”或“队列未满”。你可能会写成忙等待：

while (queue.empty()) { std::this_thread::yield(); }

，这浪费 CPU，且可能因调度延迟导致响应滞后。真正需要的是：线程挂起，直到被明确通知条件满足。

std::condition_variable 必须和 std::unique_lock<:mutex> 配合使用

这是最容易出错的点——std::condition_variable::wait() 要求传入的锁必须是 std::unique_lock（不能是 std::loc

k_guard），因为 wait() 内部会先释放锁、挂起线程，唤醒后再重新加锁。若用错锁类型，编译直接报错。

典型写法：

std::unique_lock lock(mtx);
cond_var.wait(lock, [&] { return !queue.empty(); }); // 唤醒后自动重加锁

• lambda 中的判断必须是“实际检查条件”，不能只写 queue.empty() 后取反，否则虚假唤醒会导致逻辑错误
• 不要在 wait() 外手动 lock.unlock()，它会破坏原子性
• notify_one() 和 notify_all() 不需要持有锁，但通常建议在持有锁的上下文中调用，确保通知与状态更新的可见性

生产者和消费者都要处理虚假唤醒

即使没人调用 notify_*，wait() 也可能返回（POSIX 和 C++ 标准允许）。所以永远要用带谓词的 wait()，或者手动循环检查：

std::unique_lock lock(mtx);
while (queue.empty()) {
    cond_var.wait(lock);
}
// 此时 queue 仍可能为空，必须再检查

更安全、更简洁的写法就是用谓词版本：cond_var.wait(lock, [&]{ return !queue.empty(); });，它内部已帮你做了循环。

• 生产者端同样要检查“是否已满”：cond_var.wait(lock, [&]{ return queue.size()
• 注意：queue.size() 在多线程下不是原子操作，必须在锁保护下读取

别忘了在析构前停止线程并清理资源

如果生产者/消费者线程还在运行，而容器（如 std::queue）已被析构，就会触发未定义行为。常见做法是引入一个 std::atomic done{false} 控制循环，并在退出前调用 cond_var.notify_all() 唤醒所有等待线程。

例如消费者循环结构：

while (!done.load()) {
    std::unique_lock lock(mtx);
    cond_var.wait(lock, [&]{ return !queue.empty() || done.load(); });
    if (done.load() && queue.empty()) break;
    auto item = std::move(queue.front());
    queue.pop();
    lock.unlock();
    process(item);
}

这里 done.load() 参与了 wait 谓词，确保能及时响应退出信号；同时唤醒后再次检查 done，避免漏掉终止指令。

虚假唤醒、锁类型误用、谓词缺失、析构竞态——这四点覆盖了 90% 的实际 crash 和死锁场景。