IAsyncEnumerable<T> 是 .NET Core 3.0 引入的接口,用于异步枚举数据序列,支持 await foreach 实现非阻塞的数据流处理;通过 async IAsyncEnumerable 方法结合 yield return 可逐个产生数据,适用于网络、文件或数据库等异步数据源;相比 IEnumerable<T>,它节省内存、提升响应速度、支持取消操作,并可与 LINQ 集成,适合处理日志、传感器数据或分页 API 等实时场景。

在 C# 中,异步流(Async Streams)通过 IAsyncEnumerable<T> 接口来处理数据序列,特别适用于需要异步获取多个数据项的场景,比如从网络、文件或数据库中逐步读取数据。
使用 IAsyncEnumerable<T> 逐个异步产生数据
IAsyncEnumerable<T> 是 .NET Core 3.0 引入的接口,允许你以异步方式枚举数据序列。与传统的 IEnumerable<T> 不同,它支持 await foreach,能够在不阻塞线程的情况下逐个接收数据。
定义一个异步流的方法需返回 IAsyncEnumerable<T>,并使用 yield return 结合 await foreach 或异步逻辑:
async IAsyncEnumerable{
for (int i = 1; i <= 5; i++)
{
await Task.Delay(100); // 模拟异步操作
yield return i;
}
}
用 await foreach 消费异步流
调用方可以使用 await foreach 来消费异步流中的数据,语法类似于普通的 foreach,但不会阻塞主线程。
await foreach (var number in GenerateNumbersAsync()){
Console.WriteLine(number);
}
这种方式适合处理实时数据流,如日志条目、传感器数据或分页 API 响应。
异步流的优势和适用场景
异步流解决了传统集合在大数据量或高延迟 IO 场景下的内存和性能问题。
- 节省内存:不需要一次性加载所有数据到内存
- 响应更快:消费者可以立即处理第一批到达的数据
- 天然支持取消:可通过 CancellationToken 在遍历时中断流
- 与 LINQ 集成:C# 提供了 AsAsyncEnumerable 等扩展方法支持异步查询
基本上就这些。IAsyncEnumerable 让你在处理数据序列时既能保持异步优势,又能像操作集合一样自然。










