सूची <T> धागा सुरक्षा

Question

मैं सुरक्षित नीचे कोड

var processed = new List<Guid>(); 
Parallel.ForEach(items, item => 
{ 
    processed.Add(SomeProcessingFunc(item)); 
}); 

उपयोग कर रहा हूँ ऊपर कोड धागा है? क्या संसाधित सूची दूषित होने का मौका है? या मुझे जोड़ने से पहले लॉक का उपयोग करना चाहिए?

var processed = new List<Guid>(); 
Parallel.ForEach(items, item => 
{ 
    lock(items.SyncRoot) 
     processed.Add(SomeProcessingFunc(item)); 
}); 

धन्यवाद।

Answer 1

नहीं! यह बिल्कुल सुरक्षित नहीं है, क्योंकि processed.Add नहीं है। आप निम्न कार्य कर सकते हैं:

items.AsParallel().Select(item => SomeProcessingFunc(item)).ToList(); 

ध्यान रखें कि Parallel.ForEach अनुक्रम के प्रत्येक तत्व के लिए जरूरी कार्यों के लिए ज्यादातर बनाया गया था। आप क्या करते हैं मानचित्र है: अनुक्रम के प्रत्येक मान को प्रोजेक्ट करें। Select के लिए बनाया गया था। AsParallel इसे सबसे कुशल तरीके से धागे में फैलाता है।

इस कोड को सही ढंग से काम करता है:

var processed = new List<Guid>(); 
Parallel.ForEach(items, item => 
{ 
    lock(items.SyncRoot) 
     processed.Add(SomeProcessingFunc(item)); 
}); 

लेकिन बहु सूत्रण के मामले में कोई मतलब नहीं है। प्रत्येक पुनरावृत्ति बल पर lock आईएनजी पूरी तरह अनुक्रमिक निष्पादन बलों, धागे का गुच्छा एकल धागे के लिए इंतजार कर रहा है।

Answer 2

Jon Skeet से शब्दों में इससे पहले कि वह यहाँ हो जाता है:

नेट 4 में Parellel एक्सटेंशन के हिस्से के रूप में, वहाँ कई नए संग्रह एक नया System.Collections.Concurrent नाम स्थान में हैं। अपेक्षाकृत कम लॉकिंग के साथ, समवर्ती एकाधिक थ्रेड से संचालन के चेहरे में सुरक्षित होने के लिए डिज़ाइन किया गया है।

इनमें IProducerConsumerCollection<T>, BlockingCollection<T>, ConcurrentBag<T>, ConcurrentQueue<T>, ConcurrentStack<T>, and ConcurrentDictionary<TKey, TValue> शामिल हैं।

Answer 3

उपयोग:

var processed = new ConcurrentBag<Guid>(); 

parallel foreach loop - odd behavior देखें।

Answer 4

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

यदि आप गारंटी दे सकते हैं कि सरणी एड पर आकार बदल नहीं जाएगी, तो आप पढ़ने के दौरान जोड़ना सुरक्षित हो सकते हैं, लेकिन मुझे उस पर उद्धरण न दें।

लेकिन वास्तव में, एक सूची एक सरणी के लिए एक इंटरफ़ेस है।

Answer 5

एंड्री की answer के रूप में विकल्प:

items.AsParallel().Select(item => SomeProcessingFunc(item)).ToList(); 

तुम भी लिख सकता है

items.AsParallel().ForAll(item => SomeProcessingFunc(item)); 

इस क्वेरी इसके पीछे यह है कि और अधिक कुशल क्योंकि कोई मर्ज की आवश्यकता है, MSDN बनाता है। सुनिश्चित करें कि SomeProcessingFunc फ़ंक्शन थ्रेड-सुरक्षित है। और मुझे लगता है, लेकिन इसका परीक्षण नहीं किया गया है, अगर आपको किसी अन्य धागे (जोड़ना या निकालना) तत्वों में संशोधित किया जा सकता है, तो आपको अभी भी लॉक की आवश्यकता है।

Answer 6

का उपयोग प्रकार कुछ

var bag = new ConcurrentBag<List<Something>>; 
var items = GetAllItemsINeed(); 
Parallel.For(items,i =>       
    { 
     bag.Add(i.DoSomethingInEachI()); 
    });