C++多线程编程示例：生产者与消费者模型的实现 |21xrx.com

C++多线程编程示例：生产者与消费者模型的实现

2023-07-04 22:21:30 深夜i -- --

C++ 多线程编程生产者消费者模型实现

C++是一种广泛使用的编程语言，支持多线程编程。多线程编程是一种利用计算机多核处理器的技术，可以提高程序的运行效率和性能。本文将介绍使用C++实现生产者与消费者模型的多线程编程示例。

生产者与消费者模型是一种常见的并发设计模式，用于解决多个线程之间的数据交换问题。其中，生产者线程负责生成数据，并将数据存放到共享数据缓冲区中，消费者线程负责从缓冲区中取出数据进行处理。生产者线程和消费者线程之间需要进行同步和互斥操作，以保证数据的正确性。

以下是一个C++实现生产者与消费者模型的多线程编程示例：


#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <queue>
std::mutex g_mutex;               // 全局互斥量
std::condition_variable g_cond;         // 全局条件变量
std::queue<int> g_buffer;            // 全局缓冲区
void product()                 // 生产者线程函数
{
  for(int i = 0; i < 10; i++)
  {
    std::unique_lock<std::mutex> lock(g_mutex);    // 上互斥锁
    g_buffer.push(i);                  // 将数据放入缓冲区
    std::cout << "Producer: " << i << std::endl;
    lock.unlock();                   // 解互斥锁
    g_cond.notify_one();                // 唤醒一个等待线程
  }
}
void consume()                 // 消费者线程函数
{
  for(int i = 0; i < 10; i++)
  {
    std::unique_lock<std::mutex> lock(g_mutex);    // 上互斥锁
    while(g_buffer.empty())              // 如果缓冲区为空
      g_cond.wait(lock);               // 等待唤醒
    int data = g_buffer.front();            // 取出队首元素
    g_buffer.pop();                   // 将元素弹出
    std::cout << "Consumer: " << data << std::endl;
    lock.unlock();                   // 解互斥锁
  }
}
int main()
{
  std::thread producer(product);           // 创建一个生产者线程
  std::thread consumer(consume);           // 创建一个消费者线程
  producer.join();                  // 等待生产者线程结束
  consumer.join();                  // 等待消费者线程结束
  return 0;
}

在上述示例中，我们定义了全局互斥量`g_mutex`、全局条件变量`g_cond`、全局缓冲区`g_buffer`，并实现了生产者和消费者线程的功能。生产者线程调用`g_buffer.push()`函数向缓冲区中添加数据；消费者线程使用`g_buffer.front()`函数取出队列首部元素，使用`g_buffer.pop()`从缓冲区中弹出元素并进行处理。

在C++中，多线程编程需要使用`std::thread`类和互斥量`std::mutex`、条件变量`std::condition_variable`进行线程同步。在上述示例中，通过使用互斥锁和条件变量，实现了线程之间的同步和互斥操作。在生产者线程中向缓冲区插入数据后，使用`g_cond.notify_one()`函数唤醒一个等待线程；在消费者线程中，使用`g_cond.wait(lock)`函数等待信号唤醒，当缓冲区为空时，则一直等待唤醒。

综上所述，我们实现了生产者与消费者模型的多线程编程示例。C++提供了丰富的多线程编程支持，开发人员可以按照需求和实际场景进行灵活应用，提高程序的运行效率和性能。

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

下一篇: C++中的常量和变量：了解它们的区别和用法

评论区

()

相似文章