फ़ोरैच लूप

Question

में एक नया धागा शुरू करना मेरे पास ऑब्जेक्ट्स की एक सूची है और मैं उस सूची पर लूप करना चाहता हूं और वर्तमान ऑब्जेक्ट में गुजरने वाला एक नया थ्रेड शुरू करना चाहता हूं।

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

यह परीक्षण कोड मैंने लिखा

class Program 
{ 
    static void Main(string[] args) 
    { 
     TestClass t = new TestClass(); 
     t.ThreadingMethod(); 
    } 
} 

class TestClass 
{ 
    public void ThreadingMethod() 
    { 
     var myList = new List<MyClass> { new MyClass("test1"), new MyClass("test2") }; 

     foreach(MyClass myObj in myList) 
     { 
      Thread myThread = new Thread(() => this.MyMethod(myObj)); 
      myThread.Start(); 
     } 
    } 

    public void MyMethod(MyClass myObj) { Console.WriteLine(myObj.prop1); } 
} 

class MyClass 
{ 
    public string prop1 { get; set; } 

    public MyClass(string input) { this.prop1 = input; } 
} 

है

मेरी मशीन पर उत्पादन

test2 
test2 

है, लेकिन मैं यह उम्मीद

test1 
test2 

होने के लिए मैं धागा लाइनों को बदलने की कोशिश की

ThreadPool.QueueUserWorkItem(x => this.MyMethod(myObj)); 

लेकिन धागे में से कोई भी शुरू नहीं हुआ।

मुझे लगता है कि मुझे केवल गलतफहमी है कि धागे कैसे काम करते हैं। क्या कोई मुझे सही दिशा में इंगित कर सकता है और मुझे बता सकता है कि मैं क्या गलत कर रहा हूं?

Answer 1

ऐसा इसलिए है क्योंकि आप गलत दायरे में एक चर पर बंद कर रहे हैं। Closing over the loop variable considered harmful

Answer 2

समस्या यह है कि आप सबसे वर्तमान मूल्य का उपयोग कर रहे है:

foreach(MyClass myObj in myList) 
    { 
     MyClass tmp = myObj; // Make temporary 
     Thread myThread = new Thread(() => this.MyMethod(tmp)); 
     myThread.Start(); 
    } 

जानकारी के लिए, मैं इस सटीक विषय पर एरिक Lippert की पोस्ट पढ़ने की सलाह देते हैं: समाधान यहाँ foreach पाश में एक अस्थायी उपयोग करने के लिए है आपके बंद होने के अंदर वस्तु का। इसलिए, धागे का प्रत्येक आमंत्रण एक ही मूल्य को देख रहा है। इसे पाने के लिए, मान को स्थानीय चर में कॉपी करें:

foreach(MyClass myObj in myList) 
{ 
    MyClass localCopy = myObj; 
    Thread myThread = new Thread(() => this.MyMethod(localCopy)); 
    myThread.Start(); 
} 

Answer 3

रीड के उत्तर (+1) के साथ सहमत हैं।

मैं जोड़ता हूं कि यदि आप .NET 4 पर हैं, तो आप समस्या के इस वर्ग को हल करने के लिए कार्य समांतर लाइब्रेरी को देखना चाह सकते हैं। विशेष रूप से इस मामले के लिए, Parallel.ForEach() पर एक नज़र डालें।

Answer 4

यदि अनुक्रम में कोई फर्क नहीं है की तुलना में

Parallel.ForEach(myList, obj => this.MyMethod(obj)); 

Write a Simple Parallel.ForEach Loop

Answer 5

के लिए जाना मैं इस तरह से पसंद करते हैं:

public void ThreadingMethod() 
{ 
    var myList = new List<MyClass> { new MyClass("test1"), new MyClass("test2") }; 


Parallel.ForEach(myList, new ParallelOptions() { MaxDegreeOfParallelism = 100 }, 
     (myObj, i, j) => 
     { 
      MyMethod(myObj); 
     }); 

} 

नहीं

हालांकि परीक्षण किया ....