थ्रेड-सेफ़ बुफर्ड अवलोकन योग्य प्राथमिकता कतार?

Question

मैं एक प्रोग्राम लिख रहा हूं जहां एक थ्रेड को कतार पर वस्तुओं को धक्का देने की आवश्यकता होती है, और एक या अधिक धागे कतार से वस्तुओं को पॉप करते हैं और उन्हें संसाधित करते हैं। स्मृति से बाहर निकलने से बचने के लिए, जब कतार पूरी हो जाती है तो मैं निर्माता धागा को सोना चाहता हूं। कुछ वस्तुओं की तुलना दूसरों की तुलना में अधिक प्राथमिकता है, इसलिए मैं उनको पहले संसाधित करना चाहता हूं। यदि वस्तुओं की प्राथमिकता समान है, तो मुझे वह पसंद है जिसे पहले संसाधित करने के लिए पहले जोड़ा गया था।

मैं एक WPF डेटा ग्रिड में शीर्ष 100 आइटम या तो प्रदर्शित करना चाहते हैं, तो यह भी एक यूआई धागा द्वारा पहुँचा जा करने की जरूरत है। अच्छा होगा अगर यह यूआई थ्रेड को सूचित कर सके कि एक अद्यतन भी है, यानी, IObservable लागू करता है।

वहाँ एक कंटेनर वर्ग कि यह सब करना होगा है?

बोनस अंक के लिए, मैं यकीन है कि पूरे कतार दोनों जब enqueing और dequeing बंद किया जा की जरूरत नहीं है हूँ।

.NET 4 कार्यान्वयन ठीक कर रहे हैं।

Answer 1

यदि आप .NET 4 पर हैं तो आपको Task Parallel Library पर कस्टम शेड्यूलर के साथ गंभीरता से QueuedTaskScheduler उदाहरण पर विचार करना चाहिए। मुझे यकीन नहीं है कि यह आपकी सभी आवश्यकताओं को पूरा करता है, लेकिन यह एक अच्छी शुरुआत होगी।

Answer 2

आप भाग्य एक कंटेनर की तलाश से बाहर हैं - आप एक अपने आप को लागू करने के लिए की है। प्राथमिकताओं के साथ सावधान रहें - सॉर्टिंग धीमी गति से हो जाती है। मैं क्या करता हूं कि मेरे पास एक कतार वर्ग है जो आंतरिक रूप से कई सरणी (एक प्रति प्राथमिकता - कोडित निम्न, मध्यम, उच्च) का उपयोग करता है। इस तरह मैं कभी सॉर्ट नहीं करता हूं। ताले से बचें यदि आप (बहु कोर मानते हैं) और स्पिनलॉक्स (.NET 4.0) के लिए जाते हैं, तो वे कतार परिदृश्य में तेज़/कम ओवरहेड लेते हैं।

Answer 3

मैंने जो किया है वह अतीत में कई ConcurrentQueue<T> संग्रहों को लपेटा गया है - TomTom suggests का प्रकार। यह बहुत उचित है जब आपके पास प्राथमिकताओं की संख्या कम है। उदाहरण के लिए कुछ मामलों में यह दो होने के लिए भी पर्याप्त हो सकता है: उच्च और निम्न। फिर अपने TryDequeue विधि सिर्फ इस तरह दिखता है:

public bool TryDequeue(out T item) 
{ 
    return _highItems.TryDequeue(out item) || _lowItems.TryDequeue(out item); 
} 

यह ठीक अपने प्रश्न के लिए एक व्यापक जवाब नहीं है, लेकिन शायद यह मदद कर सकते हैं आरंभ करने के लिए।