C# en Attente pour plusieurs threads pour finir

J'ai une application windows forms que je suis la vérification de tous les ports série pour voir si un périphérique est connecté.

C'est comment je le spin off de chaque thread. Le code ci-dessous est déjà filé à la sortie de l'thread gui.

foreach (cpsComms.cpsSerial ser in availPorts)
{
    Thread t = new Thread(new ParameterizedThreadStart(lookForValidDev));
    t.Start((object)ser);//start thread and pass it the port
}

Je veux que la prochaine ligne de code à attendre jusqu'à ce que tous les threads ont fini.
J'ai essayé d'utiliser un t.join là, mais cela ne les traite de façon linéaire.

  • Strictement comme une note de côté et non que vous avez demandé à ce sujet, mais vous pouvez mettre IsBackground = true sur le thread pour pas bloquer le thread principal si vous quittez l'application.
InformationsquelleAutor Andy | 2010-02-17
  1. 41
    List<Thread> threads = new List<Thread>();
foreach (cpsComms.cpsSerial ser in availPorts)
{
    Thread t = new Thread(new ParameterizedThreadStart(lookForValidDev));
    t.Start((object)ser);//start thread and pass it the port
    threads.Add(t);
}
foreach(var thread in threads)
{
    thread.Join();
}

    Modifier

    J'étais à la recherche de retour au présent, et j'aime les suivantes mieux

    availPorts.Select(ser =>
      {
          Thread thread = new Thread(lookForValidDev);
          thread.Start(ser);
          return thread;
      }).ToList().ForEach(t => t.Join());
    • C'est une bonne solution et simple. Mais dans mon cas le Système.Le filetage.Fil de discussion.Join() est visible dans l'instrumentation de profilage rapport avec la haute exclusif de la valeur temps. En dépit de cela, c'est vraiment une bonne façon.
    InformationsquelleAutor Yuriy Faktorovich
  2. 16

    Utiliser les Classes AutoResetEvent et ManualResetEvent:

    private ManualResetEvent manual = new ManualResetEvent(false);
void Main(string[] args)
{
    AutoResetEvent[] autos = new AutoResetEvent[availPorts.Count];

    manual.Set();

    for (int i = 0; i < availPorts.Count - 1; i++)
        {

        AutoResetEvent Auto = new AutoResetEvent(false);
        autos[i] = Auto;

        Thread t = new Thread(() => lookForValidDev(Auto, (object)availPorts[i]));
        t.Start();//start thread and pass it the port  

    }
    WaitHandle.WaitAll(autos);
    manual.Reset();

}


void lookForValidDev(AutoResetEvent auto, object obj)
{
    try
    {
         manual.WaitOne();
         //do something with obj 
    }
    catch (Exception)
    {

    }
    finally
    {
        auto.Set();
    }


}
    • Semble excellent!
    • auto.Set() doit être dans un bloc finally
    • Quel est le point de la ManualResetEvent ici?
    InformationsquelleAutor Islam Yahiatene
  3. 7

    La plus simple et la plus sûre façon de le faire est d'utiliser un CountdownEvent. Voir Albahari.

    • Ah, je ne savais pas que si le thread a pris fin, le Rejoindre serait de retour. Merci pour la correction.
    InformationsquelleAutor IamIC
  4. 3

    Vous pouvez utiliser un CountDownLatch:

    public class CountDownLatch
{
    private int m_remain;
    private EventWaitHandle m_event;

    public CountDownLatch(int count)
    {
        Reset(count);
    }

    public void Reset(int count)
    {
        if (count < 0)
            throw new ArgumentOutOfRangeException();
        m_remain = count;
        m_event = new ManualResetEvent(false);
        if (m_remain == 0)
        {
            m_event.Set();
        }
    }

    public void Signal()
    {
        //The last thread to signal also sets the event.
        if (Interlocked.Decrement(ref m_remain) == 0)
            m_event.Set();
    }

    public void Wait()
    {
        m_event.WaitOne();
    }
}

    Exemple comment l'utiliser:

    void StartThreads
{
    CountDownLatch latch = new CountDownLatch(availPorts.Count);

    foreach (cpsComms.cpsSerial ser in availPorts)
    {
        Thread t = new Thread(new ParameterizedThreadStart(lookForValidDev));

        //start thread and pass it the port and the latch
        t.Start((object)new Pair(ser, latch));

    }

    DoSomeWork();

    //wait for all the threads to signal
    latch.Wait();

    DoSomeMoreWork();
}

//In each thread
void NameOfRunMethod
{
    while(running)
    {
        //do work
    }

    //Signal that the thread is done running
    latch.Signal();
}
    InformationsquelleAutor Kiril
  5. 2

    Magasin le Thread résultats dans une liste, une fois qu'ils ont été générés et de réitérer la liste - au cours d'une itération appeler les rejoindre. - On encore s'inscrire de façon linéaire, mais il devrait faire ce que vous voulez.

    • tout le code source complet à ce sujet?
    InformationsquelleAutor NG.