Как удалить отдельный конкретный объект из ConcurrentBag <>?

Question

С новым ConcurrentBag<T> в .NET 4, как вы удаляете из него определенный конкретный объект, когда доступны только TryTake() и TryPeek()?

Я имею в виду использование TryTake(), а затем просто добавить полученный объект обратно в список, если я не хотите удалить его, но я чувствую, что я мог бы быть что-то отсутствует. Правильно ли это?

Answer 1

Короткий ответ: вы не можете сделать это простым способом.

ConcurrentBag поддерживает локальную очередь потока для каждого потока, и он смотрит только на очереди других потоков, когда их очередь становится пустой. Если вы удалите элемент и вернете его, то следующий элемент, который вы удалите, может снова стать тем же. Нет никакой гарантии, что многократное удаление предметов и их возвращение позволят вам перебирать все предметы.

две альтернативы для вас:

• Удалить все элементы и помнить их, пока не найдете тот, который вы хотите удалить, а затем положить остальные обратно потом. Обратите внимание, что если два потока попытаются сделать это одновременно, у вас возникнут проблемы.
• Используйте более подходящую структуру данных, такую ​​как ConcurrentDictionary.

Answer 2

Как вы упомянули, TryTake() является единственным вариантом. Это также пример на MSDN. Отражатель также не показывает других скрытых внутренних методов.

Answer 3

Вы не можете. Его мешок, он не заказан. Когда вы вернете его, вы просто застрянете в бесконечном цикле.

Вы хотите комплект. Вы можете эмулировать один с ConcurrentDictionary. Или HashSet, что вы защищаете себя блокировкой.

Answer 4

как насчет:

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

Он работает, я не знаю, насколько эффективно ...

Answer 5

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 6

ConcurrentBag отлично подходит для обработки списка, где вы можете добавить объекты и перечисления из так как его название предлагает :)

As Mark Byers told, вы можете перестроить новый ConcurrentBag, который не содержит элемент, который вы хотите удалить, bu t вы должны защитить это от нескольких ударов нитей с помощью блокировки. Это один вкладыш:

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

Это работает, и соответствует духу, в котором ConcurrentBag был разработан.

Answer 7

Правильный ответ: ConcurrentDictionary будет работать так, как вы хотите. Если вы хотите по-прежнему использовать ConcurrentBag, то вас не будет устраивать следующий, не эффективный ум.

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

Answer 8

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 9

Это мой класс расширения, которые я использую в своих проектах. Это может сделать удалить один элемент из ConcurrentBag, а также может удалить список элементов из сумки

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