当前位置：首页 > news >正文

【C++】【设计模式】生产者-消费者模型

news 来源：原创 2025/7/13 19:11:10

生产者-消费者模型（Producer-Consumer Model）是一种经典的并发编程模式，用于解决多线程或多进程环境下的数据共享和任务协作问题。以下是对该模型的详细介绍：

一、核心概念

生产者（Producer）：负责生成数据或任务，并将其放入共享缓冲区。
消费者（Consumer）：从共享缓冲区中获取数据或任务并处理。
缓冲区（Buffer）：线程安全的队列，用于临时存储数据，解耦生产者和消费者。
同步机制：确保缓冲区在多线程环境下的正确性（如互斥锁、条件变量）。

二、实现方式

1. 基于条件变量的实现

#include <iostream>
#include <queue>
#include <mutex>
#include <condition_variable>
#include <thread>template<typename T>
class BlockingQueue {
private:std::queue<T> queue_;mutable std::mutex mutex_;std::condition_variable cv_not_full_;std::condition_variable cv_not_empty_;size_t max_size_;public:explicit BlockingQueue(size_t max_size = 10) : max_size_(max_size) {}void push(const T& value) {std::unique_lock<std::mutex> lock(mutex_);cv_not_full_.wait(lock, [this]{ return queue_.size() < max_size_; });queue_.push(value);cv_not_empty_.notify_one();}T pop() {std::unique_lock<std::mutex> lock(mutex_);cv_not_empty_.wait(lock, [this]{ return !queue_.empty(); });T value = queue_.front();queue_.pop();cv_not_full_.notify_one();return value;}
};// 示例使用
void producer_consumer_example() {BlockingQueue<int> queue(5);  // 最大容量为5// 生产者线程auto producer = [&]() {for (int i = 0; i < 10; ++i) {queue.push(i);std::cout << "Produced: " << i << std::endl;std::this_thread::sleep_for(std::chrono::milliseconds(100));}};// 消费者线程auto consumer = [&]() {for (int i = 0; i < 10; ++i) {int value = queue.pop();std::cout << "Consumed: " << value << std::endl;std::this_thread::sleep_for(std::chrono::milliseconds(200));}};std::thread t1(producer);std::thread t2(consumer);t1.join();t2.join();
}

2. 基于`std::atomic`的无锁实现（简化版）

