如何通过C# Parallel.ForEach实现任务并行化 - 问答

在C#中，Parallel.ForEach是一种用于并行执行集合中每个元素的方法。它可以在多核处理器上创建并行操作，从而提高程序的执行速度。以下是如何使用Parallel.ForEach实现任务并行化的步骤：

首先，确保你的项目引用了System.Threading.Tasks命名空间。
创建一个要并行处理的数据集合。这可以是一个数组、列表或其他实现了IEnumerable接口的类型。
使用Parallel.ForEach方法遍历集合中的每个元素。你可以提供一个初始化函数，该函数在循环开始前执行一次。你还可以提供一个结束后的操作，该操作在所有元素都处理完毕后执行。
在循环体内，编写处理每个元素的代码。由于Parallel.ForEach是并行执行的，因此元素的处理顺序可能与它们在集合中的顺序不同。

下面是一个简单的示例，演示了如何使用Parallel.ForEach将一个整数列表中的每个元素乘以2：

using System;
using System.Collections.Generic;
using System.Threading.Tasks;

class Program
{
    static void Main()
    {
        // 创建一个整数列表
        List<int> numbers = new List<int> { 1, 2, 3, 4, 5 };

        // 使用Parallel.ForEach遍历列表中的每个元素
        Parallel.ForEach(numbers, (number, state, index) =>
        {
            // 将每个元素乘以2
            int doubled = number * 2;

            // 输出处理后的元素
            Console.WriteLine($"Processed {number}: {doubled}");
        });

        // 等待所有并行操作完成
        Console.WriteLine("All parallel operations completed.");
    }
}

在这个示例中，Parallel.ForEach方法接受三个参数：要处理的数据集合、一个lambda表达式，该表达式定义了如何处理每个元素，以及一个可选的状态参数。状态参数允许你在并行操作之间传递信息，但在本例中我们没有使用它。

请注意，Parallel.ForEach并不保证元素的处理顺序。如果你需要按特定顺序处理元素，可以考虑使用Parallel.ForEach的替代方法，如PLINQ（并行LINQ），它允许你指定元素的顺序。然而，PLINQ主要用于查询操作，而不是用于修改集合中的元素。在这种情况下，你可能需要使用其他方法，如Task和async/await，来实现并行处理。

0 赞

0 踩