C#学习笔记三:数据并行

学习资料http://msdn.microsoft.com/zh-cn/library/vstudio/dd537608(v=vs.100).aspx

数据并行是指对源集合或数组中的元素同时(即并行)执行相同操作的情况。

 

简单的并行for循环

 Parallel.For(0, length, i =>
{
       //do something about i
});

 

并行foreach循环

C#学习笔记三:数据并行
            //  Method signature: Parallel.ForEach(IEnumerable<TSource> source, Action<TSource> body)
            Parallel.ForEach(files, currentFile =>
            {
                // The more computational work you do here, the greater 
                // the speedup compared to a sequential foreach loop.
                string filename = System.IO.Path.GetFileName(currentFile);
                System.Drawing.Bitmap bitmap = new System.Drawing.Bitmap(currentFile);

                bitmap.RotateFlip(System.Drawing.RotateFlipType.Rotate180FlipNone);
                bitmap.Save(System.IO.Path.Combine(newDir, filename));

                // Peek behind the scenes to see how work is parallelized.
                // But be aware: Thread contention for the Console slows down parallel loops!!!
                Console.WriteLine("Processing {0} on thread {1}", filename,
                                    Thread.CurrentThread.ManagedThreadId);

            } //close lambda expression
                 ); //close method invocation
C#学习笔记三:数据并行

 

并行时的break和continue

在使用并行for的时候,普通的break和continue在这里并没有太大作用。

取而代之的是stop和break方法。

在 Action<int, ParallelLoopState>等这样的action中,使用如下的代码可以实现stop和break:

C#学习笔记三:数据并行
            Parallel.For(0, source.Length, (i, loopState) =>
            {
                loopState.Stop();
            } // Close lambda expression.
            ); // Close Parallel.For
C#学习笔记三:数据并行
C#学习笔记三:数据并行
            Parallel.For(0, source.Length, (i, loopState) =>
            {
                double d = Compute(source[i]);
                results.Push(d);
                if (d > .2)
                {
                    // Might be called more than once!
                    loopState.Break();
                    Console.WriteLine("Break called at iteration {0}. d = {1} ", i, d);
                    Thread.Sleep(1000);
                }
            });
C#学习笔记三:数据并行

 

使用Stop的时候,系统将通知其他的并行线程在可能的时候尽快停止(不是保证立即停止,使用 ParallelLoopState.IsStopped检查是否已经停止)。

使用Break的时候,上面的0, source.Length(0到10000)一共被分成了4段:0 2500 5000 7500,当执行了break的时候,只有当前段会停止,其他段仍然会继续执行。

比如在0-2500段执行了break,不会影响到2500-5000段。

 

复杂一点的并行:带有线程局部变量

C#学习笔记三:数据并行
public static ParallelLoopResult For<TLocal>(int fromInclusive, int toExclusive, Func<TLocal> localInit, Func<int, ParallelLoopState, TLocal, TLocal> body, Action<TLocal> localFinally);
C#学习笔记三:数据并行

下例中的subtotal即为线程中的局部变量:

C#学习笔记三:数据并行
            Parallel.For<long>(0, nums.Length, () => 0, (j, loop, subtotal) =>
            {
                subtotal += nums[j];
                return subtotal;
            },
                (x) => Interlocked.Add(ref total, x)
            );
C#学习笔记三:数据并行


fromInclusive:
开始索引(含)。

toExclusive:
结束索引(不含)。

localInit:
用于返回每个任务的本地数据的初始状态的函数委托。

body:
将为每个迭代调用一次的委托。

localFinally:
用于对每个任务的本地状态执行一个最终操作的委托。

类型参数:
TLocal:
线程本地数据的类型。

 

第三个参数的类型为 Func<TResult>,其中 TResult 是将存储线程本地状态的变量的类型。 请注意,在此示例中使用了方法的泛型版本,并且类型参数为 long。类型参数告知编译器将要用于存储线程本地状态的临时变量的类型。 此示例中的 () => 0 表达式表示线程本地变量的初始值为零。如果是一个对象,是这样:() => new MyClass()。

 

如何:取消 Parallel.For 或 ForEach Loop

http://msdn.microsoft.com/zh-cn/library/vstudio/ee256691(v=vs.100).aspx

C#学习笔记三:数据并行

上一篇:解决PHP在IE中下载文件,中文文件名乱码问题


下一篇:VS的Release模式配置技巧