ConcurrentBagクラスでデータを追加できない

Question

ConcurrentBagクラスでデータを追加する時、下記では42しか、入らないようです。Bagがスタートして、反復した後に追加されるからと説明がありましたがよくわかりません。上書きになり、add(21)までたどり着けないということ
でしょうか？

ConcurrentBag<int> bag = new ConcurrentBag<int>();
            Task.Run(() =>
            {
                bag.Add(42);
                Thread.Sleep(1000);
                bag.Add(21);
            });
            Task.Run(() =>
            {
                foreach (int i in bag)
                    Console.WriteLine("data: " + i);
            }).Wait();
//only Disp 42

Answer 1

最初のTask.Runの中でThread.Sleep(1000)している間に、次のTask.Runの中のループは終わってしまいます。
Waitメソッドはそのタスクに対してのみ有効です。
最初のTaskの終了を待つには最初のTaskの後ろに.Wait()を追加してください。

Comments

[kazuya_]

ありがとうございます。確かに、2番めのタスクにThread.Sleep(1500);を入れたら、21 42と表示されました。
でも先入れ先出しのはずですが、なぜ　42 21と表示されないのでしょうか？

[hihijiji]

ConcurrentBag<T>は、オブジェクトの順序付けられていないスレッド セーフなコレクションを表します。
先入先出は、ConcurrentQueue<T> クラスなどです。

[hihijiji]

念の為追記します。値の取り出しには TryPeekメソッドまたは、TryDequeueメソッドを使って下さい。

[kazuya_]

ありがとうございました。