.Net多線程編程（誤用點分析）
建個控制臺(.net framework)
?class Program
??{
????#region 1 共享變量問題
????/// <summary>
????/// 錯誤寫法：
????/// 所有的任務可能會共享同一個變量，所以輸出結果可能會一樣。
????/// </summary>
????public static void Error()
????{
??????for (int i = 0; i < 10; i++)
??????{
????????Task.Run(() => { Console.WriteLine("{0}", i); });
??????}
????}
????/// <summary>
????/// 正確寫法：
????/// 將變量i賦給局部變量temp，使得每一個任務使用不同的i值。
????/// </summary>
????public static void Right()
????{
??????for (int i = 0; i < 10; i++)
??????{
????????int temp = i;
????????Task.Run(() => { Console.WriteLine("{0}", temp); });
??????}
????}
????#endregion
????#region 2 不要清理掛起任務所需資源
????/// <summary>
????/// 錯誤寫法：
????/// 異步輸出文本內容，所以在未使用完StreamReader的時候，變量sr已經離開它的作用域，調用Dispose方法。
????/// System.ObjectDisposedException:“無法從已關閉的 TextReader 中讀取?！?/p>
????/// </summary>
????public static void Error2()
????{
??????using (StreamReader sr = new StreamReader(@"D:\說明.txt", Encoding.Default))
??????{
????????Task.Run(() => { Console.WriteLine("輸出：{0}", sr.ReadLine()); });
??????}
????}
????/// <summary>
????/// 正確寫法：
????/// </summary>
????public static void Right2()
????{
??????using (StreamReader sr = new StreamReader(@"D:\說明.txt", Encoding.UTF8))
??????{
????????var task = Task.Run(() => { Console.WriteLine("輸出：{0}", sr.ReadLine()); });
????????task.Wait();
??????}
????}
????#endregion
????#region 3 避免鎖定this，typeof(type),string
????//正確的做法：定義一個object類型的私有只讀字段，鎖定之。
????#endregion
????#region 4 關于WaitHandle.WaitAll的waitHandles的數(shù)目必須小于等于64個?
????public static void Error4()
????{
??????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);
??????}
????}
????#endregion
????#region?6 是否該釋放Task資源
????/// <summary>
????/// 建議調用Dispose，但不調用也不是一個嚴重的錯誤。
????/// 注意在Task任務處于某些狀態(tài)時是不允許釋放資源的，否則會報錯。
????/// </summary>
????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);
??????}
????}
????#endregion
????#region 7 死鎖演示
????/// <summary>
????/// 假設tsak1和task2都在獲得第二個鎖（對tsak1來說它請求的第二個鎖是LockedObj2 ，而對task2來說則是LockedObj1 ）之前成功獲得了第一個鎖，就會發(fā)生死鎖。
????/// </summary>
????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....");
??????????}
????????}
??????});
????}
????#endregion
????#region 8 不要調用Thread.Abort方法。
????/// <summary>
????///?Task沒有提供Abort方法，使用新的TPL（.NET 4.0以后），不會想到這個問題，一般使用CancellationToken來控制取消任務。
????/// </summary>
????#endregion
????#region 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);
????}
????#endregion
????#region 10 處理器超額申請與申請不足
????public static void Func10()
????{
??????ParallelOptions po = new ParallelOptions();
??????//超額申請，處理器只有4個邏輯內核，結果設置并行度為10且是個邏輯內核均在工作，等待的任務數(shù)量大于0.
??????po.MaxDegreeOfParallelism = 10;
??????//申請不足，處理器有4個邏輯內核，卻指定并行度為3，還有一個空閑的內核沒有被占用(也有可能被其他線程占用，這里假設在指定并行度為3的情況下，另一個內核空閑)
??????po.MaxDegreeOfParallelism = 3;
??????List<int> list = new List<int>();
??????Parallel.ForEach(list, po, m =>
??????{
????????//業(yè)務
??????});
????}
????#endregion
????static void Main(string[] args)
????{
??????Error();
??????Right();
??????Error2();
??????Right2();
??????Error4();
??????#region 5 無法捕獲異常的情形
??????try
??????{
????????var task = Task.Run(() => { throw new Exception("拋異常"); });
????????//如果將下面這行代碼注掉，則無法拋出異常
????????task.Wait();
??????}
??????catch (Exception ex)
??????{
????????Console.WriteLine(ex.Message);
??????}
??????#endregion
??????CatchException();
??????LockShow();
??????Func();
??????Func10();
????}
??}
