So entfernen Sie ein einzelnes, spezifisches Objekt aus einem ConcurrentBag & lt; & gt ;?

Mit der neuen ConcurrentBag<T>.NET 4, wie entfernt man eine bestimmte Objekt aus, wenn nur TryTake() und TryPeek() erhältlich sind?

Ich bin denken mit TryTake() und dann einfach nur mit dem Gegenstand, der Sie zurück in die Liste, wenn ich nicht wollen, um es zu entfernen, aber ich fühle mich wie ich könnte etwas fehlen. Ist das der richtige Weg?

InformationsquelleAutor der Frage Brandon | 2010-06-12

c#c#-4.0

65

Die kurze Antwort: Sie kann es nicht auf eine einfache Weise.

Den ConcurrentBag hält eine thread-lokale Warteschlange für jeden thread und es sieht nur auf andere threads Warteschlangen einmal seine eigene Warteschlange leer ist. Wenn Sie ein Element entfernen und legen Sie es dann das nächste Element, das Sie entfernen kann, kann das gleiche Element wieder. Es gibt keine Garantie, dass immer wieder Elemente entfernen und setzen Sie Sie zurück, wird Ihnen erlauben, zu iterieren über alle Elemente.

Zwei alternativen für Sie:
- Entfernen Sie alle Elemente und erinnern Sie Sie, bis Sie finden die, die Sie entfernen möchten, dann legen Sie die anderen wieder hinterher. Beachten Sie, dass, wenn zwei threads versuchen, gleichzeitig werden Sie Probleme haben.
- Verwenden Sie eine geeignete Datenstruktur wie Z. B. concurrentdictionary.
InformationsquelleAutor der Antwort Mark Byers
13

Können Sie nicht. Seine eine Tasche, es ist nicht der bestellten entspricht. Wenn du es zurück, dann bekommst du nur in einer Endlosschleife geraten.

Du willst einen Satz. Sie emulieren kann man mit Z. B. concurrentdictionary. Oder ein HashSet, dass Sie schützen sich selbst mit einem Schloss.

InformationsquelleAutor der Antwort Hans Passant
3

Wie Sie erwähnen, TryTake() ist die einzige option. Dies ist auch das Beispiel auf MSDN. Reflektor zeigt keine anderen versteckten internen Methoden von Interesse.

InformationsquelleAutor der Antwort Mikael Svenson
2

Den ConcurrentBag ist groß, um zu behandeln eine Liste, wo Sie können Elemente hinzufügen und auflisten von viele thread, dann werfen Sie es Weg, wie sein name suggeriert 🙂

Als Mark Byers erzähltkönnen Sie re-build eine neue ConcurrentBag, dass nicht das Element enthält, das Sie entfernen möchten, aber Sie haben, um dieses zu schützen gegen mehrere threads, die sich zuvor mit einem lock. Dies ist ein one-liner:
```
myBag = new ConcurrentBag<Entry>(myBag.Except(new[] { removedEntry }));
```
Dies funktioniert, und passen Sie der Geist, in dem die ConcurrentBag konzipiert wurde.

InformationsquelleAutor der Antwort Larry

Mark ist richtig, dass das Z. B. concurrentdictionary ist, wird die Arbeit in der Weise, die Sie wollen. Wenn Sie möchten, verwenden Sie immer noch ein ConcurrentBag die folgenden, nicht effizient, wohlgemerkt, Sie dort bekommen wird.

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);
}

InformationsquelleAutor der Antwort Rkaufman

Dies ist mein extension-Klasse, die ich benutze in meinen Projekten. Es kann ein entfernen einzelner Elemente aus ConcurrentBag und kann auch entfernen, die Liste der Gegenstände aus dem Beutel

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);
        }
    }
}

InformationsquelleAutor der Antwort huda

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);
    }

}

InformationsquelleAutor der Antwort huda

-4

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;
}

InformationsquelleAutor der Antwort Evgeniy Nikulov

-12

wie etwa:
```
bag.Where(x => x == item).Take(1);
```
Es funktioniert, ich bin mir nicht sicher, wie Sie Sie effizient...

InformationsquelleAutor der Antwort Simon Gullive

Schreibe einen Kommentar

Du musst angemeldet sein, um einen Kommentar abzugeben.