並行處理本地資料PLINQ

2022-09-06 15:15:15 字數 935 閱讀 4318

簡單介紹:

此處介紹的並行處理,主要是處理本地儲存的資料;當使用並行處理時,會把資料拆分為多個小塊,然後用多個執行緒處理這些小塊的資料,多執行緒處理後的資料再統一處理再返回;

以下是處理100萬陣列的資料量;**如下:

using system;

using system.collections.generic;

using system.diagnostics;

using system.linq;

using system.text;

using system.threading;

using system.threading.tasks;

namespace _console

public static void go()

stopwatch stopwatch = new stopwatch();

stopwatch.start();

var parallelresult = from n in array.asparallel()

where n % 2 > 0

select n;

long ddd = stopwatch.elapsedmilliseconds;

stopwatch.stop();

stopwatch.start();

var parallelresultlinq = from n in array

where n % 2 > 0

select n;

long ddd1 = stopwatch.elapsedmilliseconds;

stopwatch.stop();}}

}

執行的結果如下:

並行程式設計之PLINQ

並行 linq plinq 是linq 模式的並行實現。plinq 的主要用途是通過在多核計算機上以並行方式執行查詢委託來加快 linq to objects 查詢的執行速度。與順序linq 查詢一樣,plinq 查詢對任何記憶體中 ienumerable 或ienumerable of t 資料來...

C 並行程式設計 PLINQ

實列 console.writeline hello world console.writeline 當前計算機處理器數 environment.processorcount concurrentqueueproducts new concurrentqueue 向集合中新增多條資料 可以修改資料量...

並行程式設計與PLINQ 任務並行

任務並行 在tpl當中還可以使用parallel.invoke方法觸發多個非同步任務,其中 actions 中可以包含多個方法或者委託,paralleloptions用於配置parallel類的操作。public static void invoke action actions public st...