Was sind die Unterschiede zwischen ConcurrentQueue und BlockingCollection in .Net?

Was sind die Unterschiede zwischen ConcurrentQueue und BlockingCollection im .Net?

Warum BlockingCollection ist am besten für die Erzeuger-Verbraucher-operation, wenn es getan werden kann, durch ConcurrentQueue? Muss ich noch etwas verbessern in dem folgenden code?

MessageSlotMachineGameStartOrAndStatusUpdate msg;

while (!aCancellationToken.IsCancellationRequested)
{
    try
    {
        this.isStillConsumingMsg = true;
        Boolean takeResult = this.msgQueue.TryTake(out msg, this.msgConsumeTimeOut, aCancellationToken);
        if (takeResult)
        {
            if (msg != null)
            {
                this.ProcessMessage(msg);
            }
        }
        else
        {
            break;
        }
    }
    catch (OperationCanceledException err)
    {
        EngineManager.AddExceptionLog(err, "Signal Operation Canceled");
    }
    catch (Exception err)
    {
        EngineManager.AddExceptionLog(err, "Signal exception");
    }
    finally
    {
        this.isStillConsumingMsg = false;
    }
}
  • BlockingCollection verwendet CurrentQueue als der zugrunde liegende Typ, um die Daten aufzunehmen. Plus es hat die Blockierung der Funktionalität.
  • auch nur Hinweis BlockingCollection verwendet ConcurrentQueue standardmäßig, aber Sie können geben Sie einen anderen collection-Typ im Konstruktor implementiert, dass IProducerConsumerCollection...zum Beispiel, wenn Sie wollten, LIFO könnten Sie eine ConcurrentStack statt
InformationsquelleAutor WAP Guy | 2012-04-04
  1. 50

    BlockingCollection hat eine Take Methode blockieren würden die Verbraucher, wenn es nichts zu nehmen, und warten, bis ein Erzeuger-Seite, um ein Element. ConcurrentQueue fehlt eine solche Methode - wenn es leer ist, wird der Verbraucher behandeln müssen, das warten, und die Hersteller benötigen, um eine nicht-leere Meldung.

    • können Sie mir hier ein Beispiel wie kann die Meldung durchgeführt werden.
    • Sie können einen AutoResetEvent. Folgen Sie dem link und scrollen Sie nach unten für ein Beispiel wie es verwendet wird.
    • ok,wenn es Signale an WaitHandle? sofort, wenn es leer ist oder nach einem timeout auf Nehmen Methode?
    • Es signalisiert sofort. Die timeout-Zeitspanne ist da, um sicherzustellen, dass, wenn es kein signal innerhalb des angegebenen timeout, ist die Methode nicht immer hängen.
    • danke!@dasblinkenlight
    • mit Bezug auf die Reihenfolge nehmen? es ist FiFO für beide?
    • Standardmäßig BlockingCollection wickelt ConcurrentQueue, so dass die Antwort ist "ja". Jedoch, Sie können bauen BlockingCollection Objekte mit anderen Sammlungen, die innerhalb Sie zum ändern der Reihenfolge von "nehmen".
    • Ein gutes Beispiel ist, Sie haben einem unbekannten Endgerät oder extrem lange Wartezeit zwischen der Erstellung von Daten für die Warteschlange. Wenn Sie eine concurrent queue stattdessen können Sie einfach den Prozess zu stoppen und starten Sie es über eine andere Methode nach der langen Wartezeit. Ich glaube nicht, dass die Blockierung einen thread für einen längeren Zeitraum ist ein gutes design.

    InformationsquelleAutor dasblinkenlight
Schreibe einen Kommentar