PLINQ

Question

के साथ शून्य लौट रहा है मेरे पास आईनेमरेबल के लिए एक विस्तार विधि है जो तब संग्रह के माध्यम से पुन: सक्रिय होती है, अपना व्यवसाय कर रही है, और फिर एक नया आईनेमरेबल लौटाती है।

मैंने PLINQ का उपयोग करके PLINQ का उपयोग करने का प्रयास किया है। AsParallel()। ForAll() जो पुनरावृत्तियों को महत्वपूर्ण रूप से गति देता है (जो निश्चित रूप से करना चाहिए) हालांकि जब संग्रह वापस किया जाता है, तो उस संग्रह में अक्सर कुछ वस्तुएं होती हैं शून्य हैं

मुझे लगता है कि ऐसा हो सकता है क्योंकि यह सभी 'व्यवसाय' को पूरा करने का मौका मिलने से पहले संग्रह वापस कर रहा है? अगर मैं डीबग करता हूं और ब्रेकपॉइंट में डालता हूं, तो कोई शून्य नहीं होती है।

क्या इस तरह के 'ऑपरेशन को पूरा करने के लिए प्रतीक्षा करें' विधि है जिसका उपयोग मुझे करना चाहिए?

संपादित करें: थोड़ा स्पष्ट होने के लिए, फ़ोरल में व्यवसाय तर्क है, गुणों को संशोधित करना आदि। कुछ चुनने के बजाय, एक क्रिया को लूप करना आवश्यक है।

Answer 1

उत्तर पर लौटने का मतलब है, क्योंकि ForAll विधि कुछ भी वापस नहीं करता है। यह उस प्रतिनिधि को आमंत्रित करता है जिसे आप संग्रह के सभी तत्वों के लिए समानांतर में निर्दिष्ट करते हैं। मुझे लगता है कि होता है कि अपने कोड इस तरह दिखता है:

data.AsParallel().ForAll(() => /* calculate and store result somewhere */); 
// more code 

सभी प्रतिनिधियों को पूरा करने के लिए के लिए ForAll विधि इंतजार नहीं करता, इसलिए more code सभी प्रतिनिधियों को पूरा करने से पहले निष्पादित कर सकते हैं (और आप भी store result somewhere में सावधान रहने की जरूरत है ! बिट है, क्योंकि यह कई प्रतिनिधियों के लिए एक समय पर हो सकता है)

मुझे लगता है कि कोड Select पद्धति का उपयोग करके अधिक सुंदर ढंग से फिर से लिखा जा सकता है:

var res = data.AsParallel().Select(() => /* calculate the result */); 

इस cas में ई, प्रतिनिधि बस परिणाम देता है। Where विधि सभी परिणामों को एकत्रित करती है और जब आप IEnumerable पर वापस आते हैं, तो यह गारंटी देता है कि सभी प्रतिनिधियों ने गणना की है।

Answer 2

ForAll() विलय नहीं करता है, और तुरंत लौटाता है। Parallel.ForEach() शायद वह कार्यक्षमता है जिसे आप ढूंढ रहे हैं।

यानी बजाय:

collection.AsParallel().ForAll(t=>t.doWork());

कुछ

तरह

Parallel.ForEach(collection.AsParallel(), t=>t.doWork());