同時キューデキュー

Question

私は、同時キューを使用して

作成アクションデリゲートによって、複数のスレッドを経由

Action action =() => 
     { 
      SubscriptionResponseModel subsModel; 
      while (concurrentQueue.TryTake(out subsModel)) 
      { 
       MakeTransactionAndAddIntoQueue(subsModel); 
      } 
     }; 

をキューからデータをデキューし、このアクションデリゲート並列複数のスレッド

Parallel.Invoke(action, action, action, action, action, action, action, action, action, action, action, action, action, action, action); 

を起動しています私が知りたいです私が複数のアクションでSubscriptionResponseModel subsModel;を使用しているときの1つのことはスレッドセーフですか？

Answer 1

actionの各呼び出しには独自のsubsModelがあるため、キューから値を取得するためにスレッドを使用するとスレッドセーフです。

// ********** Code showing non-thread safe case ************** 
    SubscriptionResponseModel subsModel; 
    Action action =() => 
    { 
     // all invocations of `action` will share subsModel as it is captured. 
     while (concurrentQueue.TryDequeue(out subsModel)) 
     { 
      MakeTransactionAndAddIntoQueue(subsModel); 
     } 
    }; 

注：

• のかどうかのプロパティを使用していない/ SubscriptionResponseModelの方法は、スレッドがありますキャプチャ外側の文脈から変数をするとき、それはスレッドセーフされない

  ケースがありますその種類によって安全です。

• 複数のTryDequeueを同時に実行してもパフォーマンスが向上しない可能性は非常に高いです。 Parallel.Invoke複数のビジー・ループは、複数のスレッドが常に空のキューに問合せを行うのを単にブロックします。私は並列我々はこれを行うことができますどのように私の同時キューを消費したい場合