3

Tenho o seguinte problema, preciso rodar o mesmo método N vezes num for e saber quando todas as threads já terminaram de rodar ela.

Precisava de algo tipo assim:

foreach (MeuObjeto obj in lstObj)
{
    new Thread(delegate() { MetodoX(obj ); }).Start();             
}  
metodoY(); // só rodar depois que todas as thread  acima já tiverem terminado.

2 Respostas 2

2

É possível fazer isso usando Parallels (i.e. PLINQ) ou Tasks. Eu recomendo que use Tasks, pois provavelmente o PLINQ em algum momento se tornará obsoleto em favor do anterior.

Veja como fazer:

  • usando o método ForAll do PLINQ... é a que fica mais simples de todas:

    lstObj.AsParallel().ForAll(MetodoX);
    metodoY();
    
  • usando Task.WhenAll: chamada simples, método alterado

    var manyTasks = lstObj.Select(MetodoX); // a chamada fica símples
    Task.WhenAll(manyTasks).Wait();
    metodoY();
    

    Sendo que o MetodoX teria de ser mudado também para usar async e await:

    private async Task MetodoX(MeuObjeto obj)
    {
        await Task.Yield(); // primeira linha do método deve ser um Yield
    
  • usando Task.WhenAll e Task.Run: chamada menos simples, método original

    var manyTasks = lstObj.Select(x => Task.Run(() => MetodoX(x)));
    Task.WhenAll(manyTasks).Wait();
    metodoY();
    

Se você ainda assim não quiser usar nenhuma dessas alternativas, não quiser usar LINQ, nem PLINQ, nem Tasks, e quiser manipular Threads na mão, então pode fazer assim:

var threads = new List<Thread>();
foreach (string obj in lstObj)
    threads.Add(new Thread(delegate() { MetodoX(obj); }));

foreach (var thread in threads)
    thread.Start();

foreach (var thread in threads)
    thread.Join();
2

É possível usar Tasks conforme a recomendação do Miguel Anelo e fazer de forma simplificada sem se preocupar com o mecanismo:

using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
                    
public class Program {
    public static void Main() {
        var lstObj = new List<int> { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13 };
        Parallel.ForEach(lstObj, obj => MetodoX(obj));
        Console.WriteLine("Fim"); //aqui poderia ser o MetodoY()
    }
    public static void MetodoX(int obj) {
        Console.WriteLine($"ThreadID: {Thread.CurrentThread.ManagedThreadId, 3}, Valor: {obj}");
    }
}

Veja funcionando no ideone. E no .NET Fiddle. Também coloquei no GitHub para referência futura.

De uma maneira geral não é recomendado usar Threads brutas até que exista um bom motivo para usar.

Você deve fazer log-in para responder a esta pergunta.

Esta não é a resposta que você está procurando? Pesquise outras perguntas com a tag .