資料結構
網路
RDBMS
作業系統
Java
MS Excel
iOS
HTML
CSS
Android
Python
C 程式設計
C++
C#
MongoDB
MySQL
Javascript
PHP
物理
化學
生物
數學
英語
經濟
心理學
社會學
時尚
法律如何在 C# 中限制 Parallel.ForEach？
並行 Foreach
C# 中的 Parallel.ForEach 迴圈在多執行緒上執行，並且處理以並行方式進行。Parallel.ForEach 迴圈不是 C# 的基本特性，它在 C# 4.0 及以上版本中可用。要使用 Parallel.ForEach 迴圈，我們需在 using 指令中匯入 System.Threading.Tasks 名稱空間。
Foreach
C# 中的 Foreach 迴圈在單個執行緒上執行，並且處理逐項順序進行。Foreach 迴圈是 C# 的基本特性，它在 C# 1.0 中可用。在大多數情況下，它的執行速度比 Parallel.Foreach 慢。
示例 1
static void Main(string[] args){
List<string> alphabets = new List<string>();
alphabets.Add("A");
alphabets.Add("B");
alphabets.Add("C");
alphabets.Add("D");
alphabets.Add("E");
alphabets.Add("F");
alphabets.Add("G");
alphabets.Add("H");
alphabets.Add("I");
alphabets.Add("J");
alphabets.Add("K");
alphabets.Add("L");
alphabets.Add("M");
alphabets.Add("N");
alphabets.Add("O");
alphabets.Add("P");
alphabets.Add("Q");
alphabets.Add("R");
alphabets.Add("S");
alphabets.Add("T");
alphabets.Add("U");
alphabets.Add("V");
alphabets.Add("W");
alphabets.Add("X");
alphabets.Add("Y");
alphabets.Add("Z");
Console.WriteLine("Printing list using foreach loop
");
var stopWatch = Stopwatch.StartNew();
foreach (string alphabet in alphabets){
Console.WriteLine("alphabet Name: {0}, Thread Id= {1}", alphabet, Thread.CurrentThread.ManagedThreadId);
}
Console.WriteLine("foreach loop execution time = {0} seconds
", stopWatch.Elapsed.TotalSeconds);
Console.WriteLine("Printing list using Parallel.ForEach");
stopWatch = Stopwatch.StartNew();
Parallel.ForEach(alphabets, alphabet =>
{
Console.WriteLine("alphabet Name: {0}, Thread Id= {1}", alphabet, Thread.CurrentThread.ManagedThreadId);
}
);
Console.WriteLine("Parallel.ForEach() execution time = {0} seconds", stopWatch.Elapsed.TotalSeconds);
Console.Read();
Console.ReadLine();
}輸出
使用 foreach 迴圈列印列表
alphabet Name: A, Thread Id= 1 alphabet Name: B, Thread Id= 1 alphabet Name: C, Thread Id= 1 alphabet Name: D, Thread Id= 1 alphabet Name: E, Thread Id= 1 alphabet Name: F, Thread Id= 1 alphabet Name: G, Thread Id= 1 alphabet Name: H, Thread Id= 1 alphabet Name: I, Thread Id= 1 alphabet Name: J, Thread Id= 1 alphabet Name: K, Thread Id= 1 alphabet Name: L, Thread Id= 1 alphabet Name: M, Thread Id= 1 alphabet Name: N, Thread Id= 1 alphabet Name: O, Thread Id= 1 alphabet Name: P, Thread Id= 1 alphabet Name: Q, Thread Id= 1 alphabet Name: R, Thread Id= 1 alphabet Name: S, Thread Id= 1 alphabet Name: T, Thread Id= 1 alphabet Name: U, Thread Id= 1 alphabet Name: V, Thread Id= 1 alphabet Name: W, Thread Id= 1 alphabet Name: X, Thread Id= 1 alphabet Name: Y, Thread Id= 1 alphabet Name: Z, Thread Id= 1 foreach loop execution time = 0.0223421 seconds
使用 Parallel.ForEach 列印列表
alphabet Name: A, Thread Id= 1 alphabet Name: G, Thread Id= 4 alphabet Name: H, Thread Id= 4 alphabet Name: I, Thread Id= 4 alphabet Name: J, Thread Id= 4 alphabet Name: K, Thread Id= 4 alphabet Name: L, Thread Id= 4 alphabet Name: N, Thread Id= 4 alphabet Name: O, Thread Id= 4 alphabet Name: P, Thread Id= 4 alphabet Name: Q, Thread Id= 4 alphabet Name: Y, Thread Id= 6 alphabet Name: Z, Thread Id= 6 alphabet Name: D, Thread Id= 6 alphabet Name: E, Thread Id= 6 alphabet Name: F, Thread Id= 6 alphabet Name: T, Thread Id= 6 alphabet Name: U, Thread Id= 6 alphabet Name: V, Thread Id= 6 alphabet Name: R, Thread Id= 4 alphabet Name: M, Thread Id= 5 alphabet Name: S, Thread Id= 7 alphabet Name: B, Thread Id= 1 alphabet Name: C, Thread Id= 1 alphabet Name: W, Thread Id= 6 alphabet Name: X, Thread Id= 6 Parallel.ForEach() execution time = 0.0559777 seconds
示例 2
限制並行 foreach 中的並行度
static class Program{
static void Main(string[] args){
List<string> alphabets = new List<string>();
alphabets.Add("A");
alphabets.Add("B");
alphabets.Add("C");
alphabets.Add("D");
alphabets.Add("E");
alphabets.Add("F");
alphabets.Add("G");
alphabets.Add("H");
alphabets.Add("I");
alphabets.Add("J");
alphabets.Add("K");
alphabets.Add("L");
alphabets.Add("M");
alphabets.Add("N");
alphabets.Add("O");
alphabets.Add("P");
alphabets.Add("Q");
alphabets.Add("R");
alphabets.Add("S");
alphabets.Add("T");
alphabets.Add("U");
alphabets.Add("V");
alphabets.Add("W");
alphabets.Add("X");
alphabets.Add("Y");
alphabets.Add("Z");
Parallel.ForEach(
alphabets,
new ParallelOptions { MaxDegreeOfParallelism = 2 },
alphabet => { Console.WriteLine("alphabet Name: {0}, Thread Id= {1}", alphabet, Thread.CurrentThread.ManagedThreadId); }
);
}
}輸出
alphabet Name: N, Thread Id= 4 alphabet Name: O, Thread Id= 4 alphabet Name: P, Thread Id= 4 alphabet Name: A, Thread Id= 1 alphabet Name: B, Thread Id= 1 alphabet Name: C, Thread Id= 1 alphabet Name: Q, Thread Id= 4 alphabet Name: R, Thread Id= 4 alphabet Name: S, Thread Id= 4 alphabet Name: T, Thread Id= 4 alphabet Name: U, Thread Id= 4 alphabet Name: V, Thread Id= 4 alphabet Name: W, Thread Id= 4 alphabet Name: X, Thread Id= 4 alphabet Name: Y, Thread Id= 4 alphabet Name: Z, Thread Id= 4 alphabet Name: H, Thread Id= 4 alphabet Name: I, Thread Id= 4 alphabet Name: J, Thread Id= 4 alphabet Name: K, Thread Id= 4 alphabet Name: D, Thread Id= 1 alphabet Name: L, Thread Id= 4 alphabet Name: E, Thread Id= 1 alphabet Name: F, Thread Id= 1 alphabet Name: G, Thread Id= 1 alphabet Name: M, Thread Id= 4
更新於： 07-11-2020
1K+ 次瀏覽
廣告