Hãy thử Dequeue trong ConcurrentQueue

Question

TryDequeue trong ConcurrentQueue sẽ trả về false nếu không có mục nào trong Hàng đợi.

Nếu hàng đợi trống, tôi cần hàng đợi của tôi sẽ đợi cho đến khi mục mới được thêm vào hàng đợi và nó sẽ khử hàng mới và quá trình sẽ tiếp tục như thế.

tôi có nên sử dụng Monitor.Enter, chờ đợi, xung hoặc bất kỳ tùy chọn tốt hơn trong C# 4.0

Answer 1

Đây không phải là những gì BlockingCollection được thiết kế cho?

Khi tôi hiểu nó, bạn có thể quấn ConcurrentQueue của bạn với một trong số này, và sau đó gọi Take.

Answer 2

Bạn có thể kiểm tra định kỳ số phần tử trong hàng đợi và khi số phần tử là lớn hơn không, bạn đưa ra một tín hiệu sử dụng ví dụ ManualResetEvent vào luồng xóa (các) thành phần cho đến khi hàng đợi rỗng.

Đây là mã giả cho việc này:

Kiểm tra Ðề tài:

while(true) 
{ 
    int QueueLength = 0; 
    lock(Queue) 
    { 
    queueLength = Queue.Length; 
    } 

    if (Queue.Length > 0) 
    { 
    manualResetEvent.Set(); 
    } 
    else 
    { 
    Thread.Sleep(...); 
    }  
}  

Dequeue Ðề tài:

while(true) 
{ 
    if(manualResetEvent.WaitOne(timeout)) 
    { 
    DequeueUntilQueueEmpty(); 
    } 
} 

Xem xét sử dụng khóa trong DequeueUntilQueueEmpty, quá.