Problema di multithreading che aggiorna il valore

Question

Ho difficoltà a capire perché il multithreading non riesce ad aggiornare i valori prima del completamento del thread. Il thread separato ha una propria copia dei riferimenti o dei valori?

In caso contrario, la mia comprensione il codice qui sotto dovrebbe funzionare correttamente quando MyMethod viene chiamato, ma spesso non creare istanze di alcuni oggetti MyType nella matrice prima della thread.IsAlive diventa falso:

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

È necessario assegnare il valore della variabile loop a una variabile locale. In caso contrario, è possibile che la prima esecuzione di sia stata eseguita dopo l', pertanto non viene mai chiamato FillObjects(0) e pertanto non viene mai assegnato obj[0].

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

Su un computer multiprocessore (che è necessario disporre) i risultati scritti in una posizione di memoria in un thread potrebbero non essere visibili in un altro thread a causa della memorizzazione nella cache. Utilizzare Thread.VolatileRead e Thread.VolatileWrite leggere per leggere e scrivere "attraverso" la cache.

Cfr. the chapter on threading in c# 3.0 in a Nutshell per una spiegazione. (Cerca la domanda "È possibile che il metodo Wait scriva" False "?". Questo esempio è fondamentalmente il tuo caso.)