IAsyncEnumerable<T> 提供异步流式处理数据的能力，解决同步枚举阻塞线程的问题。通过 async yield return 生成数据，配合 await foreach 异步消费，支持取消操作，适用于大数据、文件、网络流等场景，提升性能与资源利用率。
IAsyncEnumerable<T> 是 .NET 中用于表示可异步枚举的流式数据集合的接口，它允许你一边异步获取数据，一边处理这些数据，而不需要等待整个集合加载完成。这在处理大量数据、文件读取、网络流、数据库查询或实时数据推送等场景中非常有用。
为什么需要 IAsyncEnumerable？
传统的 IEnumerable<T> 在遍历数据时是同步的，如果每条数据的获取涉及 I/O 操作（如从网络或磁盘读取），就会阻塞线程。而 IAsyncEnumerable<T> 结合 await foreach，可以实现非阻塞式的数据流处理，提升响应性和资源利用率。
如何使用 IAsyncEnumerable？
定义一个返回 IAsyncEnumerable<T> 的方法，通常使用 async yield return 语法：
- 方法返回类型为 IAsyncEnumerable<T>
- 使用 [EnumeratorCancellation] 参数接收取消令牌（可选）
- 用 yield return 异步生成每一项
示例：模拟异步产生数据流
public async IAsyncEnumerable<string> GetDataAsync([EnumeratorCancellation] CancellationToken ct = default)
{
for (int i = 1; i <= 5; i++)
{
await Task.Delay(1000, ct); // 模拟异步延迟
yield return $"Item {i}";
}
}
如何消费 IAsyncEnumerable？
使用 await foreach 来安全地异步遍历数据流：
AI舌诊面诊问诊医疗系统+诊疗商城系统源码
下载
AI 舌诊面诊问诊医疗系统 + 诊疗商城系统源码是一套结合 AI 辅助诊断与商品转化的健康类程序，基于浩创云、ThinkPHP（PHP）开发，支持微信服务号与 H5 端，适合做中医舌诊面诊问答、健康建议推送以及配套诊疗商品的运营。
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 让你在处理数据流时更高效、更可控，尤其适合高吞吐或资源受限的环境。合理使用它可以避免内存暴增和线程阻塞问题。
