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

C++如何实现生产者消费者模型_C++ 生产者消费者实现方法

穿越時空

发布： 2025-10-07 13:21:02

原创

515人浏览过

生产者消费者模型通过互斥锁和条件变量协调线程，使用固定大小缓冲区实现数据的安全生产和消费，核心是利用条件变量等待非满非空状态并通知唤醒线程。

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

生产者消费者模型是多线程编程中的经典问题，用于解决生产数据和消费数据的速度不匹配问题。在C++中，通常使用互斥锁（std::mutex）、条件变量（std::condition_variable）以及一个共享缓冲区来实现。下面介绍一种基于标准库的简洁实现方式。

基本组件说明

要实现生产者消费者模型，需要以下几个核心组件：

缓冲区：通常是一个队列（std::queue），用于存放生产者生成的数据。
互斥锁（std::mutex）：保护共享缓冲区，防止多个线程同时访问导致数据竞争。
条件变量（std::condition_variable）：用于线程间通信，当缓冲区为空时让消费者等待，当缓冲区满时让生产者等待（如果是有界缓冲区）。
生产者线程：向缓冲区添加数据。
消费者线程：从缓冲区取出数据处理。

代码实现示例

以下是一个简单的C++实现，使用固定大小的缓冲区和多线程模拟生产者与消费者行为：

#include <iostream>
#include <thread>
#include <queue>
#include <mutex>
#include <condition_variable>
#include <chrono>

const int BUFFER_SIZE = 5;
std::queue<int> buffer;
std::mutex mtx;
std::condition_variable not_full;
std::condition_variable not_empty;

void producer(int id) {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        not_full.wait(lock, []() { return buffer.size() < BUFFER_SIZE; });

        buffer.push(i);
        std::cout << "生产者 " << id << " 生产了: " << i << std::endl;

        lock.unlock();
        not_empty.notify_all();
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }
}

void consumer(int id) {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        not_empty.wait(lock, []() { return !buffer.empty(); });

        int value = buffer.front();
        buffer.pop();
        std::cout << "消费者 " << id << " 消费了: " << value << std::endl;

        lock.unlock();
        not_full.notify_all();
        std::this_thread::sleep_for(std::chrono::milliseconds(150));
    }
}

登录后复制

主函数中创建多个生产者和消费者线程：

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

歌者PPT

歌者PPT，AI 写 PPT 永久免费

197

查看详情

int main() {
    std::thread p1(producer, 1);
    std::thread p2(producer, 2);
    std::thread c1(consumer, 1);
    std::thread c2(consumer, 2);

    p1.join();
    p2.join();
    c1.join();
    c2.join();

    return 0;
}

登录后复制