notify_one() 有时不唤醒消费者，根本原因是唤醒时机与锁配合不当，如消费者未进入等待状态或唤醒发生在加锁前；正确做法是所有操作均用同一mutex保护，wait必须用带谓词重载，且notify应在状态更新后、锁内调用。
为什么 notify_one() 有时不唤醒消费者？
根本原因不是函数写错了，而是唤醒时机和锁的配合出了问题。常见现象是生产者调用了 notify_one()，但消费者仍在 wait() 中阻塞——这通常因为消费者还没来得及进入等待状态，或者唤醒发生在消费者加锁前。
正确做法是：所有对共享队列的操作（push/pop）、wait()、notify_one() 都必须在同一个 std::mutex 保护下进行，且 wait() 必须用带谓词的重载形式，避免虚假唤醒。
- 永远不要裸调
wait(lock)，必须用wait(lock, [&]{ return !queue.empty(); }) -
notify_one()可以在释放锁之后调用，但更安全的做法是「在持有锁时通知」，确保唤醒与状态变更原子可见 - 如果多个消费者线程竞争，
notify_one()只唤醒一个；需唤醒全部时改用notify_all()，但要注意惊群效应
如何避免死锁和数据竞争？
典型死锁场景：消费者在 wait() 前已持锁，而生产者也在同一把锁下卡住；或两个线程分别按不同顺序获取 mutex 和其他资源。
核心原则：只用一把 std::mutex 保护队列本身，不把它用于其他无关逻辑。所有访问 queue 的路径（包括判空、pop、push）都必须先 lock，操作完再 unlock —— wait() 会自动释放并重获该锁，无需手动干预。
立即学习“C++免费学习笔记（深入）”；
- 不要在
wait()的谓词里修改共享状态（比如调用queue.pop()），谓词只做判断 - pop 操作必须在谓词为 true 后、且仍在锁保护下执行
- 若队列类型是
std::queue<int>，注意它没有线程安全的front()+pop()原子组合，必须拆成两步并保证中间不被抢占
std::condition_variable 必须和 std::unique_lock<std::mutex> 配合吗？
是的，std::condition_variable::wait() 只接受 std::unique_lock<std::mutex>，不能传 std::lock_guard 或裸指针。这是设计使然：wait 需要能临时释放锁、挂起线程、并在唤醒后重新加锁，只有 unique_lock 支持这种可转移、可手动 unlock/lock 的行为。
-
std::lock_guard构造即加锁、析构即释放，无法满足 wait 的“释放→等待→重锁”流程 - 别试图用
std::shared_lock或自定义锁类型替代，编译会直接报错 - 可以提前
lock.unlock()再调wait()，但没必要；wait()内部会自动处理
一个最小可运行的双线程版本长什么样？
下面这段代码去掉异常处理和日志，仅保留最核心的同步逻辑，可直接编译运行（C++11 起支持）：
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <iostream>
std::queue<int> queue;
std::mutex mtx;
std::condition_variable cv;
void producer() {
for (int i = 0; i < 5; ++i) {
std::unique_lock<std::mutex> lock(mtx);
queue.push(i);
std::cout << "Produced: " << i << "\n";
lock.unlock(); // 显式释放，让 notify 更早发生（非必须）
cv.notify_one(); // 在锁外也可，但需确保 queue 状态已更新
}
}
void consumer() {
for (int i = 0; i < 5; ++i) {
std::unique_lock<std::mutex> lock(mtx);
cv.wait(lock, []{ return !queue.empty(); }); // 谓词确保真实就绪
int val = queue.front();
queue.pop();
std::cout << "Consumed: " << val << "\n";
}
}
int main() {
std::thread t1(producer);
std::thread t2(consumer);
t1.join(); t2.join();
}
注意：实际项目中应使用 std::queue<std::shared_ptr<T>> 或移动语义避免拷贝；若需多生产者/多消费者，notify_one() 要换成 notify_all()，且消费者谓词要检查是否真有数据可取，而非仅依赖通知信号。
