Как заблокировать новые потоки, пока не будут созданы и запущены все потоки

Question

Я создаю небольшое приложение, имитирующее скачки, чтобы получить некоторые базовые навыки в работе с потоками.

Мой код содержит этот цикл:

 for (int i = 0; i < numberOfHorses; i++) 
     { 
      horsesThreads[i] = new Thread(horsesTypes[i].Race); 
      horsesThreads[i].Start(100); 
     } 

Для того, чтобы сохранить гонку «справедливый», я искал способ сделать все вновь созданные темы ждать, пока остальные темы не являются и только затем запустите их все, чтобы начать использовать их методы (обратите внимание, что я понимаю, что технически нити не могут запускаться в то же время)

Итак, в основном, я ищу что-то вроде этого :

 for (int i = 0; i < numberOfHorses; i++) 
     { 
      horsesThreads[i] = new Thread(horsesTypes[i].Race); 
     } 
     Monitor.LaunchThreads(horsesThreads); 

Answer 1

Класс Barrier предназначен для поддержки этого.

Вот пример:

using System; 
using System.Threading; 

namespace Demo 
{ 
    class Program 
    { 
     private void run() 
     { 
      int numberOfHorses = 12; 

      // Use a barrier with a participant count that is one more than the 
      // the number of threads. The extra one is for the main thread, 
      // which is used to signal the start of the race. 

      using (Barrier barrier = new Barrier(numberOfHorses + 1)) 
      { 
       var horsesThreads = new Thread[numberOfHorses]; 

       for (int i = 0; i < numberOfHorses; i++) 
       { 
        int horseNumber = i; 
        horsesThreads[i] = new Thread(() => runRace(horseNumber, barrier)); 
        horsesThreads[i].Start(); 
       } 

       Console.WriteLine("Press <RETURN> to start the race!"); 
       Console.ReadLine(); 

       // Signals the start of the race. None of the threads that called 
       // SignalAndWait() will return from the call until *all* the 
       // participants have signalled the barrier. 

       barrier.SignalAndWait(); 

       Console.WriteLine("Race started!"); 
       Console.ReadLine(); 
      } 
     } 

     private static void runRace(int horseNumber, Barrier barrier) 
     { 
      Console.WriteLine("Horse " + horseNumber + " is waiting to start."); 
      barrier.SignalAndWait(); 
      Console.WriteLine("Horse " + horseNumber + " has started."); 
     } 

     private static void Main() 
     { 
      new Program().run(); 
     } 
    } 
} 

[EDIT] Я просто заметил, что Хенк уже упоминалось Barrier, но я оставлю этот ответ здесь, потому что у него есть некоторые примеры кода.

Answer 2

Threading не обещает справедливости или детерминированных результатов, поэтому это не очень хороший способ имитировать гонку.

Сказав это, есть некоторые объекты синхронизации, которые могут делать то, что вы просите. Я думаю, что класс Barrier (Fx 4+) - это то, что вы хотите.

Answer 3

Я бы посмотрел на ManualResetEvent в качестве ворот; внутриThread, декремент счетчика; если он еще не равен нулю, подождите на воротах; в противном случае откройте ворота. В принципе:

using System;  
using System.Threading; 
class Program 
{ 
    static void Main() 
    { 
     ManualResetEvent gate = new ManualResetEvent(false); 
     int numberOfThreads = 10, pending = numberOfThreads; 
     Thread[] threads = new Thread[numberOfThreads]; 
     ParameterizedThreadStart work = name => 
     { 
      Console.WriteLine("{0} approaches the tape", name); 
      if (Interlocked.Decrement(ref pending) == 0) 
      { 
       Console.WriteLine("And they're off!"); 
       gate.Set(); 
      } 
      else gate.WaitOne(); 
      Race(); 
      Console.WriteLine("{0} crosses the line", name); 
     }; 
     for (int i = 0; i < numberOfThreads; i++) 
     { 
      threads[i] = new Thread(work); 
      threads[i].Start(i); 
     } 
     for (int i = 0; i < numberOfThreads; i++) 
     { 
      threads[i].Join(); 
     } 
     Console.WriteLine("all done"); 

    } 
    static readonly Random rand = new Random(); 
    static void Race() 
    { 
     int time; 
     lock (rand) 
     { 
      time = rand.Next(500,1000); 
     } 
     Thread.Sleep(time); 
    } 

}