キューのレース条件

Question

以下のコードは、2つのパラメータを指定して送信されるソケットメッセージを処理します。情報をキューに入れ、別のスレッドで処理されます。私の質問は、2つのメッセージが直後に来て、デキューされてProcessDataメソッドに送られた場合です。ProcessDataに競合状態がありますか？

private void DataIn(long Code, string Message) 
{ 
    if (!Started) 
    { 
    if (DataInQueue == null) 
     DataInQueue = new Queue(); 
    DataInThread = new Thread(new ThreadStart(ThreadProcedure)); 
    DataInThreadEnding = false; 
    DataInThread.IsBackground = true; 
    DataInThread.Start(); 
    Started = true; 
    } 
    DataInQueue.Enqueue(new cDataIn(Code, Message)); 
} 

private void ThreadProcedure() 
{ 
    while (!ProgramEnding) 
    { 
    Queue mySyncdQ = Queue.Synchronized(DataInQueue); 
    if (mySyncdQ != null && mySyncdQ.Count > 0) 
    { 
     cDataIn data = null; 
     // Creates a synchronized wrapper around the Queue. 
     if (mySyncdQ.Count > 0) 
      data = (cDataIn)mySyncdQ.Dequeue(); 

     ProcessData(data); 
    } 
    } 

} 

Answer 1

UPDATE

キューがあなたのコード内でスレッドセーフな方法で使用されていません...あなたが表示されたコードは、競合状態が存在するかどうかを確認するには十分ではなく、ConcurrentQueueであなたが得ますより良いパフォーマンス...そしてThreadProcedureではnullでProcessDataを呼び出すことができますし、安全な側にあることがわかるようにProcessDataはすべての機能が再入可能でなければなりません。

ConcurrentQueue - いくつかの可能な問題を避けています...そして、スレッドセーフなプロデューサ/スレッド用に設計されたBlockingCollectionをチェックしてください。コンシューマーシナリオ...どちらもほとんどロックフリーですが、実際には高速です...

Answer 2

はいこれはあなたのキューを矛盾した状態にすることさえできます。 .Net 4.に同梱されているConcurrent QueueBlockingCollectionを使用する必要があります。これは、箱から取り出して最適化したスレッドセーフです。

よろしくゲルト・ヤン

Answer 3

あなたのコードはスレッドセーフではありません。 the documentation for Queue.Synchronized()でこれを注意してください：

Queueのスレッドの安全性を保証するために、すべての操作はこれだけラッパーを介して行う必要があります。

コードはスレッドセーフではないため、キューを直接使用しています。これを修正するには、ドキュメントにあるように、常に返されるラッパーを使用してください。

または、.Net 4の場合は、ConcurrentQueue<T>を使用してください。

以前のバージョンの.Netで汎用キューを使用する場合は、Queue<T>を使用し、常にlockにアクセスします。