C# IAsyncEnumerable使用方法 C#如何异步地遍历集合

幻夢星雲

发布时间：2026-01-30 08:52:03

485人浏览过

来源于php中文网

原创

该用 IAsyncEnumerable<T> 而不是 IEnumerable<T> 时：集合项需逐个异步获取且要流式消费，如数据库游标、HTTP 分块响应；关键信号是方法返回 IAsyncEnumerable<T> 且内部含 await。

c# iasyncenumerable使用方法 c#如何异步地遍历集合

什么时候该用 `IAsyncEnumerable<T>` 而不是 `IEnumerable<T>`

当你的集合项需要逐个异步获取（比如从数据库流式读取、HTTP 分块响应、文件分片加载），且你希望在拿到前几项时就立刻开始处理，而不是等全部加载完再遍历——这时候 IAsyncEnumerable<T> 是唯一合理选择。它不是为“加速普通循环”设计的，而是为「异步拉取 + 流式消费」场景存在的。

常见误用：把本地内存 List 包装成 IAsyncEnumerable 并用 await foreach 遍历——这只会增加开销，毫无收益。

适用：EF Core 6+ 的 AsAsyncEnumerable()、HttpClient 读取分块响应、自定义异步数据源
不适用：new List<int> {1,2,3}.ToAsyncEnumerable() 这类转换（除非你刻意模拟延迟）
关键信号：方法签名返回 IAsyncEnumerable<T>，且内部有 await（如 await reader.ReadAsync()）

`await foreach` 的正确写法和常见崩溃点

await foreach 是唯一安全消费 IAsyncEnumerable<T> 的方式；直接调用 GetEnumerator() 或尝试转成 List 会丢失异步上下文或引发 InvalidOperationException。

典型错误现象：System.InvalidOperationException: 'The collection was modified after the enumerator was instantiated.' —— 多数是因为在 await foreach 循环体内又修改了同一个集合（比如边遍历边 Add），和同步 foreach 一样禁止。

必须用 await foreach (var item in source)，不能漏掉 await
循环体内 await 是允许的（比如处理每个 item 时发 HTTP 请求），但要注意整体超时控制
若需提前退出，用 break 即可；return 会自动释放底层资源（如数据库连接）
不要对同一 IAsyncEnumerable 实例多次 await foreach——多数实现是“一次性”的，第二次会立即完成且不返回任何项

如何手写一个简单的 `IAsyncEnumerable<T>` 数据源

不需要复杂框架，用 yield return + async 就能写。核心是返回 IAsyncEnumerable<T> 的方法本身标记 async，并在 yield return 前加 await。

VALL-E

VALL-E是一种用于文本到语音生成 (TTS) 的语言建模方法

下载

注意：C# 8+ 要求目标框架支持（.NET Core 3.0+ / .NET 5+），且项目文件需启用 <LangVersion>8.0</LangVersion> 或更高。

public static async IAsyncEnumerable<string> ReadLinesAsync(string path)
{
    await foreach (var line in File.ReadLinesAsync(path)) // 内置支持
    {
        yield return line.Trim();
        await Task.Delay(10); // 模拟处理延迟
    }
}

yield return 必须在 async IAsyncEnumerable<T> 方法内，不能放在普通 async Task 里
若要兼容旧版运行时（如 .NET Framework），需引用 System.Linq.Async NuGet 包，并用 AsyncEnumerable.Return 等静态构造
异常传播：在 yield 块中抛出的异常，会在对应 await foreach 迭代时被抛出，不是在枚举器创建时