C++ 生产者消费者模型实现：原理、代码与应用

2026-03-17 18:10:02 1643阅读

在多线程编程中，生产者消费者模型是一种经典的并发设计模式，它用于解决生产者和消费者之间的数据共享和同步问题。生产者负责生成数据，而消费者则负责处理这些数据。这种模型在许多实际场景中都有广泛应用，如任务调度、数据处理等。本文将详细介绍 C++ 中生产者消费者模型的实现。

生产者消费者模型的原理

生产者消费者模型基于一个共享的缓冲区，生产者线程将数据放入缓冲区，而消费者线程从缓冲区中取出数据进行处理。为了避免数据竞争和不一致的问题，需要使用同步机制来确保线程安全。常见的同步机制包括互斥锁（mutex）和条件变量（condition variable）。

互斥锁用于保护共享资源，确保同一时间只有一个线程可以访问缓冲区。条件变量则用于线程间的通信，当缓冲区为空时，消费者线程会等待；当缓冲区有数据时，生产者线程会通知消费者线程。

C++ 实现生产者消费者模型

代码示例

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

// 定义共享缓冲区
std::queue<int> buffer;
// 互斥锁用于保护缓冲区
std::mutex mtx;
// 条件变量用于线程间通信
std::condition_variable not_full;
std::condition_variable not_empty;
// 缓冲区最大容量
const int MAX_SIZE = 5;

// 生产者线程函数
void producer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        // 等待缓冲区有空间
        not_full.wait(lock, [] { return buffer.size() < MAX_SIZE; });
        // 生产数据
        buffer.push(i);
        std::cout << "Produced: " << i << std::endl;
        // 通知消费者缓冲区有数据
        not_empty.notify_one();
        // 释放锁
        lock.unlock();
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }
}

// 消费者线程函数
void consumer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        // 等待缓冲区有数据
        not_empty.wait(lock, [] { return !buffer.empty(); });
        // 消费数据
        int item = buffer.front();
        buffer.pop();
        std::cout << "Consumed: " << item << std::endl;
        // 通知生产者缓冲区有空间
        not_full.notify_one();
        // 释放锁
        lock.unlock();
        std::this_thread::sleep_for(std::chrono::milliseconds(200));
    }
}

int main() {
    // 创建生产者和消费者线程
    std::thread producer_thread(producer);
    std::thread consumer_thread(consumer);

    // 等待线程结束
    producer_thread.join();
    consumer_thread.join();

    return 0;
}

代码解释

共享缓冲区：使用 std::queue<int> 作为共享缓冲区，用于存储生产者生产的数据。
互斥锁：std::mutex 用于保护缓冲区，确保同一时间只有一个线程可以访问。
条件变量：std::condition_variable 用于线程间的通信，not_full 用于通知生产者缓冲区有空间，not_empty 用于通知消费者缓冲区有数据。
生产者线程：在 producer 函数中，首先获取互斥锁，然后检查缓冲区是否有空间。如果缓冲区已满，则等待 not_full 条件变量。当缓冲区有空间时，生产数据并通知消费者。
消费者线程：在 consumer 函数中，首先获取互斥锁，然后检查缓冲区是否有数据。如果缓冲区为空，则等待 not_empty 条件变量。当缓冲区有数据时，消费数据并通知生产者。
主线程：创建生产者和消费者线程，并等待它们结束。