C#并行计算测试

超、凢脫俗 2022-08-10 12:41 166阅读 0赞

using System.Threading.Tasks;
    
        class Program
        {
            static void Main(string[] args)
            {
                //aa();
                //bb();
    
                //Parallel.For(0, 100, (x) => //结束索引不包含在内
                //{
                //    Console.WriteLine(x);
                //});
    
                var list = GetProcuctList();
                Parallel.For(0, 100, (x, loopstate) =>
                {
                    if (x < 50)
                        Console.WriteLine(x);
                    else
                    {
                        loopstate.Break();
                        return;
                    }
                });
    
                Console.ReadKey();
            }
    
            private static void aa()
            {
                List<int> arrlist = new List<int>();
    
                Enumerable.Range(0, 100)
                .AsParallel()
                .ForAll((x) =>
                {
                    if (x % 2 == 0 && (x + 1) % 3 == 0)
                    {
                        arrlist.Add(x);
                    }
                });
    
                arrlist.ForEach((x) => Console.WriteLine(x));
            }
    
            private static void bb()
            {
                List<Product> ProductList = GetProcuctList();
                Parallel.ForEach(ProductList, (model) =>
                {
                    Console.WriteLine(model.Name);
                });
            }
    
            private static List<Product> GetProcuctList()
            {
                List<Product> result = new List<Product>();
                for (int index = 1; index < 100; index++)
                {
                    Product model = new Product();
                    model.Category = "Category" + index;
                    model.Name = "Name" + index;
                    model.SellPrice = index;
                    result.Add(model);
                }
                return result;
            }
        }
    
        class Product
        {
            public string Name { get; set; }
            public string Category { get; set; }
            public int SellPrice { get; set; }
        }

调用Stop，表示Parallel.For的执行立刻停止，无论其他执行单元是否达到停止的条件。而如果我们使用Break，则表示满足条件的当前执行单元立刻停止，而对于其他执行单元，其中满足停止条件也会通过Break停止，其他未满足停止条件的则会继续执行下去，从而全部执行完毕，自然停止。当所有执行单元停止后，Parallel.For函数才停止执行并退出。

[break][]类似于for的[continue][],而stop就类似于for的break。

下面内容摘录于MSDN：

**为每个值调用一次body 委托，在迭代范围 (fromInclusive，toExclusive) 。 其具有以下参数：迭代次数 (Int32) 以及可用来提前退出循环的 ParallelLoopState 实例。  
在当前迭代不必执行后，调用 Break 方法通知 for 操作迭代。 但是，当前迭代之前的所有迭代如果尚未执行，则仍需要执行。  
因此，调用 Break 与 C\# 等语言的传统for循环中使用中断操作类似，但这不是理想的替代，因为不能保证当前迭代之后的迭代都不会执行。  
如果在当前迭代不需要之前执行所有迭代，请使用 Stop 方法而不是使用 Break。 调用 Stop将通知 for 循环它可能放弃所有剩余迭代，  
无论它们是位于当前迭代的上方还是下方，因为所有必需的工作已经都完成。 但是对于Break，没有关于不执行其他迭代的任何保证。  
当循环已提前结束时，返回的 ParallelLoopResult 结构将包含有关循环完成的相关信息。  
如果 fromInclusive 大于或等于 toExclusive，则该方法立即返回，而无需执行任何迭代。**

[break]: http://www.cxyclub.cn/Tag/break.html
[continue]: http://www.cxyclub.cn/Tag/continue.html