.NET中的IAsyncEnumerable是什么？如何异步地处理数据流？

IAsyncEnumerable 是 .NET 中用于表示可异步枚举的流式数据集合的接口，它允许你一边异步获取数据，一边处理这些数据，而不需要等待整个集合加载完成。这在处理大量数据、文件读取、网络流、数据库查询或实时数据推送等场景中非常有用。

为什么需要 IAsyncEnumerable？

传统的 IEnumerable 在遍历数据时是同步的，如果每条数据的获取涉及 I/O 操作（如从网络或磁盘读取），就会阻塞线程。而 IAsyncEnumerable 结合 await foreach，可以实现非阻塞式的数据流处理，提升响应性和资源利用率。

如何使用 IAsyncEnumerable？

定义一个返回 IAsyncEnumerable 的方法，通常使用 async 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 来安全地异步遍历数据流：

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 秒后自动取消枚举。

常见应用场景

EF Core 示例：

await foreach (var user in dbContext.Users
    .AsAsyncEnumerable()
    .WithCancellation(ct))
{
    Console.WriteLine(user.Name);
}

基本上就这些。IAsyncEnumerable 让你在处理数据流时更高效、更可控，尤其适合高吞吐或资源受限的环境。合理使用它可以避免内存暴增和线程阻塞问题。