IAsyncEnumerable 是 .NET Core 3.0 引入的异步枚举接口,结合 yield return 可实现高效异步数据流处理,适用于文件读取、网络请求等场景,支持 await foreach 消费,具有内存友好、响应快、代码简洁等优势,需注意资源释放和运行环境限制。

在 C# 中,IAsyncEnumerable
什么是 IAsyncEnumerable?
IAsyncEnumerable
使用 await foreach 可以安全地遍历异步数据流:
await foreach (var item in GetDataAsync())
{
Console.WriteLine(item);
}
如何用 yield return 返回异步流?
在异步方法中,你可以使用 async + yield return 来逐个返回元素,编译器会自动生成状态机来管理异步迭代过程。
示例:从多个 API 异步获取数据并逐个返回:
public async IAsyncEnumerableDownloadLinesAsync() { var urls = new[] { "url1", "url2", "url3" }; foreach (var url in urls) { using var client = new HttpClient(); var response = await client.GetStringAsync(url); yield return response; }}
每次 yield return 都会在数据准备好后发出,消费者可以立即处理,无需等待全部完成。
优势与适用场景
- 内存友好:不需要一次性加载所有数据到集合中,适合处理大数据流。
- 响应更快:消费者可以在第一个元素可用时就开始处理,减少延迟。
- 简化代码:无需手动实现 IAsyncEnumerator 或复杂回调逻辑。
- 自然控制流:使用标准循环和异常处理结构,代码更易读写。
常见用途包括日志流处理、分页拉取远程数据、实时传感器读数、异步文件行读取等。
注意事项
- 必须使用 await foreach 消费,否则不会触发异步行为。
- 注意资源释放:在 yield return 前确保非托管资源(如 HttpClient)正确处置。
- 不支持 .NET Framework:需运行在 .NET Core 3.0+ 或 .NET 5+ 环境。
- 调试时可能难以跟踪状态机,建议添加日志辅助分析。
基本上就这些。IAsyncEnumerable










