本文主要介紹了.Net多執行緒程式設計中的誤用點分析。具有一定的參考價值,以下跟著小編一起來看下吧
1 共享變數問題
錯誤寫法:
所有的任務可能會共用同一個變量,所以輸出結果可能會一樣。
public static void Error() { for(int i=0;i<10;i++) { Task.Run(() => { Console.WriteLine("{0}", i); }); } }
正確寫法:
將變數i賦給局部變數temp,使得每一個任務使用不同的i值。
public static void Right() { for (int i = 0; i < 10; i++) { int temp = i; Task.Run(() => { Console.WriteLine("{0}", temp); }); } }
2 不要清理掛起任務所需資源
錯誤寫法:
非同步輸出文字內容,所以在未使用完StreamReader的時候,變數sr已經離開它的作用域,呼叫Dispose方法。
public static void Error() { using (StreamReader sr = new StreamReader(@"D:\说明.txt", Encoding.Default)) { Task.Run(() => { Console.WriteLine("输出:{0}",sr.ReadLine()); }); } }
正確寫法:
##
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個
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 無法捕獲異常的情況
try { var task = Task.Run(() => { throw new Exception("抛异常"); }); //如果将下面这行代码注掉,则无法抛出异常 task.Wait(); } catch(Exception ex) { Console.WriteLine(ex.Message); }
6 是否該釋放Task資源
建議呼叫Dispose,但不呼叫也不是一個嚴重的錯誤。 注意在Task任務處於某些狀態時是不允許釋放資源的,否則會報錯。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 )之前成功獲得了第一個鎖,就會發生死鎖。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 確保共享變數是安全的
反覆運行,可觀察到不一樣的結果,下圖所示。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 處理器超額申請與申請不足
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 => { //业务 }); }
以上是.Net多執行緒程式設計中的誤用點分析的詳細內容。更多資訊請關注PHP中文網其他相關文章!