बचना ओवरलैपिंग जब SubscribeOn (Scheduler.TaskPool)

Question

मैं कुछ आरएक्स का उपयोग कर कोड है, एक से अधिक थ्रेड से कहा जाता है कि करता है का उपयोग कर OnNext Rx में कॉल:

subject.OnNext(value); // where subject is Subject<T> 

मैं चाहता हूँ मूल्यों पृष्ठभूमि में प्रोसेस किया है, इसलिए मेरी सदस्यता

subscription = subject.ObserveOn(Scheduler.TaskPool).Subscribe(value => 
{ 
    // use value 
}); 

मैं वास्तव में परवाह नहीं है जो धागे नमूदार से बाहर आने के मानों का प्रबंधन, जब तक काम TaskPool में डाल दिया है और मौजूदा धागा ब्लॉक नहीं करता है। हालांकि, मेरे ऑननेक्स्ट प्रतिनिधि के अंदर 'मूल्य' का उपयोग थ्रेड सुरक्षित नहीं है। फिलहाल, अगर अवलोकन के माध्यम से बहुत सारे मूल्य चल रहे हैं तो मुझे अपने ऑननेक्स्ट हैंडलर को ओवरलैपिंग कॉल मिल रही हैं।

मैं अपने ऑननेक्स्ट प्रतिनिधि को केवल एक लॉक जोड़ सकता हूं, लेकिन यह चीजों को करने का आरएक्स तरीका नहीं लगता है। यह सुनिश्चित करने का सबसे अच्छा तरीका क्या है कि मेरे पास केवल एक ही समय में मेरे ऑननेक्स्ट हैंडलर को एक कॉल है, जब मेरे पास subject.OnNext(value); पर कॉल करने वाले एकाधिक थ्रेड हैं?

Answer 1

MSDN

पर

Using Subjects से डिफ़ॉल्ट रूप से, विषयों धागे भर में किसी भी तुल्यकालन प्रदर्शन नहीं करते। [...] यदि, हालांकि, आप शेड्यूलर का उपयोग करके पर्यवेक्षकों को आउटगोइंग कॉल सिंक्रनाइज़ करना चाहते हैं, तो आप ऐसा करने के लिए सिंक्रनाइज़ विधि का उपयोग कर सकते हैं।

तो ब्रैंडन टिप्पणियों में कहता है कि आपको इस विषय को सिंक्रनाइज़ करना चाहिए और अपने निर्माता धागे को सौंपना चाहिए। जैसे

var syncSubject = Subject.Synchronize(subject); 

// syncSubject.OnNext(value) can be used from multiple threads 

subscription = syncSubject.ObserveOn(TaskPoolScheduler.Default).Subscribe(value => 
{ 
    // use value 
}); 

Answer 2

आप अपने स्वयं के IObserver को लागू करने का प्रयास कर सकते हैं जो इसकी ऑनएक्स्ट विधि में लॉक लागू करेगा। बस एक साधारण सजावट: लॉक लागू करें, आंतरिक ऑननेक्स्ट पर कॉल करें, लॉक को हटा दें।

फिर आप IObservable पर एक एक्सटेंशन विधि को कार्यान्वित कर सकते हैं, जैसे कुछ। थ्रेडसेफ()।

Answer 3

मुझे लगता है कि आप सिंक्रनाइज़() एक्सटेंशन विधि की तलाश में हैं। हालिया रिलीज (2011 के उत्तरार्ध में) में प्रदर्शन सुधार प्राप्त करने के लिए वे आरएक्स टीम ने अवलोकन अनुक्रम उत्पादकों की अनुक्रमिक प्रकृति के बारे में धारणाओं को आराम दिया। हालांकि ऐसा लगता है कि आप इन मान्यताओं को तोड़ते हैं (बुरी चीज नहीं) लेकिन आरएक्स को वापस खेलने के लिए उपयोगकर्ताओं की अपेक्षा करने के लिए, आपको अनुक्रम को सिंक्रनाइज़ करना चाहिए ताकि यह सुनिश्चित हो सके कि यह अनुक्रमिक है।

Answer 4

यहां कुछ और स्पष्टीकरण Synchronize (दूसरा अनुच्छेद) का उपयोग क्यों करें। दूसरी तरफ सिंक्रनाइज़ डेडलॉक में भाग ले सकता है यदि आप सक्रिय रूप से अपने कोड में लॉकिंग का उपयोग करते हैं, कम से कम मैंने ऐसी स्थिति देखी है।