.NETコンシューマ/プロデューサ（キュー）

Question

私は.NET/Threadsで新しく、この演習で誰かが私を助けることができるかどうかを知りたいと思います。私はそれがスレッドをロックせずに動作させるために、コメントを交換する必要があります。

private Queue<int> queue; 

public void ConsumeFunc(){ 
    while (true){ 
     // 1 
     while (/* 2 */){ 
     // 3 
     } 
     int element = queue.Dequeue(); 
     // 4 
     Console.WriteLine("Consume element: " + element); 
     Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 2) * 1000); 
    } 
} 

private void ProduceFunc(){ 
    while (true) { 
     // 1 
     queue.Enqueue(DateTime.Now.Millisecond); 
     // 2 
     // 3 
     Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 2) * 1000); 
    } 
} 

私はこれを管理しますが、それは

public void ConsumerFunc(){ 
    while (true){ 
     Monitor.PulseAll(queue); // 1 
     while (queue.Count == 0){ /* 2 */ 
      Monitor.Wait(queue); // 3 
     } 
     int element = queue.Dequeue(); 
     lock (queue) // 4 
     Console.WriteLine("Consume element: " + element); 
     Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 2) * 1000); 
    } 
} 


public void ProducerFunc(){ 
    while (true) { 
     lock (queue) // 1 
     queue.Enqueue(DateTime.Now.Millisecond); 
     Monitor.PulseAll(queue); // 2 
     // 3 ??? 
     Thread.Sleep(new Random((int)DateTime.Now.Ticks).Next(0, 3) * 1000); 
    } 
} 

を完了し、次のエラー与えていない： オブジェクトの同期方法を非同期コードブロックから呼び出された, オンMonitor.PulseAll(queue);

Answer 1

むしろthaあなた自身が同期を実装するために戦うnは、BlockingCollectionを見てください。すべての同期を処理し、QueueクラスとMonitorクラスを使用して作成できるものよりも優れたパフォーマンスを発揮します。

.NETのドキュメントには、スタックオーバーフローなど、さまざまな例があります。私の記事が役に立ちます：http://www.informit.com/guides/content.aspx?g=dotnet&seqNum=821