c++中如何实现生产者消费者模型_c++生产者消费者模型实现方法-C++-PHP中文网

c++中如何实现生产者消费者模型_c++生产者消费者模型实现方法

裘德小鎮的故事

发布： 2025-10-11 21:27:01

原创

700人浏览过

答案：C++中生产者消费者模型通过std::mutex和std::condition_variable实现线程同步，使用队列作为共享缓冲区，生产者添加数据后通知消费者，消费者等待数据就绪，避免竞争条件；可通过条件变量控制缓冲区满或空的状态，或在C++20中使用std::counting_semaphore简化同步逻辑。

c++中如何实现生产者消费者模型_c++生产者消费者模型实现方法

在C++中实现生产者消费者模型，核心是让多个线程安全地共享一个缓冲区：生产者往里放数据，消费者从中取数据。关键在于解决线程间的同步与互斥问题，避免竞争条件和资源冲突。

使用std::queue + std::mutex + std::condition_variable

这是现代C++中最推荐的方式，利用标准库提供的工具实现高效同步。

基本思路： 用一个队列作为共享缓冲区，互斥锁（mutex）保护对队列的访问，条件变量（condition variable）用于阻塞和唤醒线程。

生产者线程在添加数据前获取锁，添加后通知消费者
消费者线程在队列为空时等待条件变量，收到通知后再尝试取数据
通过条件变量避免忙等待，提高效率

示例代码：

立即学习“C++免费学习笔记（深入）”；

#include <iostream>
#include <thread>
#include <queue>
#include <mutex>
#include <condition_variable>
<p>std::queue<int> buffer;
std::mutex mtx;
std::condition_variable cv;
bool finished = false;
const int max_items = 10;</p><p>void producer(int id) {
for (int i = 0; i < max_items; ++i) {
std::this_thread::sleep_for(std::chrono::milliseconds(100));
std::unique_lock<std::mutex> lock(mtx);
buffer.push(i);
std::cout << "Producer " << id << " produced: " << i << "\n";
lock.unlock();
cv.notify_one();
}
}</p><p>void consumer(int id) {
while (true) {
std::unique_lock<std::mutex> lock(mtx);
cv.wait(lock, []{ return !buffer.empty() || finished; });
if (!buffer.empty()) {
int value = buffer.front();
buffer.pop();
std::cout << "Consumer " << id << " consumed: " << value << "\n";
if (value == max_items - 1) {
finished = true;
cv.notify_all();
}
} else if (finished) {
break;
}
lock.unlock();
}
}</p>

登录后复制

限制缓冲区大小的改进版本

真实场景中缓冲区通常有容量限制，需同时判断“是否满”和“是否空”。

生产者在缓冲区满时等待
消费者在缓冲区空时等待
两个条件可用同一个条件变量或两个分别控制

修改点：

歌者PPT

歌者PPT，AI 写 PPT 永久免费

197

查看详情

const int capacity = 5;
// 生产者中增加判断：
cv.wait(lock, []{ return buffer.size() < capacity; });
// 消费者中判断非空：
cv.wait(lock, []{ return buffer.size() > 0; });

登录后复制

使用信号量模拟（C++20前需自定义）

C++标准库没有原生信号量，但可以用condition_variable模拟。

或者在支持C++20的环境中使用std::counting_semaphore，更简洁。

#include <semaphore>
std::counting_semaphore<10> sem_fill(0);   // 已填充槽位
std::counting_semaphore<10> sem_empty(10); // 空槽位
<p>// 生产者：
sem_empty.acquire(); // 占用一个空位
buffer.push(data);
sem_fill.release();  // 增加一个填充位</p><p>// 消费者：
sem_fill.acquire();  // 等待有数据
data = buffer.pop();
sem_empty.release(); // 释放一个空位</p>

登录后复制