await foreach 是 C# 8.0 引入的一个语法特性,用于异步遍历实现了 IAsyncEnumerable
为什么需要 await foreach?
传统的 foreach 只能同步遍历 IEnumerable
如何使用 await foreach?
基本语法和 foreach 类似,只需在前面加上 await:
await foreach (var item in asyncDataStream)
{
// 处理每一项
Console.WriteLine(item);
}
如何生成异步集合?
使用 async 方法返回 IAsyncEnumerable
async IAsyncEnumerable
{
for (int i = 1; i
{
await Task.Delay(1000); // 模拟异步操作
yield return i;
}
}
然后就可以用 await foreach 消费:
await foreach (var num in GenerateNumbersAsync())
{
Console.WriteLine(num);
}
实际应用场景
从数据库分批读取大量记录而不占用连接 处理实时日志流或事件推送 下载大文件时按块处理 Web API 中实现 Server-Sent Events (SSE)基本上就这些。await foreach 让异步流处理变得直观又高效。
