Jak usunąć pojedynczy, określony obiekt z ConcurrentBag <>?

W nowej wersji ConcurrentBag<T>.NET 4, jak usunąć z niej określony, konkretny obiekt, gdy tylko TryTake()iTryPeek() jest on dostępny?

Myślę o użyciu, TryTake()a następnie po prostu dodaniu wynikowego obiektu z powrotem do listy, jeśli nie chcę go usuwać, ale wydaje mi się, że czegoś mi brakuje. Czy to właściwy sposób?

Krótka odpowiedź: nie da się tego zrobić w łatwy sposób.

ConcurrentBag przechowuje lokalną kolejkę wątku dla każdego wątku i przegląda kolejki innych wątków tylko wtedy, gdy jego własna kolejka stanie się pusta. Jeśli usuniesz element i odłożysz go z powrotem, następnym usuniętym elementem może być ponownie ten sam element. Nie ma gwarancji, że wielokrotne usuwanie elementów i umieszczanie ich z powrotem pozwoli ci na iterację po wszystkich elementach.

Dwie alternatywy dla Ciebie:

• Usuń wszystkie elementy i zapamiętaj je, aż znajdziesz ten, który chcesz usunąć, a następnie odłóż pozostałe. Zauważ, że jeśli dwa wątki spróbują to zrobić jednocześnie, będziesz miał problemy.
• Użyj bardziej odpowiedniej struktury danych, takiej jak ConcurrentDictionary .

Nie możesz. To torba, nie jest zamówiona. Kiedy go odłożysz, po prostu utkniesz w niekończącej się pętli.

Chcesz zestaw. Możesz emulować jeden z ConcurrentDictionary. Lub zestaw HashSet, który chronisz za pomocą zamka.

ConcurrentBag świetnie radzi sobie z listą, w której możesz dodawać elementy i wyliczać z wielu wątków, a następnie ostatecznie wyrzucać, jak sugeruje nazwa :)

Jak powiedział Mark Byers , możesz ponownie zbudować nowy ConcurrentBag, który nie zawiera elementu, który chcesz usunąć, ale musisz go zabezpieczyć przed trafieniami wielu wątków za pomocą blokady. To jest jedna linijka:

myBag = new ConcurrentBag<Entry>(myBag.Except(new[] { removedEntry }));

To działa i pasuje do ducha, dla którego zaprojektowano ConcurrentBag.

Mark ma rację, ponieważ ConcurrentDictionary będzie działać tak, jak chcesz. Jeśli nadal chcesz korzystać z ConcurrentBag , zaprowadzą Cię tam poniższe (nie wydajne).

var stringToMatch = "test";
var temp = new List<string>();
var x = new ConcurrentBag<string>();
for (int i = 0; i < 10; i++)
{
    x.Add(string.Format("adding{0}", i));
}
string y;
while (!x.IsEmpty)
{
    x.TryTake(out y);
    if(string.Equals(y, stringToMatch, StringComparison.CurrentCultureIgnoreCase))
    {
         break;
    }
    temp.Add(y);
}
foreach (var item in temp)
{
     x.Add(item);
}

Jak wspomniałeś, TryTake()to jedyna opcja. To jest również przykład w MSDN . Reflector nie wykazuje również innych ukrytych, interesujących metod wewnętrznych.

public static void Remove<T>(this ConcurrentBag<T> bag, T item)
{
    while (bag.Count > 0)
    {
        T result;
        bag.TryTake(out result);

        if (result.Equals(item))
        {
            break; 
        }

        bag.Add(result);
    }

}

To jest moja klasa rozszerzeń, której używam w moich projektach. Może usunąć pojedynczy przedmiot z ConcurrentBag, a także może usunąć listę przedmiotów z torby

public static class ConcurrentBag
{
    static Object locker = new object();

    public static void Clear<T>(this ConcurrentBag<T> bag)
    {
        bag = new ConcurrentBag<T>();
    }


    public static void Remove<T>(this ConcurrentBag<T> bag, List<T> itemlist)
    {
        try
        {
            lock (locker)
            {
                List<T> removelist = bag.ToList();

                Parallel.ForEach(itemlist, currentitem => {
                    removelist.Remove(currentitem);
                });

                bag = new ConcurrentBag<T>();


                Parallel.ForEach(removelist, currentitem =>
                {
                    bag.Add(currentitem);
                });
            }

        }
        catch (Exception ex)
        {
            Debug.WriteLine(ex.Message);
        }
    }

    public static void Remove<T>(this ConcurrentBag<T> bag, T removeitem)
    {
        try
        {
            lock (locker)
            {
                List<T> removelist = bag.ToList();
                removelist.Remove(removeitem);                

                bag = new ConcurrentBag<T>();

                Parallel.ForEach(removelist, currentitem =>
                {
                    bag.Add(currentitem);
                });
            }

        }
        catch (Exception ex)
        {
            Debug.WriteLine(ex.Message);
        }
    }
}

public static ConcurrentBag<String> RemoveItemFromConcurrentBag(ConcurrentBag<String> Array, String Item)
{
    var Temp=new ConcurrentBag<String>();
    Parallel.ForEach(Array, Line => 
    {
       if (Line != Item) Temp.Add(Line);
    });
    return Temp;
}

Co powiesz na:

bag.Where(x => x == item).Take(1);

Działa, nie jestem pewien, jak skutecznie ...