Comment retirer un objet unique et spécifique d'un ConcurrentBag<> ?

Question

Avec le nouveau ConcurrentBag<T> dans .NET 4, comment supprimer un certain objet spécifique de celui-ci lorsque seulement TryTake() y TryPeek() sont disponibles ?

Je pense utiliser TryTake() et ensuite ajouter l'objet résultant dans la liste si je Ne le fais pas. veulent l'enlever, mais j'ai l'impression que je pourrais manquer quelque chose. Est-ce la bonne méthode ?

Answer 1

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

}

Answer 2

C'est ma classe d'extension que j'utilise dans mes projets. Elle peut supprimer un seul élément du ConcurrentBag et peut également supprimer une liste d'éléments du sac.

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

Answer 3

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

Answer 4

Comment :

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

Ça marche, je ne suis pas sûr de l'efficacité...