c# 并行运算

标签：hex   ack   private   处理   padding   stack   round   顺序   列排序   

使用System.Collections.Concurrent命名空间下的类型来用于并行循环体内：

1. /// <summary>
2.         /// 并行循环操作集合类,集合内只取5个对象
3.         /// </summary>
4.         private void Demo7()
5.         {
6.             ConcurrentQueue<int> data = new ConcurrentQueue<int>();
7.             Parallel.For(0, Program.Data.Count, (i) =>
8.             {
9.                 if (Program.Data[i] % 2 == 0)
10.                     data.Enqueue(Program.Data[i]);//将对象加入到队列末尾
11.             });
12.             int R;
13.             while (data.TryDequeue(out R))//返回队列中开始处的对象
14.             {
15.                 Console.WriteLine(R);
16.             }
18.             Console.WriteLine("执行完成For.");
19.         }
21.         /// <summary>
22.         /// 并行循环操作集合类
23.         /// </summary>
24.         private void Demo8()
25.         {
26.             ConcurrentStack<int> data = new ConcurrentStack<int>();
27.             Parallel.ForEach(Program.Data, (i) =>
28.             {
29.                 if (Program.Data[i] % 2 == 0)
30.                     data.Push(Program.Data[i]);//将对象压入栈中
31.             });
32.             int R;
33.             while (data.TryPop(out R))//弹出栈顶对象
34.             {
35.                 Console.WriteLine(R);
36.             }
38.             Console.WriteLine("执行完成ForEach.");
39.         }

PLinq（Linq的并行计算）

    上面介绍完了For和ForEach的并行计算盛宴，微软也没忘记在Linq中加入并行计算。下面介绍Linq中的并行计算。

4.0中在System.Linq命名空间下加入了下面几个新的类：

在ParallelEnumerable中提供的并行化的方法

1. /// <summary>
2.         /// PLinq简介
3.         /// </summary>
4.         private void Demo11()
5.         {
6.             var source = Enumerable.Range(1, 10000);
8.             //查询结果按source中的顺序排序
9.             var evenNums = from num in source.AsParallel().AsOrdered()
10.                        where num % 2 == 0
11.                        select num;
13.             //ForAll的使用
14.             ConcurrentBag<int> concurrentBag = new ConcurrentBag<int>();
15.             var query = from num in source.AsParallel()
16.                         where num % 10 == 0
17.                         select num;
18.             query.ForAll((e) => concurrentBag.Add(e * e));
19.         }

c# 并行运算

标签：hex   ack   private   处理   padding   stack   round   顺序   列排序   

原文地址：https://www.cnblogs.com/mrray/p/10782779.html