Comment vider une BlockingCollection

J'ai un fil ajout d'éléments à une BlockingCollection .

Sur un autre fil, je suis en utilisant
foreach (var item in myCollection.GetConsumingEnumerable())

Si il y a un problème je veux sortir de mon foreach et ma méthode et effacer tout ce qui est à gauche dans le BlockingCollection cependant je ne peux pas trouver un moyen de le faire.

Des idées?

source d'informationauteur Jon

  1. 6

    Éventuellement utiliser la surcharge de GetConsumingEnumerable qui prend un CancellationTokenet puis si quelque chose va mal depuis la production de côté, il peut annuler le consommateur.

  2. 12

    Je suis en utilisant cette méthode d'extension:

    public static void Clear<T>(this BlockingCollection<T> blockingCollection)
{
    if (blockingCollection == null)
    {
        throw new ArgumentNullException("blockingCollection");
    }

    while (blockingCollection.Count > 0)
    {
        T item;
        blockingCollection.TryTake(out item);
    }
}

    Je me demandais si il y a un mieux, moins hacky, solution.

  3. 3

    Cela a fonctionné pour moi

    while (bCollection.Count > 0)
{
    var obj = bCollection.Take();
    obj.Dispose();
}

    Take() supprime de la collection, et vous pouvez appeler n'importe quel nettoyage de votre objet et de la condition de la boucle ne pas invoquer de blocage des appels.

  4. 1

    Il suffit de prendre tous les éléments restants:

    while (collection.TryTake(out _)){}
  5. 0
    BlockingCollection<T> yourBlockingCollection = new BlockingCollection<T>();

    Je suppose que vous signifie clairement de votre blocage de la collection. Jon réponse est plus approprié à votre question, je pense.

  6. -3

    Pour juste compensation de la collection, vous pouvez faire:

    myBlockingCollection.TakeWhile<*MyObject*>(qItem => qItem != null);

    ou tout simplement

    myBlockingCollection.TakeWhile<*MyObject*>(qItem => true);