.NET 4.8.2中Parallel.ForEach与Task.Run、await的协同优化问题

线程ID异常的原因 #

1. await的等待特性：await Task.Run(...)会暂停当前方法执行，直到Task.Run内部的Parallel.ForEach任务完全结束后，才会恢复后续代码运行。这就是主线程会等待并行任务完成才进入while循环的原因，属于await的正常行为。
2. 同步上下文的切换：await默认会捕获当前执行上下文（比如UI线程上下文、ASP.NET请求上下文）。当Task.Run的任务完成后，await会尝试回到原上下文执行后续代码。如果是控制台程序（无同步上下文），后续代码会在线程池的某个线程上运行，导致线程ID与原主线程不一致；如果是带同步上下文的程序（如WinForms），会回到原上下文线程，线程ID不变，但依然会等待任务完成。

正确的代码优化方案 #

你的核心需求是让Parallel.ForEach在后台并行执行，主线程直接进入while循环继续工作，无需等待任务结果。这种场景下不需要使用await，直接让任务后台运行即可，同时要补充异常处理避免程序崩溃。

基础优化代码 #

// 启动后台并行任务，不等待其完成
_ = Task.Run(() =>
{
    var items = new List<int> { 1, 2, 3, 4, 5 };
    Parallel.ForEach(items, item =>
    {
        // 模拟CPU/IO密集型任务
        Thread.Sleep(1000);
        Console.WriteLine($"并行任务执行线程ID: {Thread.CurrentThread.ManagedThreadId}");
    });
});

// 主线程直接进入循环，与后台任务并行执行
while (true)
{
    Console.WriteLine($"主线程循环执行线程ID: {Thread.CurrentThread.ManagedThreadId}");
    Thread.Sleep(500);
}

异常处理补充（关键） #

在.NET Framework 4.8.2中，未被捕获的Task异常会导致程序崩溃。如果后台任务可能抛出异常，需要添加异常处理逻辑：

_ = Task.Run(() =>
{
    var items = new List<int> { 1, 2, 3, 4, 5 };
    Parallel.ForEach(items, item =>
    {
        if (item == 3)
            throw new InvalidOperationException("并行任务出错");
            
        Thread.Sleep(1000);
        Console.WriteLine($"并行任务执行线程ID: {Thread.CurrentThread.ManagedThreadId}");
    });
}).ContinueWith(task =>
{
    // 仅在任务出错时执行
    if (task.Exception != null)
    {
        // 处理异常，比如写入日志
        Console.WriteLine($"后台任务异常: {task.Exception.InnerException.Message}");
    }
}, TaskContinuationOptions.OnlyOnFaulted);

关于await的认知纠正 #

await的作用是等待任务完成并处理后续逻辑（或获取结果），并非所有Task都必须使用await。当你不需要等待任务完成，仅需让它在后台执行时，直接启动任务即可，这完全符合异步编程的设计逻辑，不存在“不符合await使用认知”的问题。

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