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

c#多线程之生产者-消费者模型

news 来源：原创 2025/5/15 7:48:50

在 C# 中实现 生产者-消费者模式，通常需要多个线程来处理数据的生产和消费。我们可以使用 Queue<T> 来作为存储数据的队列，并使用 Thread、Mutex 或 Monitor 来确保线程安全。BlockingCollection<T> 是 C# 提供的一个线程安全的集合，可以非常方便地用于实现生产者-消费者模式。

生产者-消费者模式的关键点：

生产者线程：产生数据并将其放入队列中。
消费者线程：从队列中取出数据并进行处理。
线程同步：使用 BlockingCollection<T> 等线程安全的集合来避免竞争条件，同时确保生产者和消费者之间的协调。

示例：使用 `BlockingCollection<T>`

C# 提供了 BlockingCollection<T> 类，它可以用来在生产者和消费者线程之间提供同步机制。它是一个线程安全的集合，并支持阻塞操作，因此可以自动协调生产者和消费者的行为。

代码示例：

using System;
using System.Collections.Concurrent;
using System.Linq;
using System.Threading;class Program
{// 使用 BlockingCollection 实现线程安全的队列static BlockingCollection<int> queue = new BlockingCollection<int>(5); // 队列最大容量为5// 生产者线程static void Producer(){int item = 0;while (true){Thread.Sleep(500); // 模拟生产延迟// 生产数据并加入队列queue.Add(item);Console.WriteLine("生产者生产数据: " + item);item++;}}// 消费者线程static void Consumer(){while (true){int item = queue.Take(); // 阻塞直到队列中有数据Console.WriteLine("消费者消费数据: " + item);Thread.Sleep(1000); // 模拟消费延迟}}static void Main(){// 启动生产者线程Thread producerThread = new Thread(Producer);producerThread.Start();// 启动消费者线程Thread consumerThread = new Thread(Consumer);consumerThread.Start();// 等待线程结束（实际上，生产者和消费者线程会永远运行下去）producerThread.Join();consumerThread.Join();}
}

代码解释：

BlockingCollection<int> queue：一个线程安全的队列，最大容量为 5。BlockingCollection 会在队列满时阻塞生产者线程，在队列为空时阻塞消费者线程。
Producer()：模拟生产者线程，每 500 毫秒生成一个数据并放入队列中。如果队列已满，Add 操作会阻塞生产者线程，直到队列有空位。
Consumer()：模拟消费者线程，每秒消费一个数据。Take() 会阻塞直到队列中有数据。
Thread.Sleep()：用来模拟生产和消费的延迟。

`BlockingCollection<T>` 的关键方法：

Add(T item)：将项目添加到集合中。如果集合已满，它将阻塞直到有空余空间。
Take()：从集合中移除并返回一个项。如果集合为空，它将阻塞直到有可用项。
TryAdd(T item)：尝试将项目添加到集合中。如果成功则返回 true，否则返回 false，不会阻塞。
TryTake(out T item)：尝试从集合中移除并返回一个项。如果集合为空，返回 false。

扩展：多个生产者和多个消费者

BlockingCollection<T> 支持多个生产者和多个消费者，并且可以通过它来轻松实现复杂的生产者-消费者模型。你只需要启动多个线程来执行生产者和消费者的逻辑即可。

示例：多个生产者和多个消费者

using System;
using System.Collections.Concurrent;
using System.Threading;class Program
{static BlockingCollection<int> queue = new BlockingCollection<int>(5); // 队列最大容量为5// 生产者线程static void Producer(int id){int item = 0;while (true){Thread.Sleep(500); // 模拟生产延迟// 生产数据并加入队列queue.Add(item);Console.WriteLine($"生产者 {id} 生产数据: {item}");item++;}}// 消费者线程static void Consumer(int id){while (true){int item = queue.Take(); // 阻塞直到队列中有数据Console.WriteLine($"消费者 {id} 消费数据: {item}");Thread.Sleep(1000); // 模拟消费延迟}}static void Main(){// 启动多个生产者线程for (int i = 1; i <= 2; i++){int producerId = i;new Thread(() => Producer(producerId)).Start();}// 启动多个消费者线程for (int i = 1; i <= 3; i++){int consumerId = i;new Thread(() => Consumer(consumerId)).Start();}// 主线程等待Console.ReadLine();}
}

