在 C# 中,IAsyncEnumerable
什么是 IAsyncEnumerable?
IAsyncEnumerable
使用 await foreach 可以安全地遍历异步数据流:
await foreach (var item in GetDataAsync())
{
Console.WriteLine(item);
}
如何用 yield return 返回异步流?
在异步方法中,你可以使用 async + yield return 来逐个返回元素,编译器会自动生成状态机来管理异步迭代过程。
示例:从多个 API 异步获取数据并逐个返回:
public async IAsyncEnumerable<string> DownloadLinesAsync()
{
var urls = new[] { "url1", "url2", "url3" };
<pre class='brush:php;toolbar:false;'>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
