0

0

c# IAsyncEnumerable 和 IEnumerable 的区别 c#异步流怎么用

煙雲

煙雲

发布时间:2025-12-30 10:59:43

|

403人浏览过

|

来源于php中文网

原创

foreach会卡住而await foreach不会,因为IEnumerable是同步拉取模型,每次MoveNext()阻塞线程;IAsyncEnumerable是异步拉取,MoveNextAsync()返回ValueTask,可挂起并释放线程,适合文件、HTTP、数据库等异步数据源。

c# iasyncenumerable 和 ienumerable 的区别 c#异步流怎么用

为什么 foreach 会卡住,而 await foreach 不会?

因为 IEnumerable 是同步拉取模型:每次调用 MoveNext() 都得等结果回来,线程就停在那儿了;而 IAsyncEnumerable 是异步拉取,MoveNextAsync() 返回的是 ValueTask,可以挂起、释放线程、等 I/O 就绪后再恢复——这正是处理文件、HTTP 响应、数据库游标时不会拖垮吞吐量的关键。

  • 同步枚举(IEnumerable)适合内存中已加载好的小集合,比如 List.AsEnumerable()
  • 异步枚举(IAsyncEnumerable)适合数据源本身是异步的:文件流、网络分块响应、实时日志、gRPC 流式调用
  • 强行把 IAsyncEnumerable 转成 IEnumerable(比如用 .ToList().AsEnumerable())会立刻失去所有异步优势,还可能 OOM

怎么写一个真正能“流起来”的 IAsyncEnumerable 方法?

核心就三条:async 修饰符 + yield return + 异步等待(如 await reader.ReadLineAsync())。编译器会自动生成状态机,把每次 yield returnawait 的上下文保存下来。

async IAsyncEnumerable ReadLinesAsync(string path, CancellationToken ct = default)
{
    await using var reader = new StreamReader(path);
    string? line;
    while ((line = await reader.ReadLineAsync(ct)) != null)
    {
        yield return line;
    }
}
  • 必须用 await using 确保资源异步释放,否则可能泄漏文件句柄
  • CancellationToken 要传给所有底层异步调用(如 ReadLineAsync(ct)),否则无法响应取消
  • 别在 yield return 后面写耗时同步代码(比如 Thread.Sleep(100)),它会阻塞整个流,破坏非阻塞性

await foreach 消费时,哪些坑会让异步流“变回同步”?

最常见的错误是「表面用了 await foreach,实际还是串行阻塞」。比如在循环体内做同步 I/O 或没开并发。

Studio Global
Studio Global

Studio Global AI 是一个内容生成工具,帮助用户客制化生成风格和内容,以合理价格提供无限生成,希望将 AI 带给全世界所有人。

下载
  • ❌ 错误示范:
    await foreach (var line in ReadLinesAsync("log.txt"))
    {
        ProcessLineSync(line); // 这里是同步 CPU 密集操作,但没并行,流被拖慢
    }
  • ✅ 改进思路:用 Task.WhenAll 批量并发处理,或配合 Channel 构建生产-消费管道
  • ⚠️ 注意:await foreach 本身不提供背压控制,如果生产快、消费慢,缓冲区可能暴涨——需要手动加限流(如 BufferBlock 或自定义 IAsyncEnumerable 包装器)

IEnumerable 和 IAsyncEnumerable 能混用吗?

不能直接赋值或隐式转换。它们是完全不同的接口,运行时类型不兼容。LINQ 方法也得换——System.Linq 里的 WhereSelectIAsyncEnumerable 无效,必须用 System.Linq.Async(NuGet 包 Microsoft.Bcl.AsyncInterfaces 已内置)。

  • myAsyncStream.Where(x => x.Length > 10) → 编译失败(缺少引用或 using)
  • ✅ 正确写法:
    using System.Linq.Async;
    
    await foreach (var item in myAsyncStream.Where(x => x.Length > 10))
    {
        Console.WriteLine(item);
    }
  • ⚠️ ToHashSetAsync()ToListAsync() 这类终结方法会把整个流收集成内存集合,慎用——除非你明确知道数据量可控
异步流不是“加个 async 就完事”,关键在让数据真正按需流动、线程按需释放。最容易忽略的是取消传播和资源异步释放,这两个点一漏,轻则响应迟钝,重则连接/句柄泄漏。

相关专题

更多
php中foreach用法
php中foreach用法

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

37

2025.12.04

string转int
string转int

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

312

2023.08.02

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

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

518

2024.08.29

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

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

48

2025.08.29

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

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

188

2025.08.29

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

988

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

48

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

135

2025.12.29

俄罗斯搜索引擎Yandex最新官方入口网址
俄罗斯搜索引擎Yandex最新官方入口网址

Yandex官方入口网址是https://yandex.com;用户可通过网页端直连或移动端浏览器直接访问,无需登录即可使用搜索、图片、新闻、地图等全部基础功能,并支持多语种检索与静态资源精准筛选。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

1

2025.12.29

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
简单聊聊mysql8与网络通信
简单聊聊mysql8与网络通信

共1课时 | 776人学习

10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

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

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号