Parallel.ForEach - 并行处理

📅 2026/7/4 9:32:05
Parallel.ForEach - 并行处理
Parallel.ForEach是 C# 中System.Threading.Tasks.Parallel类提供的一个方法用于并行地迭代集合中的每一个元素。Parallel.ForEach方法允许多个线程同时处理集合中的元素从而提高程序的执行效率特别是在处理大量数据或执行耗时任务时。语法Parallel.ForEach的基本语法如下Parallel.ForEach(source,body);其中source要迭代的集合。body一个委托定义了对集合中每个元素的操作。设置最大并行度示例中Parallel.ForEach方法还接收了一个ParallelOptions对象用于设置并行执行的选项。特别地MaxDegreeOfParallelism属性指定了同时执行的最大线程数。在这个例子中MaxDegreeOfParallelism被设置为 16这意味着最多同时有 16 个线程并行执行。示例代码下面是提供的代码示例的完整形式usingSystem;usingSystem.Diagnostics;usingSystem.Threading.Tasks;classProgram{staticvoidMain(){vartPAgvTasksListnew[]{1,2,3,4,5,6,7,8,9,10};// 示例数据// 并行迭代 tPAgvTasksList 集合中的每一个元素Parallel.ForEach(tPAgvTasksList,newParallelOptions(){MaxDegreeOfParallelism16},item{// 代码块Console.WriteLine($Processing item{item}on thread{Thread.CurrentThread.ManagedThreadId});DoSomeWork(item);});Console.WriteLine(All tasks completed.);}staticvoidDoSomeWork(intitem){// 模拟耗时操作Thread.Sleep(1000);}}解释Parallel.ForEach 方法Parallel.ForEach方法接收三个参数一个集合tPAgvTasksList一个ParallelOptions对象以及一个 Lambda 表达式来定义每个元素的处理逻辑。ParallelOptions 对象new ParallelOptions() { MaxDegreeOfParallelism 16 }设置并行执行的最大线程数为 16。这意味着在任何时刻最多有 16 个线程在执行。Lambda 表达式item { /* 代码块 */ }定义了对集合中每个元素item的处理逻辑。在这个例子中每个元素被打印出来并执行了一个模拟的耗时操作DoSomeWork。DoSomeWork 方法DoSomeWork方法模拟了一个耗时的操作比如数据库访问、文件读写或其他 I/O 操作。优点使用Parallel.ForEach的主要优点包括提高性能通过并行处理多个任务可以显著提高程序的执行效率。简化编程模型无需显式管理线程Parallel.ForEach自动管理线程池中的线程。注意事项资源竞争如果并行度设置过高可能会导致系统资源如 CPU 时间片、内存的竞争反而降低程序性能。线程安全在并行执行时需要注意对共享资源的访问避免竞态条件race condition。可以使用锁lock、原子操作Interlocked类或其他并发集合如ConcurrentQueue来保证线程安全。异常处理并行任务中发生的异常不会立即抛出而是被捕获并在所有任务完成后统一处理。可以通过Parallel.ForEach的重载版本添加异常处理逻辑。总结Parallel.ForEach提供了一种简便的方法来并行处理集合中的元素通过设置MaxDegreeOfParallelism可以控制并行执行的最大线程数。这种技术非常适合处理大规模数据集或执行耗时的任务可以显著提升程序的性能。