BlockingCollection、競合状態ですか？

Question

BlockingCollectionを使用してプロデューサ/コンシューマパターンを実装しましたが、期待通りにブロックされていないようです。

しかし、私は

private void video_NewFrame(object sender, NewFrameEventArgs eventArgs) { 
    image = (Bitmap)eventArgs.Frame.Clone(); 
    queue.Add(image); 
    if (NewFrame != null) 
     NewFrame(this, new NewFrameEventArgs(image)); //invoke the event for display 
} 

をウェブカメラからフレームを受信し、BlockingCollection

に追加するスレッドを1つ持っているし、別のスレッドで、私はコレクションへの参照を持っていると

public void Run() { 
    foreach (Bitmap bmp in queue.GetConsumingEnumerable()) { 
     // process bitmap 

を使用してフレームを処理下に示すように、InvalidOperationExceptionがスローされて、引っ張っているフレームが他の場所で使用されていることがわかります。

img http://i17.photobucket.com/albums/b52/orubap/2012-03-24_020858.png

それはいつもすぐに発生しませんが、私は、キューが空または空の近くにあるときにのみ発生気づいた（すなわち。消費者が生産者よりも高速である）ので、私はそれをだ推測しています追加された最初の画像または最後に撮影された画像と関係があります。これがなぜ起こっているのでしょうか？

Answer 1

video_NewFrameを実行するスレッドは、NewFrameイベントハンドラに渡されるときにイメージを使用しています。これはRunと同時に実行されているため、2つのスレッドが同時にimageにアクセスすることはありません。 （NewFrameイベントハンドラがそれを処理している間Runは画像をデキューするときにのみ、キューが空またはほぼ空である場合にのみ、あなたはそれを参照してください理由を説明され、発生します。）

一つの修正はNewFrameへの呼び出しを移動するかもしれませんの前、queue.Add(image);（video_NewFrame）。これにより、イベントハンドラがイベントハンドラを終了するまで、Runがそれを見ることができなくなります（イベントハンドラに参照が格納されていないと仮定して）。