ConcurrentBag'den tüm öğeler nasıl kaldırılır?

Question

ConcurrentBag Nasıl Temizlenir? Bunu bir döngü içinde teker nesneyi tek kaldırabilirsiniz

Answer 1

T someItem; 
while (!myBag.IsEmpty) 
{ 
    myBag.TryTake(out someItem); 
} 

Answer 2

... Clear veya RemoveAll gibi herhangi bir yöntem yoktur:

torba bundan sonra boş olduğu guaranted olmadığını

object result; 
while (bag.TryTake(out result)); 

Not Döngü, öğeler bittikten sonra öğeler eklenebilir ve farklı iş parçacığı tarafından sonraki deyimden önce.

Answer 3

Güncelleme 10/03/2017: @ @ Doğru şekilde işaret ettiyseniz, atama atomiktir. Bu örnekte, ConcurrentBag'un oluşturulması atomik olmayacaktır, ancak bu referansı atomik atomuna sokacaktır - bu yüzden kilitleme veya Interlocked.Exchange kesinlikle gerekli değildir.

Bazı ileri okuma:

reference assignment is atomic so why is Interlocked.Exchange(ref Object, Object) needed?

Is a reference assignment threadsafe?

---

Bunun yeni bir örneğini her zaman kilit çanta kendisine erişim ve yaratabilir. başka hiçbir şey onlara tutunarak ise torba içinde Öğeler sonra GC için uygun hale gelmeden olacaktır:

lock (something) 
{ 
    bag = new ConcurrentBag(); 
} 

Veya Lukazoid işaret ettiği gibi: bin

var newBag = new ConcurrentBag(); 
Interlocked.Exchange<ConcurrentBag>(ref bag, newBag); 

Kolay yolu içerikleri, ancak bu varsayar Bir öğe erişim istediğinde de kilidi alır - bu pahalı olabilir ve ConcurrentBag'un kendisine giden performans ayarını olumsuz etkileyebilir.

Eğer başka bir şey bu kez, kanat-and-a-namaz it at çantayı erişecek ve

Answer 4

:-) kilitlenmesini engellemek için biliyorsanız seçilen cevap tür, iyi, bir geçici çözüm, bu yüzden kendi çözümümü ekliyorum.

Çözümüm, koleksiyondaki tüm öğeleri temizlemenin önemsiz olduğunu bulmak için System.Collections.Concurrent ad alanındaki tüm kullanılabilir koleksiyonlara bakmaktı.

ConcurrentStack sınıfı, koleksiyondaki tüm öğeleri kaldıran Clear() yöntemine sahiptir. Aslında, isim alanında (şu anda) bulunan tek koleksiyon. Evet, Add(T element) yerine Push(T element)'a ihtiyacınız var, ama açıkçası bu zaman kazandı.

Answer 5

Çözümlerin ruhunda .. ConcurrentDictionary<T, bool> bir atomik Clear'e sahip, ancak bir anahtar olup olmadığını hızlı bir şekilde kontrol etmenizi de sağlar. 'Çabuk' tabiki göreceli bir terimdir, fakat kullanımınıza bağlı olarak büyük bir yığının numaralandırılmasından daha hızlı olabilir.