能否将LINQ与异步(async)结合实现异步流？

嘿，这个需求很常见！其实你可以借助.NET的System.Linq.Async包，把现有逻辑整合成更简洁的“异步流”风格LINQ查询，既保留异步操作的优势，又让代码更连贯。

第一步：准备依赖 #

首先需要安装System.Linq.Async NuGet包，它提供了针对异步可枚举类型的LINQ扩展方法，这是实现异步流LINQ的核心：

Install-Package System.Linq.Async
# 或者用.NET CLI
dotnet add package System.Linq.Async

方式1：保持并行执行（和原Task.WhenAll效果一致） #

如果你想保留原代码中所有任务并行启动的特性，可以用AsyncEnumerable的扩展方法把整个流程串成单一查询：

using System.Linq;
using System.Linq.Async;

// 整合后的单一LINQ查询
var results = await inputs.ToAsyncEnumerable()
    .SelectAwait(async input =>
    {
        var x = await Foo(input);
        var y = await Bar(x);
        var z = await Baz(y);
        return z;
    })
    .ToArrayAsync();

这段代码和你原来的Task.WhenAll逻辑完全等价：所有输入对应的异步任务会同时启动，最后等待全部完成并返回结果数组。

方式2：更紧凑的链式异步调用 #

如果你想把Foo→Bar→Baz的链式调用也融入LINQ风格，还可以进一步拆解（虽然可读性见仁见智，但确实更“流式”）：

var results = await inputs.ToAsyncEnumerable()
    .SelectAwait(async input => await Foo(input))
    .SelectAwait(async x => await Bar(x))
    .SelectAwait(async y => await Baz(y))
    .ToArrayAsync();

注意：这种写法依然是并行执行所有输入的完整链路（每个输入的Foo/Bar/Baz是串行，但不同输入之间是并行），和原逻辑一致。

可选：控制并发或顺序执行 #

如果需要限制并发数或者按顺序处理每个输入，可以搭配ConfigureAwait(false)和AsSequential()：

// 按顺序处理每个输入（串行执行）
var results = await inputs.ToAsyncEnumerable()
    .AsSequential()
    .SelectAwait(async input =>
    {
        var x = await Foo(input).ConfigureAwait(false);
        var y = await Bar(x).ConfigureAwait(false);
        var z = await Baz(y).ConfigureAwait(false);
        return z;
    })
    .ToArrayAsync();

为什么这能行？ #

ToAsyncEnumerable()把普通的输入集合转换成IAsyncEnumerable<T>，这是.NET中异步流的核心类型。之后的SelectAwait允许你在LINQ查询中嵌入异步操作，最后ToArrayAsync()（或ToListAsync()）会等待所有异步操作完成并收集结果，效果和Task.WhenAll一致，但写法更贴近“流式”LINQ的风格。

内容的提问来源于stack exchange，提问作者user7127000