समानांतर foreach, और कतार

Question

प्रत्येक पाश प्रक्रिया एक कतार में आइटम ऐसी है कि इसके लिए एक समानांतर है करने के लिए क्या यह संभव है:

1. केवल आइटम प्रक्रिया किये जा रहे
2. विराम को हटा जब तक नए आइटम जोड़ रहे हैं कतार में

संपादित करें: यह System.Threading.Tasks 'Parallel.ForEach कार्यक्षमता के संबंध में है

Answer 1

प्रतिक्रियाशील एक्सटेंशन का उपयोग करके कतार की सदस्यता लें और प्रत्येक आइटम को नए कार्य में निष्पादित करें। आपको नए आइटम को अवरुद्ध या इंतजार नहीं करना पड़ेगा क्योंकि इसे आपके सब्सक्राइब लैम्ब्डा पर धकेल दिया जाएगा और आपका निष्पादन/प्रसंस्करण समानांतर होगा।

http://rxwiki.wikidot.com/101samples

Answer 2

मुझे लगता है कि यह संभव हो सकता है अगर कतार ठोस impleme ntation सिंक्रनाइज़ किया गया है, मूल रूप से यह एक उपभोक्ता उत्पादक परिदृश्य है।

Answer 3

ऐसा लगता है जैसे आप क्लासिक निर्माता/उपभोक्ता स्थिति के बारे में बात कर रहे हैं। यह हमेशा मुझे आश्चर्यचकित करता है कि इस मॉडल के लिए .NET में निर्मित अधिक प्रत्यक्ष समर्थन नहीं है। मैं निकटतम में आया हूं। नेट एक समय में समेकन और समन्वय रनटाइम के अंदर छिपा हुआ था, जो माइक्रोसॉफ्ट रोबोटिक्स सूट का हिस्सा था। शुभकामनाएं अब इसे ढूंढ रही हैं।

लेकिन एक बार जब आप जानते हैं कि क्या खोजना है, तो एक त्वरित Google चेक कुछ अन्य संभावित विकल्प प्रदान करता है।

Answer 4

इस तरह का प्रयोग करें BlockingCollection कुछ: बहुत

var bc = new BlockingCollection<int>(); 
Task.Factory.StartNew(() => 
    { 
     ParallelOptions options = new ParallelOptions 
      { 
       MaxDegreeOfParallelism = 30 
      }; 
     Parallel.ForEach(bc.GetConsumingEnumerable(), options, i => { }); 
    });