Tüketicilerin bir ağacın her seviyesinde bir miktar çalışma yaptıkları, daha sonra ağaca tekrar girmeleri ve aynı işi bir sonraki aşamada gerçekleştirmeleri gerektiği bir sorun var.Üreticiler ayrıca tüketiciler olduğunda Üretici/Tüketici modelindeki engelleme kodunu nasıl kullanırım? - Nasıl sona ererim?
Paralel olarak çalıştırmak için ConcurrentBag/BlockingCollection vb. Kullanmak istiyorum. Bu senaryoda, sıra tüketiciler, aynı zamanda kuyruk üreticisidir!
Sorunum şudur: BlockingCollection'ı kullanarak, öğelerin dequeue için çok basit bir foreach mantığı yazabilirim ve yeni olanları sıralayabilirim - Sıra boş olduğunda, engelleme koleksiyonu doğru bir şekilde tıkanır ve yeni işlerin üretilmesini bekler. diğer tüketicilerden biri.
Ancak tüm tüketicilerin engellenip engellemediğini nasıl bilebilirim ?!
CompleteAdding() hakkında bir şey biliyorum, ancak bu, tam olarak tamamlandığınız zaman, tüm üreticilerin üretildiği ve kuyruğun boş olduğu ve bunların hepsinin engelleneceğinden dolayı sunulmayacağı anlamına gelmez. CompleteAdding() öğesini ayarlamak için "ücretsiz" kimse yoktur. Bunu tespit etmenin bir yolu var mı? (Engelleme sırasında tetiklenebilecek bir olay ve engellemediğinde yeniden ateş açabilecek bir olay var mı?)
Bunu elle, bir foreach kullanmadan, ancak bir süre (! Complete) döngüsünü kullanarak ve TryTake kullanarak elle yapabilirim, ancak o zaman el ile uyumaya ihtiyacım var, bu da verimsiz gibi görünüyor (ilk etapta sadece eşzamanlı koleksiyonlara karşı tıkanıklık koleksiyonuna sahip olmanın tüm nedeni!) Her zaman döngüde, TryTake yanlışsa, bir Boşta bayrağı ayarlayabilirdim ve kuyruk boşsa ve tüm iş parçacığı boşsa bir Ana kontrol var, tam bir bayrak ayarla, ama yine, bu kludgy görünüyor.
Sezgiler, bunu yapmak için Engelleme Koleksiyonu'nu kullanmanın bir yolunun olduğunu söylüyor, ancak oraya tam olarak ulaşamıyorum.
Neyse, herkes tüketiciler üreticileri ve tüm bloklar MSDN'den bu bağlantıyı size yardımcı olabilir bence
İyi soru. Dış bayraklar veya olaylarla ilgili her şey yarış koşulları için olgunlaşmış görünüyor. –
İşlemciler (kombine tüketiciler/üreticiler) çok fazla devlete sahipler veya çok fazla kaynak istiyorlar mı? Sorunu, her biri sadece bir yineleme yapmak olan Görevler oluşturma açısından yeniden atabilir misiniz? –
@Damien_The_Unbeliever: Evet, tek yineleme yapabilirim ve aslında zaten çalışıyor, ancak üretici/tüketici modelini kullanmaya çalışıyorum, çünkü bu, gelecekteki bulutta geçirilebilecek koddur. Azure Kuyruğu deposunu aynı şekilde kullanarak, genel mantığı iki uygulama arasında olabildiğince benzer tutmak isterim. Bu senaryoda, İşçilerin sıraya gireceğine karar vermek için boşta olup olmadıklarını kontrol etmek zorunda kalacağım, ancak yerel olarak mümkün olduğunca verimli olmalıyım - aynı zamanda bunu anlamak istiyorum :) –