IAsyncEnumerable 提供异步流式处理数据的能力，解决同步枚举阻塞线程的问题。通过 async yield return 生成数据，配合 await foreach 异步消费，支持取消操作，适用于大数据、文件、网络流等场景，提升性能与资源利用率。
IAsyncEnumerable
为什么需要 IAsyncEnumerable？
传统的 IEnumerable
如何使用 IAsyncEnumerable？
定义一个返回 IAsyncEnumerable
- 方法返回类型为 IAsyncEnumerable
- 使用 [EnumeratorCancellation] 参数接收取消令牌（可选）
- 用 yield return 异步生成每一项
示例：模拟异步产生数据流
public async IAsyncEnumerableGetDataAsync([EnumeratorCancellation] CancellationToken ct = default) { for (int i = 1; i <= 5; i++) { await Task.Delay(1000, ct); // 模拟异步延迟 yield return $"Item {i}"; } }
如何消费 IAsyncEnumerable？
使用 await foreach 来安全地异步遍历数据流：
await foreach (var item in GetDataAsync())
{
Console.WriteLine(item);
}
支持取消操作：
using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3));
await foreach (var item in GetDataAsync(cts.Token))
{
Console.WriteLine(item);
}
上面代码会在 3 秒后自动取消枚举。
常见应用场景
- 从 API 流式下载数据（如分页拉取日志）
- 读取大文件或日志流，逐行处理
- 数据库中使用 EF Core 6+ 的 AsAsyncEnumerable() 查询大数据集
- SignalR 或 gRPC 中推送实时消息
EF Core 示例：
await foreach (var user in dbContext.Users
.AsAsyncEnumerable()
.WithCancellation(ct))
{
Console.WriteLine(user.Name);
}
基本上就这些。IAsyncEnumerable 让你在处理数据流时更高效、更可控，尤其适合高吞吐或资源受限的环境。合理使用它可以避免内存暴增和线程阻塞问题。
