Inicio de un nuevo hilo en un bucle foreach

Question

Tengo una lista de objetos y me gustaría pasar por encima de esa lista y comenzar un nuevo hilo, pasando el objeto actual.

He escrito un ejemplo de lo que pensé que debería hacer esto, pero no está funcionando. Específicamente, parece que los hilos se sobrescriben en cada iteración. Sin embargo, esto realmente no tiene sentido para mí porque estoy creando un nuevo objeto Thread cada vez.

Este es el código de prueba que escribí

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; } 
} 

La salida en mi máquina es

test2 
test2 

pero yo esperaba que fuera

test1 
test2 

He intentado cambiar las líneas de hilo a

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

pero ninguno de los hilos se inició.

Creo que tengo un malentendido acerca de cómo se supone que los hilos funcionan. ¿Puede alguien señalarme en la dirección correcta y decirme qué estoy haciendo mal?

Answer 1

Esto se debe a que está cerrando una variable en el ámbito incorrecto. La solución a este problema es utilizar un temporal en el bucle foreach:

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

Para más detalles, recomiendo leer el post de Eric Lippert sobre este tema exacto: Closing over the loop variable considered harmful

Answer 2

El problema es que está utilizando el valor más actual del objeto dentro de su cierre. Entonces, cada invocación del hilo está buscando el mismo valor. Para evitar esto, copie el valor en una variable local:

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

Answer 3

De acuerdo con la respuesta de Reed (+1).

Yo agregaría que si está en .NET 4, es posible que desee consultar la Biblioteca de tareas paralelas para resolver esta clase de problema. Específicamente para este caso, eche un vistazo a Parallel.ForEach().

Answer 4

si la secuencia no es materia de ir a

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

Write a Simple Parallel.ForEach Loop

Answer 5

prefiero de esta manera:

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); 
     }); 

} 

no

probado aunque ....