#include <atomic>
#include <array>template<typename T, size_t N>
class LockFreeQueue {
private:std::array<T, N> buffer_;std::atomic<size_t> head_ = {0};std::atomic<size_t> tail_ = {0};static size_t next(size_t idx) { return (idx + 1) % N; }public:bool push(const T& value) {size_t tail = tail_.load(std::memory_order_relaxed);size_t next_tail = next(tail);if (next_tail == head_.load(std::memory_order_acquire))return false;  // 队列已满buffer_[tail] = value;tail_.store(next_tail, std::memory_order_release);return true;}bool pop(T& value) {size_t head = head_.load(std::memory_order_relaxed);if (head == tail_.load(std::memory_order_acquire))return false;  // 队列为空value = buffer_[head];head_.store(next(head), std::memory_order_release);return true;}
};

三、关键组件详解

1. 缓冲区设计

有界缓冲区：设置最大容量，防止内存溢出。
无界缓冲区：理论上可无限扩展（如std::list），但需警惕内存耗尽。

2. 同步机制

条件变量：生产者等待缓冲区非满，消费者等待缓冲区非空。
原子操作：用于无锁队列，通过内存屏障保证可见性。

3. 线程协作

一对一：一个生产者和一个消费者。
多对一/一对多：多个生产者或消费者共享缓冲区。
多对多：最复杂的场景，需严格控制同步。

四、应用场景

任务队列：Web服务器将HTTP请求放入队列，工作线程处理请求。
数据处理流水线：如视频编码（采集→编码→渲染）。
事件驱动系统：生产者发布事件，消费者监听并响应。
内存池/对象池：预先创建对象放入队列，避免频繁分配内存。

五、常见问题与解决方案

问题	解决方案
死锁	统一加锁顺序，使用`std::lock`同时锁定多个互斥锁。
虚假唤醒	在条件变量等待时使用谓词（如`cv.wait(lock, []{ return !queue.empty(); })`）。
内存可见性	使用原子操作或同步原语确保修改对其他线程可见。
性能瓶颈	采用无锁算法（如CAS操作）或分区锁减少竞争。

六、C++标准库中的相关工具

std::condition_variable：实现线程间的等待/通知机制。
std::atomic：提供原子操作，用于无锁编程。
std::queue/std::deque：基础队列容器。
std::async/std::future：简化异步任务的管理。

七、扩展与优化

多缓冲区技术：使用多个缓冲区减少锁竞争。
批量处理：消费者一次性获取多个数据，减少同步开销。
背压机制：当缓冲区满时，生产者暂停或降低生产速度。
优先级队列：根据任务优先级处理数据。

总结

生产者-消费者模型是并发编程的基础模式，通过分离数据生产和处理逻辑，提高系统吞吐量和可维护性。合理选择缓冲区类型和同步机制是实现高效、线程安全的关键。在实际应用中，需根据场景特点（如性能需求、数据量）调整实现方式。

【C++】【设计模式】生产者-消费者模型

生产者-消费者模型（Producer-Consumer Model）是一种经典的并发编程模式，用于解决多线程或多进程环境下的数据共享和任务协作问题。以下是对该模型的详细介绍： 一、核心概念生产者（Producer）：…...

编程日记 2025/7/13 19:11:10

第五十七篇 Java接口设计之道：从咖啡机到智能家居的编程哲学

目录引言：生活中的接口无处不在一、咖啡机与基础接口：理解抽象契约1.1 咖啡制作的标准接口二、智能家居与策略模式：灵活切换实现2.1 温度调节策略场景三、物流系统与工厂模式：标准接口下的多样实现3.1 快递运输接口设计四、健…...

编程日记 2025/6/28 23:05:40

设置docker库 sudo dnf -y install dnf-plugins-core sudo dnf config-manager --add-repo https://download.docker.com/linux/centos/docker-ce.repo 安装 Docker 包 sudo dnf install docker-ce docker-ce-cli containerd.io docker-buildx-plugin docker-compose-plugin …...

编程日记 2025/6/29 1:06:43

OpenAI for Countries：全球AI基础设施的“技术基建革命”

2025年5月7日，OpenAI宣布启动“OpenAI for Countries”计划，目标是为全球各国构建本土化的AI基础设施，提供定制化服务。这一计划被视为其“星际之门”项目的全球化延伸，以技术合作为核心，覆盖数据中心建设、模型适配与…...

编程日记 2025/6/28 23:05:38

手风琴效果

图示： 目的：这段HTML代码展示了一个简单的图片展示效果。通过使用Flexbox布局，创建了一个包含多个图片的容器，每张图片的宽度默认为120px，并在鼠标悬停时扩展至400px。代码中，图片路径通过JavaScript动态生…...

编程日记 2025/6/29 0:38:00

idea Maven 打包SpringBoot可执行的jar包

背景：当我们需要坐联调测试的时候，需要对接前端同事，则需要打包成jar包直接运行启动服务需要将项目中的pom文件增加如下代码配置： <build><plugins><plugin><groupId>org.springframework.boot</gr…...

编程日记 2025/6/28 23:45:29

Visual Studio 项目 .gitignore 文件指南

Visual Studio 项目 .gitignore 文件指南什么是 .gitignore？ .gitignore 是一个特殊的文件，用于告诉 Git 哪些文件或文件夹不需要纳入版本控制。这对于 Visual Studio 项目尤其重要，因为 Visual Studio 会生成很多你不需要手动管理的文件。…...

编程日记 2025/6/29 1:04:05

使用ADB命令操作Android的apk/aab包

keystore文件转换jks文件操作步骤： 步骤1，生成P12文件： keytool -importkeystore -srckeystore [文件名].keystore -srcstoretype JKS -deststoretype PKCS12 -destkeystore [文件名].p12 步骤2，生成jks文件： keytool…...

编程日记 2025/6/29 8:28:13

Ansys 计算刚柔耦合矩阵系数

Ansys 计算刚柔耦合系数矩阵文章目录 Ansys 计算刚柔耦合系数矩阵卫星的刚柔耦合动力学模型采用 ANSYS 的 APDL 语言的计算方法系统转动惯量的求解方法参考文献卫星的刚柔耦合动力学模型柔性航天器的刚柔耦合动力学模型可以表示为 m v ˙ B t r a n η F J ω ˙ ω J…...

编程日记 2025/6/28 23:31:13

原生小程序+springboot+vue医院医患纠纷管理系统的设计与开发（程序+论文+讲解+安装+售后）

感兴趣的可以先收藏起来，还有大家在毕设选题，项目以及论文编写等相关问题都可以给我留言咨询，我会一一回复，希望帮助更多的人。系统背景在医疗行业快速发展的当下，医患关系已成为社会各界关注的焦点。近年来&#…...

编程日记 2025/6/28 23:05:46

django扩展练习记录

一、Django 中使用 django-apscheduler 实现定时任务可以方便地管理周期性任务（如每天清理缓存、定时发送邮件等） 1. 安装 pip install django-apscheduler -i https://pypi.tuna.tsinghua.edu.cn/simple #0.7.02.添加到应用，python m…...

编程日记 2025/6/29 0:36:25

Android Exoplayer多路不同时长音视频混合播放

在上一篇Android Exoplayer 实现多个音视频文件混合播放以及音轨切换中我们提到一个问题，如果视频和音频时长不一致，特别是想混合多个音频和多个视频时就会出问题，无法播放。报错如下： E/ExoPlayerImplInternal(11191): Playback…...

编程日记 2025/6/29 0:37:23

第一章：HTML基石·现实的骨架

教学目标： • 理解 HTML 的整体结构（<!DOCTYPE>, <html>,<head>, <body>） • 掌握基础标签（<h1>, <p>, <a>, <img>, <ul>/<ol>/<li>, <div>, <span&…...

编程日记 2025/6/28 23:05:49

按键精灵ios脚本新增元素功能助力辅助工具开发（二）

元素节点功能（iOSElement） 在按键精灵 iOS 新版 APP v2.2.0 中，新增了元素节点功能 iOSElement，该功能包含共 15 个函数。这一功能的出现，为开发者在处理 iOS 应用界面元素时提供了更为精准和高效的方式。通过这些函…...

编程日记 2025/6/29 0:44:21

【源码+文档+调试讲解】党员之家服务系统小程序1

摘要本毕业设计的内容是设计并且实现一个基于springboot的党员之家服务系统小程序。它是在Windows下，以MYSQL为数据库开发平台，java技术和Tomcat网络信息服务作为应用服务器。党员之家服务系统小程序的功能已基本实现，主要包括首页、个人…...

编程日记 2025/7/12 12:17:13

《ffplay 读线程与解码线程分析：从初始化到 seek 操作，对比视频与音频解码的差异》

1 read-thread 1.1 初始化部分 1.分配. avformat_alloc_context 创建上下⽂ ic avformat_alloc_context();if (!ic) {av_log(NULL, AV_LOG_FATAL, "Could not allocate context.\n");ret AVERROR(ENOMEM);goto fail;}2 ic->interrupt_callback.callback deco…...

编程日记 2025/6/28 23:15:44

AI+可视化：数据呈现的未来形态

当AI生成的图表开始自动“美化”数据，当动态可视化报告能像人类一样“讲故事”，当你的眼球运动直接决定数据呈现方式——数据可视化的未来形态，正在撕裂传统认知。某车企用AI生成的3D可视化方案，让设计师集体失业；某医…...

编程日记 2025/6/28 23:05:50

Spring Boot 整合 Redis 实战

一、整合准备：环境与依赖 1. 技术栈说明 Spring Boot 版本：3.1.2（兼容 Java 17） Redis 服务器：Redis 7.0（本地部署或 Docker 容器） Maven 依赖： <dependency><…...

编程日记 2025/7/7 15:27:20

pdf url 转图片

背景：vue2.0需要把pdf转成图片，显示在url里面，使用pdfjs-dist来解决步骤： 1、安装依赖包(我的项目是node12，安装太高版本会报错) npm i pdfjs-dist2.16.105 2、vue代码 <template><div class"main…...

编程日记 2025/6/29 0:32:36

JPG与PDF格式转换器

该插件可实现JPG与PDF格式的互转。 MainForm.Designer.cs using System.Windows.Forms; namespace JpgToPdfConverter {partial class MainForm{private System.ComponentModel.IContainer components null;protected override void Dispose(bool disposing){if (disposing &…...

编程日记 2025/7/3 4:48:09

Kafka 如何保证消息顺序性

文章目录分区策略轮询随机按 Partition 路由按 key 路由顺序性保证分区策略 Kafka 的消息会被生产者发送到分区 Partition中，然后消费者通过获取分区中的消息来完成消费操作。所以Kafka不仅有主题 Topic这个概念，也引入分区 Partition 这个概念来实现…...

编程日记 2025/7/7 22:48:10

C++23 views::zip 和 views::zip_transform (P2321R2) 深入解析

文章目录一、引言二、C23与Ranges库背景知识2.1 C23概述2.2 Ranges库回顾三、views::zip 详解3.1 功能与定义3.2 使用场景3.3 示例代码四、views::zip_transform 详解4.1 功能与定义4.2 使用场景4.3 示例代码五、views::zip 与 views::zip_transform 的对比5.1 功能差异5.2…...

编程日记 2025/6/28 23:10:22

Starrocks的主键表涉及到的MOR Delete+Insert更新策略

背景写这个文章的作用主要是做一些总结和梳理，特别是正对大数据场景下的实时写入更新策略 COW 和 MOR 以及 DeleteInsert 的技术策略的演进， 这也适用于其他大数据的计算存储系统。该文章主要参考了Primary Key table. 分析总结 Starrocks 的主键表主…...

编程日记 2025/7/4 9:40:27

【计算机视觉】OpenCV实战项目：基于OpenCV的车牌识别系统深度解析

基于OpenCV的车牌识别系统深度解析 1. 项目概述2. 技术原理与算法设计2.1 图像预处理1) 自适应光照补偿2) 边缘增强 2.2 车牌定位1) 颜色空间筛选2) 形态学操作3) 轮廓分析 2.3 字符分割1) 投影分析2) 连通域筛选 2.4 字符识别 3. 实战部署指南3.1 环境配置3.2 项目代码解析 4.…...

