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

老婷同学_5621

老婷同学_5621

2025-12-30

443人浏览

原创

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 return 和 await 的上下文保存下来。

async IAsyncEnumerable<string> 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;
    }
}</string>
  • 必须用 await using 确保资源异步释放,否则可能泄漏文件句柄
  • CancellationToken 要传给所有底层异步调用(如 ReadLineAsync(ct)),否则无法响应取消
  • 别在 yield return 后面写耗时同步代码(比如 Thread.Sleep(100)),它会阻塞整个流,破坏非阻塞性

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

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

outlook-microsoft
outlook-microsoft

微软 Outlook 邮箱和日历管理工具(支持世纪互联版 Office 365)。用于查看、发送、搜索邮件,管理日历日程,创建会议,查询忙闲状态。注意:此功能仅支持世纪互联(21Vianet)版 Microsoft 365,使用 login.chinacloudapi.cn。

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

IEnumerable 和 IAsyncEnumerable 能混用吗?

不能直接赋值或隐式转换。它们是完全不同的接口,运行时类型不兼容。LINQ 方法也得换——System.Linq 里的 Where、Select 对 IAsyncEnumerable 无效,必须用 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速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

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

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

2025.12.04

798

13

string转int
string转int

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

2023.08.02

6959

3

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

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

2024.08.29

3345

6

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

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

2025.08.29

4348

10

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

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

2025.08.29

2965

10

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

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

2023.10.19

3208

3

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

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

2025.10.17

5189

12

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

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

2025.12.29

3849

9

java接口相关教程
java接口相关教程

本专题整合了java接口相关内容,阅读专题下面的文章了解更多详细内容。

2026.01.19

486

15

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程