C++ 生产者消费者模型详解 |21xrx.com

C++ 生产者消费者模型详解

2023-06-28 00:24:36 深夜i -- --

生产者消费者模型 C++ 多线程编程同步机制缓冲区

C++的生产者消费者模型是一种常用的多线程编程技术，通过分离数据生产和消费的过程，可以提高程序的效率和可靠性。在这篇文章中，我们将详细探讨C++中的生产者消费者模型。

一、什么是生产者消费者模型？

生产者消费者模型是一种设计模式，用于解决数据生产和消费之间的同步问题。在该模型中，生产者负责生成数据，并将其放入一个缓冲区中，而消费者则从该缓冲区中读取数据并进行相应的处理。这种模型可以提高程序的并发能力，使得多个线程可以同时进行数据的生产和消费，从而提高程序的效率。

二、C++中的生产者消费者模型

在C++中，可以使用多种方式来实现生产者消费者模型，其中最常见的方式是使用信号量和互斥量。下面我们将详细介绍如何使用这两种技术来实现生产者消费者模型。

1、使用信号量实现生产者消费者模型

在使用信号量实现生产者消费者模型时，需要定义一个计数器（即信号量），用于表示当前缓冲区中可用的数据项数目。生产者在将数据放入缓冲区时，需要将计数器加1；而消费者在从缓冲区中读取数据时，需要将计数器减1。当计数器为0时，表示缓冲区中没有可用的数据，此时消费者需要等待，直到有新的数据被生产出来。当计数器为缓冲区容量时，表示缓冲区已满，此时生产者需要等待，直到有新的空间可用。

下面是一个使用信号量实现生产者消费者模型的示例代码：


#include<semaphore.h>
#include<queue>
#include<thread>
#include<iostream>
using namespace std;
const int BUFFER_SIZE = 10;// 缓冲区大小
queue<int> buffer;// 缓冲区队列
sem_t empty;// 空闲信号量
sem_t full;// 满信号量
sem_t mutex;// 互斥信号量
void producer()
{
  int item = 0;
  while (true)
  {
    // 生产者等待空闲信号量
    sem_wait(&empty);
    // 互斥地访问缓冲区
    sem_wait(&mutex);
    // 生产一个数据项
    item++;
    buffer.push(item);
    cout << "Producer produces item " << item << endl;
    // 计数器加1
    sem_post(&mutex);
    // 释放满信号量
    sem_post(&full);
    // 休眠1000ms
    this_thread::sleep_for(chrono::milliseconds(1000));
  }
}
void consumer()
{
  while (true)
  {
    // 消费者等待满信号量
    sem_wait(&full);
    // 互斥地访问缓冲区
    sem_wait(&mutex);
    // 消费一个数据项
    int item = buffer.front();
    buffer.pop();
    cout << "Consumer consumes item " << item << endl;
    // 计数器减1
    sem_post(&mutex);
    // 释放空闲信号量
    sem_post(&empty);
    // 休眠1000ms
    this_thread::sleep_for(chrono::milliseconds(1000));
  }
}
int main()
{
  // 初始化信号量
  sem_init(&empty, 0, BUFFER_SIZE);
  sem_init(&full, 0, 0);
  sem_init(&mutex, 0, 1);
  // 创建生产者和消费者线程
  thread t1(producer);
  thread t2(consumer);
  // 等待线程结束
  t1.join();
  t2.join();
  // 销毁信号量
  sem_destroy(&empty);
  sem_destroy(&full);
  sem_destroy(&mutex);
  return 0;
}

2、使用互斥量实现生产者消费者模型

除了信号量，互斥量也是一种常见的实现生产者消费者模型的技术。在使用互斥量实现生产者消费者模型时，需要定义一个互斥量，并将其用于保护缓冲区的访问。当一个线程需要访问缓冲区时，需要先获得互斥量，以保证自己是唯一的访问者。当访问结束后，需要释放互斥量，以便其他线程可以获得访问权限。

下面是一个使用互斥量实现生产者消费者模型的示例代码：


#include<mutex>
#include<queue>
#include<thread>
#include<iostream>
using namespace std;
const int BUFFER_SIZE = 10;// 缓冲区大小
queue<int> buffer;// 缓冲区队列
mutex mtx;// 互斥量
void producer()
{
  int item = 0;
  while (true)
  {
    // 生产一个数据项
    item++;
    // 互斥地访问缓冲区
    mtx.lock();
    // 如果缓冲区已满，则等待
    while (buffer.size() == BUFFER_SIZE)
    {
      this_thread::yield();
    }
    buffer.push(item);
    cout << "Producer produces item " << item << endl;
    // 释放互斥量
    mtx.unlock();
    // 休眠1000ms
    this_thread::sleep_for(chrono::milliseconds(1000));
  }
}
void consumer()
{
  while (true)
  {
    // 互斥地访问缓冲区
    mtx.lock();
    // 如果缓冲区为空，则等待
    while (buffer.empty())
    {
      this_thread::yield();
    }
    // 消费一个数据项
    int item = buffer.front();
    buffer.pop();
    cout << "Consumer consumes item " << item << endl;
    // 释放互斥量
    mtx.unlock();
    // 休眠1000ms
    this_thread::sleep_for(chrono::milliseconds(1000));
  }
}
int main()
{
  // 创建生产者和消费者线程
  thread t1(producer);
  thread t2(consumer);
  // 等待线程结束
  t1.join();
  t2.join();
  return 0;
}

三、总结

本文介绍了C++中的生产者消费者模型，并详细介绍了如何使用信号量和互斥量来实现该模型。通过使用生产者消费者模型，可以提高程序的效率和可靠性，特别是在多线程编程中，更能够体现出其优势。对于需要处理数据生产和消费的应用程序，使用生产者消费者模型是一种非常有用的解决方案。

上一篇: idea打包java可执行jar包

下一篇: C和C++与Java相比有什么优劣之处？

评论区

()

相似文章