.Net多執行緒程式設計中的誤用點分析

怪我咯
發布: 2017-04-10 10:59:31
原創
1950 人瀏覽過

本文主要介紹了.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中文網其他相關文章!

相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板
關於我們 免責聲明 Sitemap
PHP中文網:公益線上PHP培訓,幫助PHP學習者快速成長!