编程日记 2025/6/29 0:57:05

20250513_问题：由于全局Pytorch导致的错误

文章目录前言问题：由于全局Pytorch导致的错误找到问题(1)找到问题(2) 总结前言问题：由于全局Pytorch导致的错误代码报错显示无法使用CUDA AttributeError: module ‘torch._C’ has no attribute ‘_cuda_setDevice’ 找到问题(1) import torch pri…...

编程日记 2025/6/29 0:56:30

flinksql实践(从kafka读数据)

本案例是基于flinksql实现的，将逐步实现从kafka读写数据，聚合查询，关联维表(外部系统)等。环境准备首先确保电脑已经安装好zookeeper、kafka、flink。本文flink使用单机模式，zookeeper和kafka也使用单机配置。(环境配置部分可以…...

编程日记 2025/6/29 0:50:56

Linux系统：文件系统前言，详解CHSLBA地址

本节重点理解硬盘的组成结构与工作原理理解柱面、扇区CHS地址进行寻址对整块硬盘的逻辑抽象LBA地址进行寻址LBA与CHS地址的相互转换一、初识硬盘 1.1 基本概念硬盘（Hard Disk Drive，HDD）是一种用于存储和检索数据的计算机硬件设备。它…...

编程日记 2025/6/28 23:05:54

2025年01月10日浙江鑫越系统科技前端面试

目录 vue2 和 vue3 的区别vue 怎么封装组件js 怎么把一个数组置空怎么组件自己调用自己的组件v-bind:attribute 和 v-bind“{attribute}” 的区别var let const 的区别this 指向作用域链闭包原型链事件循环 1. vue2 和 vue3 的区别 Vue 2 和 Vue 3 在多个方面存在区别&#…...

编程日记 2025/6/28 23:40:51

2025.05.11阿里云机考真题算法岗-第三题

📌 点击直达笔试专栏 👉《大厂笔试突围》 💻 春秋招笔试突围在线OJ 👉 笔试突围OJ 03. 镜像追踪游戏问题描述 A先生正在玩一款名为「镜像追踪」的游戏。游戏在一个 n n n...

编程日记 2025/6/28 23:29:20

实景三维建模软件应用场景（众趣科技实景三维建模）

实景三维建模软件应用场景概述实景三维建模软件，作为数字化时代的重要工具，不仅能够真实、立体、时序化地反映和表达物理世界，还为国家的基础设施建设和数字化发展提供了有力的支撑。在测绘与地理信息领域，实景三维建模软件是构…...

编程日记 2025/6/29 0:20:54

centos中libc.so.6No such file的解决方式

你在运行安装程序时遇到了以下错误： Configuring the installer for this systems environment...strings: /lib/libc.so.6: No such file 这个错误通常是由于系统中缺少 glibc（GNU C Library）或其相关文件导致的。glibc 是 Linux 系统中的…...

编程日记 2025/6/28 23:56:27

MapReduce打包运行

1. 编写 MapReduce 程序首先需要编写 MapReduce 程序，通常包含 Mapper、Reducer 和 Driver 类。例如，一个简单的 WordCount 程序： java import java.io.IOException; import java.util.StringTokenizer;import org.apache.hadoop.conf.Con…...

编程日记 2025/6/29 0:26:21

RustDesk：开源电脑远程控制软件

RustDesk：开源电脑远程控制软件 RustDesk：开源电脑远程控制软件一、RustDesk 简介二、下载教程2.1 桌面版下载2.2 Android 版下载三、安装教程3.1 桌面版安装四、功能讲解4.1 远程控制4.2 文件传输4.3 安全可靠4.4 自定义服务器五、RustDesk技术架构解…...

编程日记 2025/7/13 12:37:12

【Unity】WebGL开发问题汇总

1 前言主要记录下WebGL开发过程中遇到的各种问题。 2 问题 2.1 中文字体不显示问题： 经典问题了。将项目打包在WebGL平台后，运行发现所用中文字体都不现实了。解决办法： 替换Text组件的“字体”。可以将电脑字体复制到项目当中然后替换组…...

编程日记 2025/7/10 3:54:49

华为海思系列----昇腾张量编译器（ATC）模型转换工具----入门级使用指南（LINUX版）

由于官方SDK比较冗余且经常跨文档讲解且SDK整理的乱七八糟，对于新手来说全部看完上手成本较高，本文旨在以简短的方式介绍 CAFFE / ONNX 模型转 om 模型，并进行推理的全流程。希望能够帮助到第一次接触华为海思框架的道友们。大佬们就没必要看这种基础文章啦！注：本…...

编程日记 2025/6/28 23:05:51

c++STL-list的模拟实现

cSTL-list的模拟实现 list源码剖析list模拟实现list构造函数拷贝构造函数赋值重载迭代器 iterator访问结点数size和判空尾插 push_back头插 push_front尾删pop_back头删pop_front插入 insert删除 erase清空clear和析构函数访问结点参考程序 list源码剖析建议先看cSTL-list的…...

编程日记 2025/6/28 23:10:36

RabbitMQ 核心概念与消息模型深度解析（二）

四、代码实战了解了 RabbitMQ 的核心概念和消息模型后，接下来我们通过代码实战来进一步加深对它们的理解和掌握。下面将以 Java 和 Spring AMQP 为例，展示如何使用 RabbitMQ 进行消息的发送和接收。 4.1 环境准备在开始编写代码之前，需要…...

编程日记 2025/6/28 23:54:27

JAVA研发+前后端分离，ZKmall开源商城B2C商城如何保障系统性能？

在电商行业竞争白热化的当下，B2C 商城系统的性能表现成为决定用户留存与商业成败的关键因素。ZKmall 开源商城凭借 Java 研发与前后端分离架构的深度融合，构建起一套高效、稳定且具备强大扩展性的系统架构，从底层技术到上层应用全方位保障性能…...

编程日记 2025/6/28 23:33:35

【android bluetooth 框架分析 02】【Module详解 6】【StorageModule 模块介绍】

1. 背景我们在 gd_shim_module 介绍章节中，看到我们将 StorageModule 模块加入到了 modules 中。 // system/main/shim/stack.cc modules.add<storage::StorageModule>();在 ModuleRegistry::Start 函数中我们对加入的所有 module 挨个初始化。而在该函…...

编程日记 2025/6/29 0:20:58

Datawhale 5月llm-universe 第1次笔记

课程地址：GitHub - datawhalechina/llm-universe: 本项目是一个面向小白开发者的大模型应用开发教程，在线阅读地址：https://datawhalechina.github.io/llm-universe/ 难点：配置conda环境变量我用的vscode github方法目录重要…...

编程日记 2025/6/28 23:31:06

Linux架构篇、第五章git2.49.0部署与使用

Linux_架构篇欢迎来到Linux的世界，看笔记好好学多敲多打，每个人都是大神！ 题目：git2.49.0部署与使用版本号: 1.0,0 作者: 老王要学习日期: 2025.05.13 适用环境: Centos7 文档说明这份文档聚焦于在 CentOS 7 环境下部署和…...

编程日记 2025/6/29 0:21:00

南方科技大学Science！自由基不对称催化新突破 | 乐研试剂

近日，南方科技大学刘心元教授团队联合浙江大学洪鑫教授团队在自由基不对称催化领域取得新进展。课题组开发了一系列大位阻阴离子 N,N,P-配体，用于铜催化未活化外消旋仲烷基碘与亚砜亚胺的不对称胺化反应。该反应表现出广泛的底物兼容性，涵盖具…...

编程日记 2025/6/29 1:11:41

手机换IP真的有用吗？可以干什么？

在当今数字化时代，网络安全和个人隐私保护日益受到重视。手机作为我们日常生活中不可或缺的工具，其网络活动痕迹往往通过IP地址被记录和追踪。那么，手机换IP真的有用吗？它能为我们带来哪些实际好处？本文将为你一一解答…...

编程日记 2025/6/28 23:05:52

【C++详解】类和对象（上）类的定义、实例化、this指针

文章目录一、类的定义1、类定义格式2、访问限定符3、类域二、实例化1、实例化概念2、对象大小三、this指针一、类的定义 1、类定义格式 class为定义类的关键字，Stack为类的名字，{}中为类的主体，注意类定义结束时后面分号不能省略。类体中…...

编程日记 2025/6/28 23:05:53

C语言—再学习（数据的存储类别）

在c语言中，每个变量和函数都有两个属性：数据类型和数据的存储类别 C的存储类别包括4种：自动挡（auto）、静态的（static）、寄存器的（register）、外部的（extern&…...

编程日记 2025/6/29 1:06:09

软考软件评测师——计算机组成与体系结构（分级存储架构）

一、虚拟存储技术虚拟存储系统通过软硬件协同实现内存扩展，其核心特征包括： 逻辑容量扩展能力：实际物理内存与外存结合，呈现远大于物理内存的连续地址空间动态加载机制：程序运行时仅加载必要部分到内存，…...

编程日记 2025/7/5 4:32:35

需求跟踪矩阵准确性的5大策略

需求跟踪矩阵的准确性可显著提升软件项目质量，确保需求的全面覆盖、减少遗漏和偏差，有利于优化变更管理，降低返工风险，最终保障产品符合用户预期和业务目标。如果不能保证跟踪矩阵的准确性，可能会导致需求遗漏、测试覆…...

编程日记 2025/7/6 23:25:33

【调度算法】MAPF多智能体路径规划问题

参考链接：https://blog.csdn.net/qq_43353179/article/details/129396325 在这篇博客的基础上对一些省略的部分进行补充。网站：https://mapf.info/ 可行性判断 1. k-鲁棒性（k-robust MAPF） 在经典 MAPF 中，只要所有…...

编程日记 2025/6/28 23:18:23

迅龙3号基于兆讯MH22D3适配CST328多点触摸驱动开发笔记

MH22D3芯片是兆讯公司新推出的基于cortex-M3内核的新一代芯片，专注于显示应用，其主频高达216Mhz，64KB SRAM，512KB Flash，开发UI应用游刃有余。详细介绍请看：MH22D3新一代显控应用性价比之王新龙微基于MH22…...

编程日记 2025/6/28 23:09:03

推荐算法工程化：ZKmall模板商城的B2C 商城的用户分层推荐策略

在 B2C 电商竞争激烈的市场环境中，精准推荐已成为提升用户体验、促进商品销售的关键。ZKmall 模板商城通过推荐算法工程化手段，深度挖掘用户数据价值，制定科学的用户分层推荐策略，实现 “千人千面” 的个性化推荐，帮助…...

编程日记 2025/7/13 3:30:21