为什么 foreach 会卡住,而 await foreach 不会?
因为
IEnumerable<t></t>是同步拉取模型:每次调用
MoveNext()都得等结果回来,线程就停在那儿了;而
IAsyncEnumerable<t></t>是异步拉取,
MoveNextAsync()返回的是
ValueTask<bool></bool>,可以挂起、释放线程、等 I/O 就绪后再恢复——这正是处理文件、HTTP 响应、数据库游标时不会拖垮吞吐量的关键。 同步枚举(
IEnumerable)适合内存中已加载好的小集合,比如
List<int>.AsEnumerable()</int>异步枚举(
IAsyncEnumerable)适合数据源本身是异步的:文件流、网络分块响应、实时日志、gRPC 流式调用 强行把
IAsyncEnumerable转成
IEnumerable(比如用
.ToList().AsEnumerable())会立刻失去所有异步优势,还可能 OOM
怎么写一个真正能“流起来”的 IAsyncEnumerable 方法?
核心就三条:
async修饰符 +
yield return+ 异步等待(如
await reader.ReadLineAsync())。编译器会自动生成状态机,把每次
yield return和
await的上下文保存下来。
async IAsyncEnumerable<string> ReadLinesAsync(string path, CancellationToken ct = default)
{
await using var reader = new StreamReader(path);
string? line;
while ((line = await reader.ReadLineAsync(ct)) != null)
{
yield return line;
}
}
必须用 await using确保资源异步释放,否则可能泄漏文件句柄
CancellationToken要传给所有底层异步调用(如
ReadLineAsync(ct)),否则无法响应取消 别在
yield return后面写耗时同步代码(比如
Thread.Sleep(100)),它会阻塞整个流,破坏非阻塞性
await foreach 消费时,哪些坑会让异步流“变回同步”?
最常见的错误是「表面用了
await foreach,实际还是串行阻塞」。比如在循环体内做同步 I/O 或没开并发。 ❌ 错误示范:
await foreach (var line in ReadLinesAsync("log.txt"))
{
ProcessLineSync(line); // 这里是同步 CPU 密集操作,但没并行,流被拖慢
}
✅ 改进思路:用 Task.WhenAll批量并发处理,或配合
Channel<t></t>构建生产-消费管道 ⚠️ 注意:
await foreach本身不提供背压控制,如果生产快、消费慢,缓冲区可能暴涨——需要手动加限流(如
BufferBlock<t></t>或自定义
IAsyncEnumerable包装器)
IEnumerable 和 IAsyncEnumerable 能混用吗?
不能直接赋值或隐式转换。它们是完全不同的接口,运行时类型不兼容。LINQ 方法也得换——
System.Linq里的
Where、
Select对
IAsyncEnumerable无效,必须用
System.Linq.Async(NuGet 包
Microsoft.Bcl.AsyncInterfaces已内置)。 ❌
myAsyncStream.Where(x => x.Length > 10)→ 编译失败(缺少引用或 using) ✅ 正确写法:
using System.Linq.Async;
await foreach (var item in myAsyncStream.Where(x => x.Length > 10))
{
Console.WriteLine(item);
}
⚠️ ToHashSetAsync()、
ToListAsync()这类终结方法会把整个流收集成内存集合,慎用——除非你明确知道数据量可控 异步流不是“加个 async 就完事”,关键在让数据真正按需流动、线程按需释放。最容易忽略的是取消传播和资源异步释放,这两个点一漏,轻则响应迟钝,重则连接/句柄泄漏。
