讲师中心 微信公众号
AI工具推荐 视频效率加速

C# BlockingCollection的用法 - 生产者-消费者模式的利器

夏宇大大_6402

夏宇大大_6402

发布时间:2025-12-08 20:25:16

|

1050人浏览过

|

来源于php中文网

原创

BlockingCollection是C#中专为线程安全生产者-消费者场景设计的核心类型,封装ConcurrentQueue等容器,提供阻塞添加/消费、CompleteAdding()结束通知、超时与取消支持及自定义底层容器能力。

c# blockingcollection<t>的用法 - 生产者-消费者模式的利器

BlockingCollection 是 C# 中专为线程安全的生产者-消费者场景设计的核心类型,它封装了线程安全的队列(默认 ConcurrentQueue<t></t>),自动处理阻塞、取消和完成通知,让多线程协作变得简洁可靠。

基础用法:创建、添加与消费

只需指定内部容器(可选)和最大容量,就能快速启用阻塞行为:

  • 无参构造:使用默认 ConcurrentQueue<t></t>,无限容量
  • 指定容量(如 new BlockingCollection<int>(10)</int>):Add() 在满时阻塞,Take() 在空时阻塞
  • Add(item) 和 Take() 是最常用方法,线程安全且自带阻塞语义

优雅结束:CompleteAdding 与 IsCompleted

当所有生产者完成投递,需显式调用 CompleteAdding(),否则消费者调用 Take() 会一直阻塞等待新项:

C#
C#

"避开 C# 常见错误——空陷阱、异步陷阱、LINQ 陷阱及资源泄漏。"

下载
  • 调用后,IsCompleted 返回 true,且后续 Add() 抛出异常
  • 消费者可通过 GetConsumingEnumerable() 遍历——它会在完成添加后自动退出循环
  • 示例:foreach (var item in collection.GetConsumingEnumerable()) { /* 处理 */ }

带超时与取消:更可控的阻塞操作

避免无限等待,可用重载方法传入 TimeSpan 或 CancellationToken:

  • TryAdd(item, TimeSpan.FromMilliseconds(500)):超时返回 false
  • TryTake(out item, TimeSpan.FromSeconds(1)):空时等待 1 秒后返回 false
  • Take(cancellationToken):支持协作式取消,适合长任务中响应中断

进阶技巧:自定义容器与批量操作

BlockingCollection 不限于队列,还可包装 ConcurrentStack<t></t>(LIFO)或 ConcurrentBag<t></t>(无序):

  • new BlockingCollection<string>(new ConcurrentStack<string>())</string></string> 实现栈式消费
  • 注意:不同底层容器影响遍历顺序和性能特征,但阻塞逻辑保持一致
  • 不直接支持批量 Add/Take,但可通过循环 + 超时控制实现“尽力批量”逻辑

基本上就这些。BlockingCollection 的价值不在功能繁多,而在把生产者-消费者中最容易出错的同步、边界、生命周期问题都收束到几个简单方法里——写对一次,线程安全就有了保障。

热门AI工具

更多
UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

超级简历WonderCV

一款AI办公效率工具,主要用于免费求职简历模版下载制作,应届生职场人必备简历制作神器,适合需要提升相关任务效率的用户。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

6779

2023.08.02

php中foreach用法
php中foreach用法

本专题整合了php中foreach用法的相关介绍,阅读专题下面的文章了解更多详细教程。

798

2025.12.04

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

6779

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

3265

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

4248

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

2885

2025.08.29

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

6247

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

2628

2023.08.10

Vite 项目如何打包和部署
Vite 项目如何打包和部署

Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章,帮助读者完成上线流程。

40

2026.10.28

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn