Çoklu iş parçacığı sorunu değeri güncelleştiriliyor

Question

İş parçacığı tamamlanmadan önce çoklu iş parçacığının değerleri güncelleştiremediğini anlamakta güçlük çekiyorum. Ayrı iş parçacığı, referansların veya değerlerin kendi kopyasına sahip midir?

Değilse, benim anlayışıma için aşağıdaki kod MyMethod çağrıldığında düzgün çalışması gerekir, ancak çoğu zaman thread.IsAlive önce dizide bazı MyType nesnelerin örneklerini yaratmaz yanlış olur:

class MyClass 
{ 
    static MyType[] obj = new MyType[Environment.ProcessorCount - 1]; 
    void MyMethod() 
    { 
     Thread[] threads = new Thread[Environment.ProcessorCount - 1]; 

     for (int i = 0; i < Environment.ProcessorCount - 1; i++) 
     { 
      threads[i] = new Thread(() => FillObjects(i)); 
      threads[i].Priority = ThreadPriority.AboveNormal; 
      threads[i].Start(); 
     } 

     while (threads[i].Any(c => c.IsAlive)) 
     { 
      Thread.Sleep(50); 
     } 
    } 
    void FillObjects(int i) 
    { 
     obj[i] = new MyType(); 
     //perform actions with obj[i] to fill it with necessary values 
    } 
} 

Answer 1

Döngü değişkeninin değerini bir yerel değişkene atamanız gerekir. Aksi halde, FillObjects(i)'un ilk çalıştırılmasınınnumaralı satırdan sonra çalıştırılmasının mümkün olması dolayısıyla FillObjects(0)'un hiçbir zaman çağrılmaması ve dolayısıyla obj[0]'un hiçbir zaman atanmaması mümkündür.

void MyMethod() 
{ 
    Thread[] threads = new Thread[Environment.ProcessorCount - 1]; 

    for (int i = 0; i < Environment.ProcessorCount - 1; i++) 
    { 
     int local = i; 
     threads[i] = new Thread(() => FillObjects(local)); 
     threads[i].Priority = ThreadPriority.AboveNormal; 
     threads[i].Start(); 
    } 

    while (threads.Any(c => c.IsAlive)) 
    { 
     Thread.Sleep(50); 
    } 
} 

Answer 2

Bir işlemcideki bir bellek konumuna yazılan çok işlemcili bir makinede (sahip olmanız gereken) sonuçlar, önbelleğe alma nedeniyle başka bir iş parçacığında görünmeyebilir. Önbelleği okumak ve yazmak için Thread.VolatileRead ve Thread.VolatileWrite okumalarını kullanın.

Cf. Bir açıklama için the chapter on threading in c# 3.0 in a Nutshell. ("Bekle yönteminin" Yanlış "yazması mümkün mü?". Bu örnek temelde sizin durumunuzdur.)