キューを利用するには？［C#／VB］：.NET TIPS

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using static System.Console;

static void Main(string[] args)
{
  // 整数を格納するキュー
  var que = new Queue<int>();

  // キューに1から3まで順に投入
  for (int i = 1; i < 4; i++)
    que.Enqueue(i);

  // キューから全てを取り出す
  while (que.Count > 0)
  {
    WriteLine($"キューの先頭を見る：{que.Peek()}");
    WriteLine($"キューに入っている個数：{que.Count}");

    int n = que.Dequeue();
    WriteLine($"キューから取り出し：{n}");
    WriteLine($"キューに入っている個数：{que.Count}");
  }
  // 出力：
  // キューの先頭を見る：1
  // キューに入っている個数：3
  // キューから取り出し：1
  // キューに入っている個数：2
  // キューの先頭を見る：2
  // キューに入っている個数：2
  // キューから取り出し：2
  // キューに入っている個数：1
  // キューの先頭を見る：3
  // キューに入っている個数：1
  // キューから取り出し：3
  // キューに入っている個数：0

#if DEBUG
  ReadKey();
#endif
}

// 整数を格納するキュー
var que = new Queue<int>();
// キューに1から3まで順に投入
for (int i = 1; i < 4; i++)
  que.Enqueue(i);

WriteLine($"IEnumerable<int>：キューの内容：{string.Join(", ", que)}");
// 出力：IEnumerable<int>：キューの内容：1, 2, 3
WriteLine($"LINQ：キューの最後の要素：{que.Last()}");
// 出力：LINQ：キューの最後の要素：3
WriteLine($"LINQ：キューの合計：{que.Sum()}");
// 出力：LINQ：キューの合計：6
WriteLine($"LINQ：奇数の個数：{que.Count(n => (n % 2 != 0))}");
// 出力：LINQ：奇数の個数：2

const int MAX_QUE = 3; // キューに保持する最大個数
var que = new Queue<int>(MAX_QUE);
bool runningFlag = true; // falseにした後、キューが空になるとConsumerが止まる

// Producerを定義して実行開始
var produceTask = Task.Run(() => {
  // 1から5まで順にデータを投入していく
  for (int i = 1; i <= 5; i++)
  {
    // データ投入が間に合わない場合をシミュレート
    if (i == 5)
    {
      WriteLine($"stop enqueue");
      System.Threading.Thread.Sleep(1000);
      WriteLine($"restart enqueue");
    }

    // 投入データを作成する処理をシミュレート
    System.Threading.Thread.Sleep(10);

    // キューへデータを投入する
    lock (que) // 排他ロックを取得
    {
      while (que.Count >= MAX_QUE)
      {
        // MAX_QUEを超えないように投入を待機する
        WriteLine($"wait enqueue");
        System.Threading.Monitor.Wait(que); // 待機する（他でMonitor.PulseAllされると再開）
      }

      que.Enqueue(i);
      WriteLine($"Enqueue({i}), count={que.Count}");
      System.Threading.Monitor.PulseAll(que); // 待機中のスレッドがあったら、再開させる
    } // 排他ロックを解放
  }
  runningFlag = false; // データ投入完了を通知
  WriteLine($"end enqueue");
});

// Consumerを定義
Action<string> consume = (header) => {
  while (true)
  {
    int? data = null;
    lock (que) // 排他ロックを取得
    {
      while (que.Count == 0 && runningFlag)
      {
        // キューが空の間は待機
        WriteLine($"{header} wait dequeue");
        System.Threading.Monitor.Wait(que); // 待機する（他でMonitor.PulseAllされると再開）
      }

      // キューからデータを取り出す
      if (que.Count > 0)
      {
        data = que.Dequeue();
        WriteLine($"{header} Dequeue({data.Value}), count={que.Count}");
        System.Threading.Monitor.PulseAll(que); // 待機中のスレッドがあったら、再開させる
      }
      else // キューが空で、runningFlag==falseのとき
        break; // 無限ループを抜ける
    } // 排他ロックを解放
    // データの処理はロックを外してから行う
    if (data.HasValue)
    {
      // キューから取り出したデータを使う処理をシミュレート
      WriteLine($"{header} start process({data.Value})");
      System.Threading.Thread.Sleep(300);
      WriteLine($"{header} end process({data.Value})");
    }
  }
  WriteLine($"{header} EXIT");
};

System.Threading.Thread.Sleep(100);

// Consumerの実行を開始（2スレッド）
var consumeTask1 = Task.Run(() => consume("  [1]"));
var consumeTask2 = Task.Run(() => consume("    [2]"));

// 実行終了を待機
Task.WaitAll(produceTask, consumeTask1, consumeTask2);
WriteLine("COMPLETED");

var que = new Queue();
var syncQue = Queue.Synchronized(que); 

……省略……

Object obj = null;
// 次のコードは正しくない
if (syncQue.Count > 0) {
  // ↑↓この間に他スレッドでキューが空にされたら……
  obj = syncQue.Dequeue(); // ←ここで例外が出てしまう
}

// 正しくは次のようにロックしなければならない
lock (syncQue.SyncRoot) { 
  if (syncQue.Count > 0)
    obj = syncQue.Dequeue();
}