Multithreading-Problem beim Aktualisieren des Werts

Question

Ich habe Schwierigkeiten zu verstehen, warum das Multithreading keine Werte aktualisieren kann, bevor der Thread abgeschlossen ist. Hat der separate Thread eine eigene Kopie der Referenzen oder Werte?

Wenn nicht, nach meinem Verständnis der Code unten sollte ordnungsgemäß funktionieren, wenn MyMethod genannt wird, aber oft ist es nicht Instanzen einiger MyType Objekte im Array erstellen, bevor die thread.IsAlive wird false:

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

Sie müssen den Wert der Schleifenvariablen einer lokalen Variablen zuweisen. Andernfalls ist es möglich, dass die erste Ausführung von FillObjects(i) ausgeführt wird, nachdem i inkrementiert wurde, so dass FillObjects(0) nie aufgerufen wird und daher obj[0] niemals zugewiesen wird.

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

Auf einem Multi-Prozessor-Rechner (den Sie haben müssen) sind Ergebnisse, die an einen Speicherort in einem Thread geschrieben wurden, aufgrund des Caching möglicherweise nicht in einem anderen Thread sichtbar. Verwenden Sie Thread.VolatileRead und Thread.VolatileWrite lesen, um "durch" den Cache zu lesen und zu schreiben.

Cf. the chapter on threading in c# 3.0 in a Nutshell für eine Erklärung. (Suchen Sie nach der Frage "Ist es möglich, dass die Wait-Methode" False "schreibt? Dieses Beispiel ist grundsätzlich Ihr Fall.)