C++如何实现简单的生产者消费者(多生产者模型)-C++-PHP中文网

根本原因是未对共享队列做线程安全保护，多个生产者并发调用push()导致数据丢失或队列损坏；必须用互斥量保护所有队列操作（push/pop/empty/size），配合condition_variable使用notify_one()和带谓词的wait()避免假唤醒与性能损耗。

c++如何实现简单的生产者消费者(多生产者模型)

根本原因是没对共享队列做线程安全保护。多个 std::thread 同时调用 push()，可能同时修改队尾指针或内部缓冲区，导致数据丢失、越界或 std::queue 内部状态损坏。哪怕只读的 size() 在未加锁时也可能返回脏值。

必须用互斥量保护所有队列操作：构造/析构不算，但 push()、pop()、empty()、size() 全都要套在 std::lock_guard<:mutex></:mutex> 里。别信“只读不用锁”——std::queue 不是线程安全容器。

不需要额外逻辑，“公平”由互斥量天然保证。只要每个生产者线程都走相同的临界区路径：lock → push → unlock → notify_one，操作系统调度器会决定谁先抢到锁，没有优先级偏移。

关键陷阱是误用 notify_all()：它会让所有等待的消费者线程一起唤醒，但只有一个能真正取走数据，其余线程发现队列又空了，只能再次等待——徒增上下文切换开销。除非你明确需要广播语义（比如终止信号），否则一律用 notify_one()。

根据原题生成新题面、验证器及完整测试数据，自动套用 testlib 模板，用于用户要求生成测试数据时。

下载

生产者代码模板固定：

std::unique_lock<:mutex> lock(mtx);
queue.push(data);
cond_var.notify_one();</:mutex>

别在 push() 前加 if (!queue.full()) —— std::queue 没有 full()，且容量检查和插入不是原子操作，必须锁内判断
如果生产者需限速，用 std::this_thread::sleep_for 放在锁外，而不是在锁里 delay

用 cond_var.wait(lock, [&]{ return !queue.empty(); }); 这种带谓词的重载。它自动处理假唤醒：每次被唤醒后重新检查 lambda 返回值，为 false 就继续等待，无需手写 while 循环加 empty() 判断。

注意这个 lambda 必须捕获 &，且里面访问的 queue 和 mtx 必须是同一作用域下的变量，否则编译失败或运行时 UB。

不要写 cond_var.wait(lock); 然后自己 if (queue.empty()) continue; —— 这漏掉了唤醒后队列仍为空的情况
消费者取数后立刻 unlock() 再处理数据，别把业务逻辑（比如打印、计算）锁在临界区内
若消费者要退出，需发一个特殊哨兵值（如 -1）并确保所有生产者已结束，否则可能死等

大概率是死锁或资源泄漏。典型组合：生产者锁着 mtx 时调用 cond_var.wait()，但忘了 wait() 会自动释放锁；或者消费者在 wait() 返回前被异常中断，导致 std::unique_lock 析构时尝试重复解锁。

用 RAII 是底线：所有锁必须由 std::unique_lock 或 std::lock_guard 管理，绝不用 mtx.lock()/mtx.unlock() 手动配对。C++11 起，裸 lock() 几乎没有正当理由。

检查所有 std::thread 是否都调用了 join() 或 detach() —— 忘掉 join() 会导致主线程结束时强制调用 std::terminate()
若用 std::shared_ptr 管理队列或条件变量，确认生命周期覆盖所有线程，尤其注意生产者线程是否引用了已销毁的对象
调试时加 std::cout ，但记得用 <code>std::lock_guard 包住，否则输出乱序掩盖真实问题

实际最难的部分不是写对那十几行核心逻辑，而是让所有线程的生命周期、资源归属、退出顺序严丝合缝。稍有松动，就会在高并发下暴露竞态——而这往往不会立刻报错，只会让程序偶尔卡住、偶尔丢数据、偶尔 segfault。