.Netマルチスレッドプログラミングにおける誤用ポイントの分析

この記事では主に.Netマルチスレッドプログラミングにおける誤用ポイントの分析を紹介します。一定の参考値があるので、以下のエディタで見てみましょう

1 共有変数の問題

誤記:

すべてのタスクは同じ変数を共有する可能性があるため、出力結果は同じになる可能性があります。

public static void Error()
{
   for(int i=0;i<10;i++)
   {
    Task.Run(() => { Console.WriteLine("{0}", i); });
   }
}

正しい書き方:

各タスクが異なる i 値を使用するように、変数 i をローカル変数 temp に割り当てます。

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 これ、typeof(type)、stringをロックしないでください

正しい方法: オブジェクトタイプのプライベート読み取り専用フィールドを定義します。それをロック。

4 WaitHandle.WaitAll に関しては、waitHandle の数は 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 タスクリソースは解放された?

Dispose を呼び出すことをお勧めしますが、呼び出さなくても重大な間違いではありません。

タスクが特定の状態にあるときはリソースを解放できないことに注意してください。そうでない場合はエラーが報告されます。

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 の両方が 2 番目のロックを取得していると仮定します (tsak1 の場合、要求する 2 番目のロックは 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....");
     }
    }
   });
}

複数回実行すると以下の2つの結果が得られます。1枚目はデッドロックが発生していない状況、2枚目はデッドロックが発生している状況です。

8 Thread.Abort メソッドを呼び出さないでください。

タスクには Abort メソッドがありません。新しい TPL (.NET 4.0 以降) を使用する場合は、通常、タスクのキャンセルを制御するために CancelToken が使用されます。

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 中国語 Web サイトの他の関連記事を参照してください。