使用.NET并行任务库(TPL)与并行Linq(PLINQ)充分利用多核性能

转载 作者：撒哈拉 更新时间：2024-09-25 12:22:49 55 4

 //创建顺序执行方法
 static List<dynamic> AddModelSequential(int modelCount)
 {
     var list = new List<dynamic>();
     //为了增加循环复杂性,里面嵌套一个循环
     for (int i = 0; i < modelCount; i++)
     {
         int f = 0;
         for (int j = 0; j < 5000; j++)
         {
             f++;
         }
         list.Add(new { bbb = i, aaa = "1", ccc = f });
     }
     return list;
 }
 //创建并行执行方法
 static List<dynamic> AddModelParallel(int modelCount)
 {
     var list = new List<dynamic>();
     Parallel.For(0, modelCount, i =>
     {
         int f = 0;
         //为了增加循环复杂性,里面嵌套一个循环
         for (int j = 0; j < 5000; j++)
         {
             f++;
         }
         list.Add(new { bbb = i, aaa = "1",ccc= f});
     });
     return list;
 }

 static void Main(string[] args)
 {

     Console.Error.WriteLine("执行顺序循环...");
     Stopwatch stopwatch = new Stopwatch();
     stopwatch.Start();

     AddModelSequential(1000000);
     stopwatch.Stop();
     Console.Error.WriteLine("顺序循环时间（毫秒）: {0}",
                             stopwatch.ElapsedMilliseconds);

     stopwatch.Reset();
     Console.Error.WriteLine("执行并行循环...");
     stopwatch.Start();
     AddModelSequential(100000);
     stopwatch.Stop();
     Console.Error.WriteLine("并行循环时间（毫秒）: {0}",
                             stopwatch.ElapsedMilliseconds);
     Console.ReadLine();
 }

//LINQ
var results = from item in dataSource
              where item.SomeCondition()
              select item.SomeTransformation();
//PLINQ
var parallelResults = from item in dataSource.AsParallel()
                      where item.SomeCondition()
                      select item.SomeTransformation();

55 4 0

• c# - Plinq 里面的 Plinq？

  假设我有一个 DataTable。 var dt = getDataTable(); 然后我做 Parallel.For (0, dt.Rows.Count, i => Foo (dt.Rows[i]

• c# - PLINQ 与 LINQ : OutOfMemoryException for LINQ but not PLINQ

  很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈，无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开，visit the help center . 关闭 1

• .net - PLINQ 更新失败

  对不起我的英语不好。所以，这是我的问题 我正在尝试通过 PLINQ 更新 DataTable 这是我的代码 DataTable table = new DataTable(); table.Colum

• c# - 单核 Plinq？

  据我了解: Programming to leverage multicores or multiple processors is called parallel programming. 但是如果

• .net - PLINQ 有异步版本吗？

  我想对数据流执行查询，同时以一定程度的并行性并行处理项目。通常，我会使用 PLINQ，但我的工作项不受 CPU 限制，而是 IO 限制。我想使用异步IO。 PLINQ 不支持异步工作。 使用异步工作项

• c# - 单核 Plinq？

  据我了解: Programming to leverage multicores or multiple processors is called parallel programming. 但是如果

• c# - PLINQ 真的不保留顺序吗？

  在MSDN据说 PLINQ 不保留顺序。我想在我的项目中演示它，但我有一个问题，那就是始终保持秩序。我有一个收藏List> table这些是我的疑问: var linqQuery = table

• c# - PLinq 的存储库模式

  我对 Plinq 和 Repo 模式还很陌生。我需要您提供一些引用资料和指南，以便在 fx 4.0 中使用 dbml、PLinq 实现存储库模式 最佳答案 存储库模式为您提供了对数据存储的抽象。如果带

• c# - 单核处理器上的 PLinq

  假设您正在查询具有一百万条记录的集合，当您只有一个 CORE 处理器时，PLINQ 的性能是否与普通的 LINQ 查询有任何不同。 我知道 PLINQ 在多核处理器上工作得很好。只是想了解它在单个核心

• c# - PLINQ 异常

  我正在使用带有以下代码的 PLINQ: static void Main(string[] args) { var lt = new List() {1,2,3,4,5};

• c# - PLINQ 性能不佳

  我正在尝试实现 PLINQ 示例但面临以下问题我的顺序查询比并行查询执行得更快。 这里是代码示例: Stopwatch sw = new Stopwatch(); in

• c# - PLINQ 查询中的评估顺序是什么？

  下面是我在 Windows 服务中定期运行的示例 PLINQ 查询: var resultList = new List>(); try { resultList = emailsToSend

• c# - PLINQ 没有提高性能

  我写了一个 LINQ 来找出文本文件中唯一字符的频率。我还在 select 的帮助下将我的初始结果转换为一个对象。最终结果以列表的形式出现。以下是我使用的查询。 charNodes = inputSt

• c# - PLINQ 是否保留序列中的原始顺序？

  PLINQ 是否保证按照原始序列被操作的顺序返回查询结果，即使结果是并行产生的？例如: new List(){"a", "b", "c", "d"}.asParallel().Select(str =

• c# - 利用带有自定义可枚举扩展的 PLINQ

  许多自定义 Enumerable 扩展可以根据其他内置操作来实现 - 例如这个简单的便捷方法: public static bool AnyOf(this TElement item, IEnumer

• c# - PLINQ 查询给出溢出异常

  我正在运行一个 PLINQ 查询，如下所示: ParallelQuery winningCombos = from n in nextComboMaker.GetNextCombo()

• c# - Plinq 语句在静态构造函数中陷入僵局

  我遇到过静态构造函数中的以下 plinq 语句陷入僵局的情况: static void Main(string[] args) { new Blah(); } class Blah {

• c# - PLINQ 有什么真正的好处吗？

  最近我对 Linq 和 Plinq 做了一些测量。我看不出 Plinq 在哪种情况下具有真正显着的优势。 我发现了很多例子，例如: Enumerable.Range(0, 10000).AsParal

• c# - 究竟什么是 PLINQ？

  PLINQ 作为 LINQ 的扩展被添加到 .NET 4.0 Framework 中。 这是什么？ 它解决了什么问题？ 什么时候合适，什么时候不合适？ 最佳答案 这是并行 LINQ。这是一种在多核/多

• C# PLINQ 内存列表查询优化历程

  产品中（基于ASP.NET MVC开发）需要经常对药品名称及名称拼音码进行下拉匹配及结果查询。为了加快查询的速度，所以我最开始就将其加入内存中（大约有六万五千条数据）。 下面附实体类。