BlockingCollectionキューがバックグラウンドスレッドによってクリアされるまで待ちますが、時間がかかりすぎるとタイムアウトが発生しますか？

Question

C＃では、BlockingCollectionがバックグラウンドスレッドによってクリアされるまで待つことが可能かどうか、時間がかかり過ぎるとタイムアウトが発生するのではないかと思います。

現時点で私が持っている一時的なコードはやや洗練として私を打つ（それはThread.Sleepを使用することをお勧めしたとき以来？）：

while (_blockingCollection.Count > 0 || !_blockingCollection.IsAddingCompleted) 
{ 
    Thread.Sleep(TimeSpan.FromMilliseconds(20)); 
    // [extra code to break if it takes too long] 
} 

Answer 1

何があなたを消費スレッドでこのような何かを書く場合：

var timeout = TimeSpan.FromMilliseconds(10000); 
T item; 
while (_blockingCollection.TryTake(out item, timeout)) 
{ 
    // do something with item 
} 
// If we end here. Either we have a timeout or we are out of items. 
if (!_blockingCollection.IsAddingCompleted) 
    throw MyTimeoutException(); 

Answer 2

あなたは、イベントがときに設定できるように再設計することができる場合コレクションが空である、あなたは、コレクションが空であるのを待つために待機ハンドルを使用することができます。

static void Main(string[] args) 
{ 
    BlockingCollection<int> bc = new BlockingCollection<int>(); 
    ManualResetEvent emptyEvent = new ManualResetEvent(false); 
    Thread newThread = new Thread(() => BackgroundProcessing(bc, emptyEvent)); 
    newThread.Start(); 
    //wait for the collection to be empty or the timeout to be reached. 
    emptyEvent.WaitOne(1000); 

} 
static void BackgroundProcessing(BlockingCollection<int> collection, ManualResetEvent emptyEvent) 
{ 
    while (collection.Count > 0 || !collection.IsAddingCompleted) 
    { 
     int value = collection.Take(); 
     Thread.Sleep(100); 
    } 
    emptyEvent.Set(); 
} 

Answer 3

あなたは、キューが空であるかを決定するために消費するスレッドでGetConsumingEnumerable()とforeachを使用して、メインスレッドはキューが空であるかどうかを確認することができManualResetEventを設定することができます。 GetConsumingEnumerable()は空のキューで終了する前にCompleteAdding()が呼び出されたかどうかをチェックする列挙子を返します。

サンプルコード：

using System; 
using System.Collections.Concurrent; 
using System.Threading; 
using System.Threading.Tasks; 

namespace Demo 
{ 
    internal class Program 
    { 
     private void run() 
     { 
      Task.Run(new Action(producer)); 
      Task.Run(new Action(consumer)); 

      while (!_empty.WaitOne(1000)) 
       Console.WriteLine("Waiting for queue to empty"); 

      Console.WriteLine("Queue emptied."); 
     } 

     private void producer() 
     { 
      for (int i = 0; i < 20; ++i) 
      { 
       _queue.Add(i); 
       Console.WriteLine("Produced " + i); 
       Thread.Sleep(100); 
      } 

      _queue.CompleteAdding(); 
     } 

     private void consumer() 
     { 
      foreach (int n in _queue.GetConsumingEnumerable()) 
      { 
       Console.WriteLine("Consumed " + n); 
       Thread.Sleep(200); 
      } 

      _empty.Set(); 
     } 

     private static void Main() 
     { 
      new Program().run(); 
     } 

     private BlockingCollection<int> _queue = new BlockingCollection<int>(); 

     private ManualResetEvent _empty = new ManualResetEvent(false); 
    } 
}