Spróbuj wycofać w ConcurrentQueue

Question

Parametr TryDequeue w ConcurrentQueue zwróci wartość false, jeśli w kolejce nie ma żadnych elementów.

Jeśli kolejka jest pusta, potrzebuję, aby moja kolejka czekała, aż nowy element zostanie dodany do kolejki, i usunie ten nowy, a proces będzie kontynuowany.

należy używać monitor.enter, czekaj, puls lub jakieś lepsze opcje w C# 4.0

Answer 1

Czy nie jest to przeznaczone dla BlockingCollection?

Jak rozumiem, możesz zawinąć swój ConcurrentQueue jednym z nich, a następnie zadzwonić pod numer Take.

Answer 2

Można okresowo sprawdzać liczbę elementów w kolejce i gdy liczba elementów jest większa od zera, dasz sygnał za pomocą np ManualResetEvent do wątku, który zapisuje w kolejce elementy, dopóki kolejka nie będzie pusta.

Oto kod tego pseudo:

Sprawdź Temat:

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

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

rozkolejkowania Temat:

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

Rozważ użycie blokady w DequeueUntilQueueEmpty też.