代码解释：

多个生产者线程：在 Main() 方法中，启动了 2 个生产者线程。每个线程调用 Producer() 方法，生成不同的数据并将其放入共享队列。
多个消费者线程：启动了 3 个消费者线程，它们从同一个共享队列中取出数据进行处理。

运行结果：

生产者 1 生产数据: 0
生产者 2 生产数据: 0
消费者 1 消费数据: 0
生产者 1 生产数据: 1
消费者 2 消费数据: 1
消费者 3 消费数据: 2
...

总结：

BlockingCollection<T> 是 C# 中实现生产者-消费者模式的理想工具。它是线程安全的，支持阻塞操作，且可以容纳多个生产者和消费者。
通过 BlockingCollection<T> 的 Add 和 Take 方法，生产者和消费者可以安全地进行数据交换而无需担心并发问题。
使用多个生产者和消费者线程时，BlockingCollection<T> 会自动处理队列的同步和线程间协调。

c#多线程之生产者-消费者模型

在 C# 中实现生产者-消费者模式，通常需要多个线程来处理数据的生产和消费。我们可以使用 Queue<T> 来作为存储数据的队列，并使用 Thread、Mutex 或 Monitor 来确保线程安全。BlockingCollection<T> 是 C# 提供的一个线程安全的集合&#xf…...

编程日记 2025/5/15 7:48:50

2011-2020年各省城镇职工基本医疗保险年末参保人数数据

2011-2020年各省城镇职工基本医疗保险年末参保人数数据 1、时间：2011-2020年 2、来源：国家统计局 3、指标：省份、时间、城镇职工基本医疗保险年末参保人数 4、范围：31省 5、指标解释：参保人数指报告期末按国家有关…...

编程日记 2025/5/12 15:44:40

Python基础语法知识——列表、字典、元组与集合

