1 共享變量問題
錯誤寫法：
所有的任務可能會共享同一個變量，所以輸出結果可能會一樣。
|
1
2
3
4
5
6
7
|
public static void Error(){ for(int i=0;i<10;i++) { Task.Run(() => { Console.WriteLine("{0}", i); }); }} |
正確寫法：
將變量i賦給局部變量temp，使得每一個任務使用不同的i值。
|
1
2
3
4
5
6
7
8
|
public static void Right(){ for (int i = 0; i < 10; i++) { int temp = i; Task.Run(() => { Console.WriteLine("{0}", temp); }); }} |
2 不要清理掛起任務所需資源
錯誤寫法：
異步輸出文本內容，所以在未使用完StreamReader的時候，變量sr已經離開它的作用域，調用Dispose方法。
|
1
2
3
4
5
6
7
|
public static void Error(){ using (StreamReader sr = new StreamReader(@"D:\說明.txt", Encoding.Default)) { Task.Run(() => { Console.WriteLine("輸出：{0}",sr.ReadLine()); }); }} |
正確寫法：
|
1
2
3
4
5
6
7
8
|
public static void Right(){ using (StreamReader sr = new StreamReader(@"D:\說明.txt", Encoding.Default)) { var task = Task.Run(() => { Console.WriteLine("輸出：{0}", sr.ReadLine()); }); task.Wait(); }} |
3 避免鎖定this，typeof(type),string
正確的做法：定義一個object類型的私有只讀字段，鎖定之。
4 關于WaitHandle.WaitAll的waitHandles的數目必須小于等于64個
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
public static void Error(){ ManualResetEvent[] manualEvents = new ManualResetEvent[65]; try { for (int i = 0; i < 65; i++) { var temp = i; Task.Run(() => { manualEvents[temp] = new ManualResetEvent(false); Console.WriteLine("{0}", temp); manualEvents[temp].Set(); }); } WaitHandle.WaitAll(manualEvents); } catch (Exception ae) { Console.WriteLine(ae.Message); }} |
5 無法捕獲異常的情形
|
1
2
3
4
5
6
7
8
9
10
|
try{ var task = Task.Run(() => { throw new Exception("拋異常"); }); //如果將下面這行代碼注掉，則無法拋出異常 task.Wait();}catch(Exception ex){ Console.WriteLine(ex.Message);} |
6 是否該釋放Task資源
建議調用Dispose，但不調用也不是一個嚴重的錯誤。
注意在Task任務處于某些狀態時是不允許釋放資源的，否則會報錯。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
public static void CatchException(){ try { Console.WriteLine("開始"); var task = Task.Run(() => { //throw new Exception("拋異常"); }); //注掉下面這行代碼，觀察異常結果 //task.Wait(); task.Dispose(); Console.WriteLine("結束"); } catch(Exception ex) { Console.WriteLine(ex.Message); }} |
7 死鎖演示
假設tsak1和task2都在獲得第二個鎖（對tsak1來說它請求的第二個鎖是LockedObj2 ，而對task2來說則是LockedObj1 ）之前成功獲得了第一個鎖，就會發生死鎖。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
private static readonly Object LockedObj1 = new object();private static readonly Object LockedObj2 = new object();public static void LockShow(){ var task1 = Task.Run(() => { lock (LockedObj1) { Console.WriteLine("get LockedObj1"); lock (LockedObj2) { Console.WriteLine("get LockedObj2...."); } } }); var task2 = Task.Run(() => { lock (LockedObj2) { Console.WriteLine("get LockedObj2"); lock (LockedObj1) { Console.WriteLine("get LockedObj1...."); } } });} |
多次運行可得下面兩種結果：第一個圖是未發生死鎖的情形，第二個圖是發生死鎖的情形。
8 不要調用Thread.Abort方法。
Task沒有提供Abort方法，使用新的TPL（.NET 4.0以后），不會想到這個問題，一般使用CancellationToken來控制取消任務。
9 確保共享變量是安全的
反復運行，可觀察到不一樣的結果，下圖所示。
|
1
2
3
4
5
6
7
8
9
|
public static void Func(){ string s = "ASDFGH"; Parallel.Invoke( () => { s = s.Replace("A", "1"); s = s.Replace("S", "1s"); }, () => { s = s.Replace("A", "2"); s = s.Replace("S", "2s"); }, () => { s = s.Replace("A", "3"); }); Console.WriteLine(s);} |
10 處理器超額申請與申請不足
|
1
2
3
4
5
6
7
8
9
10
11
12
13
|
public static void Func(){ ParallelOptions po = new ParallelOptions(); //超額申請，處理器只有4個邏輯內核，結果設置并行度為10且是個邏輯內核均在工作，等待的任務數量大于0. po.MaxDegreeOfParallelism = 10; //申請不足，處理器有4個邏輯內核，卻指定并行度為3，還有一個空閑的內核沒有被占用(也有可能被其他線程占用，這里假設在指定并行度為3的情況下，另一個內核空閑) po.MaxDegreeOfParallelism = 3; List<int> list = new List<int>(); Parallel.ForEach(list, po, m => { //業務 });} |
以上就是本文的全部內容，希望本文的內容對大家的學習或者工作能帶來一定的幫助，同時也希望多多支持服務器之家！
原文鏈接：http://www.cnblogs.com/hdwgxz/p/6294892.html
