C#中多线程异步操作的方法-Parallel.ForEachAsync

1. 核心概念Parallel.ForEachAsync是在.NET 6中引入的方法。它的核心作用是对一组数据执行异步操作并且同时控制并发数量也就是同时跑多少个任务。它完美解决了两个痛点传统的Parallel.ForEach不支持async/await它是为阻塞式 CPU 任务设计的。直接用Task.WhenAll(tasks)会一次性把所有任务扔出去如果数据有 10 万条会瞬间耗尽内存或网络端口。2. 基本语法与关键参数publicstaticTaskForEachAsyncTSource(thisIEnumerableTSourcesource,ParallelOptionsparallelOptions,FuncTSource,CancellationToken,ValueTaskbody)关键参数说明source数据源如数组、List、或你用Chunk()切分出的块。parallelOptions并行配置项极其重要包含两个核心属性MaxDegreeOfParallelism最大并发数。比如设为 5表示最多同时运行 5 个异步任务完成一个再补一个。CancellationToken取消令牌用于中途终止所有并发任务。body要执行的异步逻辑注意返回类型是ValueTask不是Task性能更好。3. 经典示例示例 1批量并发下载网页/API请求最常见场景假设我们要下载 100 个网页如果串行可能需要 1 分钟但如果同时开 10 个并发只需 6 秒。usingSystem.Net.Http;ListstringurlsGetUrls();// 假设有 100 个 URLusingHttpClientclientnewHttpClient();// 配置并行选项最大并发 10varoptionsnewParallelOptions{MaxDegreeOfParallelism10};Console.WriteLine(开始并发下载...);awaitParallel.ForEachAsync(urls,options,async(url,ct){try{// 传入 ct如果外部取消当前请求会立即中止stringcontentawaitclient.GetStringAsync(url,ct);Console.WriteLine($成功下载{url}长度:{content.Length});}catch(OperationCanceledException){// 被取消}catch(Exceptionex){Console.WriteLine($下载失败{url}:{ex.Message});}});Console.WriteLine(全部下载完成。);示例二收集结果ForEachAsync 本身没有返回值返回 Task如果需要收集处理结果必须使用线程安全集合如 ConcurrentBag 或 ConcurrentQueue。**usingSystem.Collections.Concurrent;usingSystem.Diagnostics;publicstaticasyncTaskExample_WithResultCollection(){varinputsEnumerable.Range(1,10);varresultsnewConcurrentBagint();// 线程安全集合awaitParallel.ForEachAsync(inputs,asynci{awaitTask.Delay(100);// 模拟耗时操作intresulti*i;// 计算逻辑results.Add(result);// 并发添加结果线程安全Console.WriteLine(${DateTime.Now:mm:ss:fff}- 处理{i});});Console.WriteLine($结果数量:{results.Count});}示例三配合取消令牌在用户关闭窗口或点击“停止”按钮时优雅地停止处理。publicstaticasyncTaskExample_WithCancellation(CancellationTokencts){varrangeEnumerable.Range(0,1000);try{awaitParallel.ForEachAsync(range,newParallelOptions{CancellationTokencts,MaxDegreeOfParallelism10},async(i,ct){// 如果外部取消这里会抛出 OperationCanceledExceptionawaitTask.Delay(100,ct);Console.WriteLine($处理中:{i});});}catch(OperationCanceledException){Console.WriteLine(任务被用户取消。);}}4. 核心优势对比表特性foreachawaitTask.WhenAllParallel.ForEachAsync执行方式串行一个接一个全量并发同时启动所有可控并发池化执行内存/资源占用极低极高容易内存溢出/端口耗尽适中按需启动总耗时最长最短如果不崩溃的话较短与并发数成正比支持取消支持支持完美支持5. 注意事项与避坑指南必须限制并发数不设置MaxDegreeOfParallelism时默认可能会使用处理器数量作为并发度。对于网络请求建议显式设置为5到20之间根据目标服务器的承受能力和你的网络带宽决定防止把对方服务器打挂或触发对方防爬机制被封 IP。线程安全问题最容易踩的坑在并发环境下Parallel.ForEachAsync的内部相当于多线程同时运行。如果你在里面修改了 UI 绑定的集合如ObservableCollection或普通的计数字典极大概率会报错或数据错乱。集合操作使用ConcurrentDictionary或ConcurrentBag或者用lock。UI 更新如果要在里面更新 WPF/WinForms 的 UI需要使用Dispatcher.Invoke。异常处理如果在循环体内抛出异常且未 catch 吞掉Parallel.ForEachAsync会将异常包装进AggregateException抛出。如果你想让某个任务失败不影响其他任务就在循环体内部try-catch吞掉单次异常。如果收到CancellationToken必须立即停止并抛出OperationCanceledException。