列表（list）、字典(dictionary)、元组(tuple)与集合(set)都可以看成存储数据的容器，但是前两者常用，后两者用得相对较少。目录 1 列表（list) 1.1列表入门 1 列表（list) 1.1列表入门 class1["李白…...

编程日记 2025/5/15 7:22:21

Mysql数据库中，监测某张表中某字段的修改情况（被哪个ip所修改、新老值）

在Mysql数据库中，通过写一个触发器，来监测某张表(q_device)字段(run_status)的改变情况。【示例】 -- 1. 创建监测日志表 CREATE TABLE change_log (id INT AUTO_INCREMENT PRIMARY KEY,table_name VARCHAR(255),column_name VARCHAR(255),old_value T…...

编程日记 2025/5/14 13:14:38

迁移学习详解及应用示例

简介： 迁移学习是一种机器学习技术，其核心思想是利用在一个任务上已经学到的知识（源任务：任务已经有一个训练好的模型，然后我们将这个模型的某些部分或知识迁移到一个新的但相关的“目标任务”上。）来帮助解…...

编程日记 2025/5/15 7:46:42

ubuntu控制器多网口配置

在Ubuntu系统中配置多网口，可以通过编辑网络配置文件（Netplan 或旧版 /etc/network/interfaces）实现。这适用于需要管理多个网络接口（如 eth0、eth1 等）的场景，例如负载均衡、网络隔离或多路径通信。以下…...

编程日记 2025/5/15 7:30:14

接口调用限频（代理模式+滑动窗口）

目录代码示例接口代理接口实现限流工厂限流处理器接口直接交换处理器限流处理器限流配置滑动窗口限流通过代理模式滑动窗口，限流请求第三方平台，避免出现第三方平台抛出限流异常，影响正常业务流程，从出口出发…...

编程日记 2025/5/10 3:25:37

链式算法处理视频流视频源是本地摄像头 # codinggbk # 本地摄像头直接推流到 RTMP 服务器 import cv2 import mediapipe as mp import subprocess as sp# 初始化 Mediapipe mp_drawing mp.solutions.drawing_utils mp_drawing_styles mp.solutions.drawing_styles mp_holis…...

编程日记 2025/5/15 7:48:50

2- Linux系统的命令帮助

Linux 命令行帮助信息使用指南一、引言对于初学者来说，Linux命令行可能会显得复杂和难以捉摸。然而，一旦掌握了如何有效地利用命令行的帮助信息，您将发现它是一个强大而灵活的工具，可以极大地提高您的工作效率。本指南旨在为新手介绍如何在Linux中获取命令的帮助信息，…...

编程日记 2025/5/13 0:43:30

Mysql事务

一、数据库事务基础 1.1. 什么是事务简单来说，事务就是要保证一组数据库操作，要么全部成功，要么全部失败。在 MySQL 中，事务支持是在引擎层实现的。比如 MySQL 原生的MyISAM引擎就不支持事务，这也是MyISAM被InnoDB…...

编程日记 2025/5/13 17:47:44

Fast adaptively balanced min-cut clustering

#0.论文信息标题：Fast adaptively balanced min-cut clustering期刊：Pattern Recognition作者: Feiping Nie , Fangyuan Xie , Jingyu Wang ,Xuelong Li机构: China Telecom, Northwestern Polytechnic al University.代码链接： #1.摘要 …...

编程日记 2025/5/9 14:58:58

vue3和springboot使用websocket通信

前端端口：9090 后端端口：8080 vue3 引入依赖： npm install sockjs-client stomp/stompjs vue页面 <template><div><h1>WebSocket 示例</h1><button click"sendMessage">发送消息</button>…...

编程日记 2025/5/13 17:29:41

Log4j2的Policies详解、SizeBasedTriggeringPolicy、TimeBasedTriggeringPolicy

文章目录一、Policies二、SizeBasedTriggeringPolicy:基于文件大小的滚动策略2.1、文件达到指定大小就归档三、TimeBasedTriggeringPolicy：基于时间间隔的滚动策略3.1、验证秒钟归档场景3.2、验证分钟场景3.3、验证小时场景四、多策略组合使用五、扩展知识5.1、S…...

编程日记 2025/5/10 3:58:38

js版本之ES6特性简述【Proxy、Reflect、Iterator、Generator】(五)

目录 Proxy Reflect 静态方法部分实例 Iterator 实际开发迭代器的使用实例迭代器（Iterator）应用 Generator Proxy Proxy 是 ES6 中新增的对象 Proxy 是JavaScript中的内置对象，它提供了一种机制，可以拦截并自定义各种…...

编程日记 2025/5/14 8:20:14

微信V3支付报错平台证书及平台证书序列号

1.平台证书及平台证书序列号设置错误报错： 错误1： Verify the response’s data with: timestamp1735184656, noncea5806b8cabc923299f8db1a174f3a4d0, signatureFZ5FgD/jtt4J99GKssKWKA/0buBSOAbWcu6H52l2UqqaJKvrsNxvodB569ZFz5G3fbassOQcSh5BFq6hvE…...

编程日记 2025/5/15 7:47:46

【开发问题记录】执行 git cz 报require() of ES Module…… 错误

文章目录 1、问题2、解决3、参考链接 1、问题在对 commitizen 进行完，一系列的初始化以后 ， 对代码进行提交到暂存区，然后要提交到本地仓库的报错然后因为安装了 commitizen 所以是想用 git cz 进行提交的， 执行命令的时候…...

编程日记 2025/5/11 3:00:48

Kubernetes 安装 Nginx以及配置自动补全

部署 Nginx ： [rootk8s-master ~]# kubectl create deployment nginx --imagenginx:1.14-alpine deployment.apps/nginx created暴露端口： [rootk8s-master ~]# kubectl expose deployment nginx --port80 --typeNodePort service/nginx exposed查看服…...

编程日记 2025/5/5 2:57:51

JS中的闭包和上下文

变量提升和函数提升这里要提到一个提升的概念，即在JS中，在解析代码之前还有一个预处理的过程，这个过程中会把部分变量和函数声明提前到代码的最顶部， 会在其他所有代码之前执行。虽然当我们按照规范（严格模式或者T…...

编程日记 2025/5/11 14:55:58

element-ui表格多级表头固定列和合并单元格

多级表头固定列代码示例-不能直接运行，仅供参考 <el-table ref"table" class"table":data"list"style"width: 100%":header-cell-style"headerCellStyle"v-loading"dataLoading":span-method&qu…...

编程日记 2025/5/10 5:43:37

视频汇聚融合云平台Liveweb一站式解决视频资源管理痛点

随着5G技术的广泛应用，各领域都在通信技术加持下通过海量终端设备收集了大量视频、图像等物联网数据，并通过人工智能、大数据、视频监控等技术方式来让我们的世界更安全、更高效。然而，随着数字化建设和生产经营管理活动的长期开展&#xff0…...

编程日记 2025/5/7 17:38:54

第五十九章假脱机设备

文章目录第五十九章假脱机设备介绍打开和使用假脱机设备用于假脱机设备的 OPEN 和 USE 命令USE 命令第五十九章假脱机设备介绍 IRIS数据平台使能够将打印输出直接发送到您的打印机或屏幕，或将其保留在后台打印中以供以后打印。IRIS 假脱机独立于您的操作系统…...

编程日记 2025/5/14 22:10:54

Maven Wrapper 报错“未找到有效的 Maven 安装”

1. 检查 Maven Wrapper 配置： 确保你的项目中包含 .mvn/wrapper/maven-wrapper.properties 文件。检查该文件中的 distributionUrl 属性，确保它指向一个有效的 Maven 发行版 URL。 2.确认 Maven Wrapper 脚本存在： 在项目根目录下&#x…...

编程日记 2025/5/13 11:43:08

yarn list --pattern vuex-module-decorators

dgqdgqdeMac-mini spid-admin % yarn list --pattern vuex-module-decorators yarn list v1.22.22 └─ vuex-module-decorators0.16.1 ✨ Done in 0.24s.好的，这段代码是一个典型的 Vuex 模块定义，使用了 vuex-module-decorators 库。这个库为 Vuex 提…...

编程日记 2025/5/15 7:48:50

day19-Linux软件包

科普，什么是代码文件。电脑程序Program，就是某一个编程语言编写的一个代码文件，里面包含了该语言特有的指令，以及各种字符、符号。 linux自带的network管理脚本，shell脚本什么是软件程序。软件程序，就…...

编程日记 2025/5/6 3:46:20

【网络分析工具】WireShark的使用（超详细）

网络分析工具——WireShark的使用简介WireShark软件安装Wireshark 开始抓包示例WireShark抓包界面WireShark 主要分为这几个界面TCP包的具体内容Wireshark过滤器设置wireshark过滤器表达式的规则Wireshark抓包分析TCP三次握手Wireshark分析常用操作简介 WireShark是非常流…...

编程日记 2025/5/15 7:44:21

React 高级组件开发：动态逻辑与性能优化

React 高级组件开发：动态逻辑与性能优化引言一、动态逻辑与配置化组件1. 动态组件的设计二、自定义 Hooks 解决复杂状态管理1. 自定义 Hook 的优势三、高阶组件（HOC）模式1. 高阶组件的应用场景四、性能优化1. 使用 React.memo 优化渲染2.…...

编程日记 2025/5/15 7:15:17

Vue 3 与 Tauri 集成开发跨端APP

1、安装RUST 下载地址：Install Rust - Rust Programming Language 安装： 安装完成后，在命令行里运行: rustup 2、安装 Node.js 与 npm 或 pnpm ，如果已经安装，可以忽略 # 使用 nvm 安装 Node.js 最新版本 nvm install…...

编程日记 2025/5/15 7:43:17

FreeRTOS中xPortPendSVHandler()和vPortSVCHandler()这两个函数的作用

在 FreeRTOS 中，xPortPendSVHandler() 和 vPortSVCHandler() 是两个重要的中断服务例程（ISR），它们负责处理与操作系统相关的异常。这些函数对于实现上下文切换和任务管理至关重要。下面分别解释这两个函数的作用： xPo…...

编程日记 2025/5/15 7:26:05

【RK3588 Linux 5.x 内核编程】-内核IO复用与poll

内核IO复用与poll 文章目录内核IO复用与poll1、IO复用2、Poll的使用2.1 用户空间程序中使用Poll2.2 在内核空间实现Poll3、驱动程序实现4、用户空间程序实现5、验证让我们假设应用程序想要根据其状态读取/写入许多 IO（输入和输出）的情况。在这种情况下我们该怎么办？我们必…...

编程日记 2025/5/15 1:16:15

精选9个自动化任务的Python脚本精选

大家好，我是老邓，今天我们来一起学习如何用Python进行一些常见的自动化操作，涉及文件处理、网络交互等实用技巧。即使你没有任何Python基础也没关系，我会用最通俗易懂的语言来讲解。 1. 对目录中的文件进行排序 import osdef so…...

编程日记 2025/5/15 7:46:42

使用JFLASH批量烧录程序导入生产的简易设置

基于上一篇帖子我们可以把任意厂家的MCU导入jflash来使用首先，我使用的是V699C版本，目前使用了一段时间没有问题我尝试过换不同的电路板烧录连续烧录，当单片机里没有程序的时候，问题不大，但是一旦单片机里有程序的话…...

编程日记 2025/5/10 18:46:56

计算机体系结构期末复习1：分支预测

目录一、为什么需要分支预测 1.存在分支的指令 2.控制相关的处理方式一：stall(阻塞）流水线二、分支预测方法 1.预测正确与预测错误的性能损失 2.减少预测错误的惩罚 3.提高分支预测的准确度 1）编译时（静态方法&#xff…...

编程日记 2025/5/15 7:15:17

获取页面上所有的img，并保存到本地

浏览器的 JavaScript 环境中受限于安全和隐私原因，不允许直接指定下载文件夹或访问本地文件系统。因此，无法通过纯 JavaScript 在浏览器控制台中实现下载图片到指定文件夹的功能。然而，您可以使用 Web API 提供的文件系统访问 API 进行一定…...

编程日记 2025/5/15 7:12:08

Day56 图论part06

108.冗余连接并查集应用类题目，关键是如何把题意转化成并查集问题代码随想录 import java.util.Scanner;public class Main{public static void main (String[] args) {Scanner scanner = new Scanner(System.in);int n = scanner.nextInt();DisJoint disjoint = new DisJo…...

编程日记 2025/5/11 6:02:35

深度学习助力股市预测：LSTM、RNN和CNN模型实战解析

作者：老余捞鱼原创不易，转载请标明出处及原作者。写在前面的话：众所周知，传统的股票预测模型有着各种各样的局限性。但在我的最新研究中，探索了一些方法来高效预测股市走势，即CNN、RNN和LSTM这些深度学习…...

编程日记 2025/5/10 11:28:14

.NET能做什么？全面解析.NET的应用领域

.NET 是由微软开发的一个开源、跨平台的开发框架。它不仅支持构建各种应用程序，还能运行在不同的操作系统上，包括 Windows、Linux 和 macOS。自从 .NET Core 的推出，.NET 成为了一个现代化的开发平台，能够满足企业和开发者日益多样…...

编程日记 2025/5/6 7:23:01

分布式事务入门一

分布式事务入门一您好，我是今夜写代码,今天学习下分布式事务相关理论，以及常见的解决方案，为后续掌握Seata分布式事务框奠定基础。为什么需要分布式事务? 分布式事务主要由于存储资源的分布性，通常涉及多个数据库。分布式…...

编程日记 2025/5/14 20:39:50

华为，新华三，思科网络设备指令

1. 设备信息查看华为 display version # 查看设备版本信息 display device # 查看设备硬件信息新华三（H3C） display version # 查看设备版本信息 display device # 查看设备硬件信息锐捷 show version …...

编程日记 2025/5/8 1:44:56

深入理解HTML页面加载解析和渲染过程（一）

一篇老文章，存在草稿有点可惜 HTML页面呈现通常包括三个主要过程：加载、解析和渲染。让我们详细探讨每个过程。 1. 加载过程加载过程主要涉及获取页面所需的所有资源。这个过程包括以下步骤： 1.1 URL资源加载缓存读取：浏览器…...

编程日记 2025/5/6 20:28:37

Odoo 免费开源 ERP：通过 JavaScript 创建对话框窗口的技术实践分享

作者 | 老杨出品 | 上海开源智造软件有限公司（OSCG） 概述在本文中，我们将深入研讨如何于 Odoo 18 中构建 JavaScript（JS）对话框或弹出窗口。对话框乃是展现重要讯息、确认用户操作以及警示用户留意警告或错误的行…...

编程日记 2025/5/13 17:29:23

Word批量更改题注

文章目录批量更改批量去除空格在写文章的时候，往往对图片题注有着统一的编码要求，例如以【图 1- xx】。一般会点击【引用】->【插入题注】来插入题注，并且在引用的时候，点击【引用】->【交叉引用】，并且在交叉…...

编程日记 2025/5/12 15:59:54

电脑缺失libcurl.dll怎么解决？详解电脑libcurl.dll文件丢失问题

一、libcurl.dll文件丢失的原因 libcurl.dll是一个用于处理URL传输的库文件，广泛应用于各种基于网络的应用程序。当这个文件丢失时，可能会导致相关应用程序无法正常运行。以下是libcurl.dll文件丢失的一些常见原因： 软件安装或卸载不完整&a…...

编程日记 2025/5/10 8:48:00

OpenCV相机标定与3D重建(36)计算两幅图像之间基本矩阵（Fundamental Matrix）的函数findFundamentalMat()的使用

操作系统：ubuntu22.04 OpenCV版本：OpenCV4.9 IDE:Visual Studio Code 编程语言：C11 算法描述从两幅图像中的对应点计算基本矩阵。 cv::findFundamentalMat 是 OpenCV 中用于计算两幅图像之间基本矩阵（Fundamental Matrix&#…...

编程日记 2025/5/12 23:07:29

JQ中的each()方法与$.each()函数的使用区别

介绍 jquery里的 each() 是一个强大的遍历工具，用于迭代集合中的元素，并为每个元素执行指定的函数‌。它既可以用于遍历 jQuery对象集合，也可以用于遍历普通的数组或对象。 each()对象遍历语法： $(selector).each(function(in…...

编程日记 2025/5/12 2:48:38

浅谈下雪花算法的原理，及在项目中使用需要注意哪些事项

目录背景雪花算法原理算法特点注意事项总结背景雪花算法是一种分布式ID生成算法，由Twitter提出，用于在分布式系统中生成全局唯一的ID。该算法通过将64位的长整型数字分为符号位、时间戳、工作机器ID和序列号四个部分，确保了ID的…...

编程日记 2025/5/12 21:59:54

洛谷P1536 村村通（c嘎嘎）

题目链接：P1536 村村通 - 洛谷 | 计算机科学教育新生态题目难度：普及/提高解题思路：本题很明显考察是并查集，并查集之前我的博客介绍过可以看看这篇洛谷P1551 亲戚（c嘎嘎）-CSDN博客，本题是…...

编程日记 2025/5/14 0:56:43

双指针——查找总价格为目标值的两个商品

一.题目描述 LCR 179. 查找总价格为目标值的两个商品 - 力扣（LeetCode） 二.题目解析这个题目非常简单，其实就是判断有没有两个数加起来等于target。三.算法解析 1.暴力解法暴力解法的话我们可以枚举出所有的情况，然后判…...

编程日记 2025/5/11 14:59:44

智慧园区小程序开发制作功能介绍

智慧园区小程序开发制作功能介绍智慧园区小程序系统作为一款面向园区企业的一站式线上服务平台，可为企业提供数智化的园区办公服务。智慧园区小程序功能介绍 1、园区公告、政策信息查看足不出户掌握最新动态，“园区公告、政策信息”等信息。首页点击对应…...

编程日记 2025/5/9 9:41:45

【面经】25届双非本科字节跳动北京四年的总结

点击“硬核王同学”，选择“关注” 福利干货第一时间送达大家好，我是硬核王同学，最近在做免费的嵌入式知识分享，帮助对嵌入式感兴趣的同学学习嵌入式、做项目、找工作！ 给大家分享一个25届本科大佬的面经&#xff0c…...

编程日记 2025/5/11 21:02:53

MySql幻读问题

认识具有反复性。之前以为理解了幻读，最近看黑马的mysql教程以为再次加深了认识。然而现在认为之前的理解都是错误的，而且网上很多关于幻读的解释，都不太准确。关于幻读的最佳解释还是要看官网mysql官网幻读解释脏读和不可重复读比较好理…...

编程日记 2025/5/11 15:52:41

生产者-消费者模式的关键点：

示例：使用 BlockingCollection<T>

代码示例：

代码解释：

BlockingCollection<T> 的关键方法：

扩展：多个生产者和多个消费者

示例：多个生产者和多个消费者

代码解释：

运行结果：

总结：

相关文章：

示例：使用 `BlockingCollection<T>`

`BlockingCollection<T>` 的关键方法：