C# Parallel之for,foreach使用（笔记）

　　C# 4.0 的新特性之并行库（TPL）， 是 .NET Framework 4的 System.Threading 和 System.Threading.Tasks 命名空间中的一组公共类型和 API,基本包含以下几点：

Parallel.For - for 循环的并行运算

Parallel.ForEach - foreach 循环的并行运算

Parallel.Invoke - 并行调用多个任务

Task - 任务，基于线程池。其使我们对并行编程变得更简单，且不用关心底层是怎么实现的

PLINQ - 用于对内存中的数据做并行运算，也就是说其只支持 LINQ to Object 的并行运算

　　今天先记录以下For,ForEach的基本使用，也是最常用到的。方便自己使用。

　　1.如果遍历集合里面的元素，做没有关系的处理时：

　　　　For：

public static class ParallelFor_narmal
{
// 每个之间独立，不需要交互
public static void narmal()
{
int[] arry = { 1, 2, 3, 4, 5, 6, 7, 8, 9 };

Parallel.For(0,arry.Length,(i,loopstate)=>
{
Console.Out.WriteLine(arry[i]);
});
}
}

　　　　ForEach的情况差不多，这种情况是最简单的。其实也就可以使用泛型集合的ForEach(Action(T))方法了.

　　2.如果集合里面的元素处理是有关联的，比如求和，但是并发是多线程的，按照传统的集合遍历肯定是有问题的，这个时候就需要了局部变量了。

　　　　For：　

public static long withlocalvariable()
{

// int[] nums = Enumerable.Range(0, 1000000).ToArray();
int[] nums = { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30 };
long total = 0;
object lockflg = new object();

// Use type parameter to make subtotal a long, not an int
// 带有局部变量的并发。
// 第一个参数是for循环的起始迭代位置
// 第二个参数是for循环的终了迭代位置
// 第三个参数是局部变量的初始化。Func(T)。 这里就是给每个线程局部变量subtotal初始化为0;
// 第四个参数就是每个线程的执行的方法体。原型为Func(int,ParallelLoopState,T,B)，具有三个入力参数和一个返回值的代理。
//                其中j是运行时自动提供的迭代值，loop是用来控制循环的中断，subtotal就是局部变量，最有有一个返回值。
// 第五个参数为具有一个入力参数，没有返回值的代理Action(T)，用来处理每个线程的返回的结果。因为是多线程处理，所有要注意线程安全
Parallel.For<long>(0, nums.Length, () => 0, (j, loop, subtotal) =>
{
subtotal += nums[j];
return subtotal;
},
(x) =>
{ //Interlocked.Add(ref total, x);
lock (lockflg)
{
total += x;
}

}
);

return total;
}

　　　　ForEach：

public static class ParallelForEach_WithLocalVariable
{
public static long withlocalvariable()
{
int[] nums = { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30 };
long total = 0;
object lockflg = new object();

//  ForEach<int, long> 第一个参数指定源元素的类型，此处的j，第二个参数指定线程本地变量的类型,此处的subtotal
Parallel.ForEach<int, long>(nums,  // 数据源
() => 0, // subtotal初始化
(j, loop, subtotal) =>{ subtotal +=j;return subtotal;}, // 每个线程执行的方法体
(x) =>{lock (lockflg) { total += x; }});  // 处理每个结果

return total;
}
}

　　　　　　这两种情况是最长使用到了，其实还有更细致的控制操作，有兴趣的可以看看 数据并行（任务并行库）