关于Linq Select中Task.Run执行时机与并行逻辑的技术问询

我希望理解Linq Select中Task.Run的执行逻辑，以下是相关代码：

IEnumerable<Task<ValidationResult>> processWorkSheetTasks = workBook
    .Worksheets
    .Select(worksheet => Task.Run(() => SomeCPUBoundWork(worksheet)));  

try
{
    var results = await Task.WhenAll(processWorkSheetTasks);
}
catch (Exception)
{
    IEnumerable<AggregateException> exceptions = processWorkSheetTasks
        .Where(executedTask => executedTask.Exception != null)
        .Select(executedTask => executedTask.Exception);

    throw new AggregateException(exceptions);
}

按认知，Task.Run应立即将SomeCPUBoundWork排入线程池执行，并返回Task句柄，这是否意味着SomeCPUBoundWork会与主线程执行的Select语句并行？但调试发现，SomeCPUBoundWork内的断点要在执行完await Task.WhenAll(processWorkSheetTasks)后才触发，对此我感到困惑，恳请解释Linq中Task.Run的工作机制。

核心原因：LINQ的延迟执行特性 #

你遇到的问题根本不是Task.Run的逻辑问题，而是LINQ IEnumerable的延迟执行机制在起作用：

• processWorkSheetTasks是一个IEnumerable<Task<ValidationResult>>，这只是一个查询定义，而非查询结果。Select里的委托（即Task.Run(...)代码）并不会在定义查询时执行，只有当你枚举这个集合时才会逐个触发。
• 第一次枚举发生在await Task.WhenAll(processWorkSheetTasks)执行时：Task.WhenAll需要遍历所有任务来等待完成，此时才会逐个调用Select里的逻辑，创建Task并将SomeCPUBoundWork排入线程池。
• 这就是调试断点延迟触发的原因：在await Task.WhenAll之前，Select里的Task.Run根本没被调用过，自然没有任务启动。

纠正认知偏差 #

你的理解没错：Task.Run确实会在被调用时立即将工作项排入线程池并返回Task句柄。但问题是，你定义的LINQ查询并没有立刻执行Task.Run，只是定义了“当需要时如何创建Task”的规则。

如何让任务立即启动？ #

如果你希望在定义查询时就启动所有Task（和主线程后续代码并行），只需把IEnumerable转成立即执行的集合（比如List或Array）：

// 用ToList()强制立即执行Select，创建所有Task并启动
List<Task<ValidationResult>> processWorkSheetTasks = workBook
    .Worksheets
    .Select(worksheet => Task.Run(() => SomeCPUBoundWork(worksheet)))
    .ToList();  

这样，Select里的Task.Run会在调用ToList()时立刻全部执行，任务被排入线程池并行运行，主线程可继续执行后续代码，直到await Task.WhenAll时等待所有任务完成。

原代码的额外问题：catch块逻辑错误 #

你代码中的catch块存在严重问题：再次枚举processWorkSheetTasks时，会重新执行一遍Select逻辑，创建一批全新的Task，而非原来那些已经执行过的任务。这批新任务未被执行，Exception属性自然为null，因此catch块永远拿不到真正的异常。

正确做法是先将任务存入立即执行的集合，再在catch块中使用该集合：

List<Task<ValidationResult>> processWorkSheetTasks = workBook
    .Worksheets
    .Select(worksheet => Task.Run(() => SomeCPUBoundWork(worksheet)))
    .ToList();  

try
{
    var results = await Task.WhenAll(processWorkSheetTasks);
}
catch
{
    var exceptions = processWorkSheetTasks
        .Where(t => t.Exception != null)
        .Select(t => t.Exception);

    throw new AggregateException(exceptions);
}

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