CountDownEvent не будет ждать, пока все сигналы не будут вызваны

Question

Я смотрю этот сайт для threads. Я играл с кодом, чтобы ответить на вопрос: «Does CountdownEvent остановить все потоки?» ответа у меня нет. Затем я решил сыграть с номером, который передается в CountdownEvent. Вот мой код

namespace ThreadPractice 
{ 
    class Program 
    { 
     static CountdownEvent CountDown = new CountdownEvent(4); 
     static void Main() 
     { 
      new Thread(() => SaySomething("I am Thread one.")).Start(); 
      new Thread(() => SaySomething("I am thread two.")).Start(); 
      new Thread(() => SaySomethingElse("Hello From a different Thread")).Start(); 
      new Thread(() => SaySomething("I am Thread Three.")).Start(); 
      CountDown.Wait(); 
      Console.Read(); 
     } 

     static void SaySomething(string Something) 
     { 
      Thread.Sleep(1000); 
      Console.WriteLine(Something); 
      CountDown.Signal(); 
     } 

     static void SaySomethingElse(string SomethingElse) 
     { 
      Thread.Sleep(1000); 
      Console.WriteLine(SomethingElse); 
     } 
    } 
} 

Я ожидаю, что поток, вызывающий SaySomethingELse() для выполнения, но остальные потоки выполняются так же, даже если только четыре сигналы были вызваны.

Почему это так?

Спасибо,

dhoehna

Answer 1

Он смотрит на меня, как вы получили Signal и Wait навыворот. Если вы хотите, чтобы звонки SaySomething дождались обратного отсчета до 0, вы должны позвонить Wait. Вот пример:

using System; 
using System.Threading; 

namespace ThreadPractice 
{ 
    class Program 
    { 
     static CountdownEvent CountDown = new CountdownEvent(4); 
     static void Main() 
     { 
      new Thread(() => SaySomething("I am Thread one.")).Start(); 
      new Thread(() => SaySomething("I am thread two.")).Start(); 
      new Thread(() => SaySomethingElse("Hello From a different Thread")).Start(); 
      new Thread(() => SaySomething("I am Thread Three.")).Start(); 
      for (int i = 0; i < 4; i++) 
      { 
       Console.WriteLine("Calling Signal (time #{0})", i); 
       CountDown.Signal(); 
       Thread.Sleep(1000); 
      } 
      Console.WriteLine("Done"); 
     } 

     static void SaySomething(string Something) 
     { 
      CountDown.Wait(); 
      Console.WriteLine(Something); 
     } 

     static void SaySomethingElse(string SomethingElse) 
     { 
      Thread.Sleep(1000); 
      Console.WriteLine(SomethingElse); 
     } 
    } 
} 

Выход:

Calling Signal (time #0) 
Hello From a different Thread 
Calling Signal (time #1) 
Calling Signal (time #2) 
Calling Signal (time #3) 
I am Thread one. 
I am Thread Three. 
I am thread two. 
Done 

Answer 2

Хммм ... он смотрит на меня, как вы хотите, чтобы ждать, пока все нити, чтобы закончить, прежде чем продолжить в главном потоке. Если это так, вы забыли Signal() в SaySomethingElse(). Это не позволяет CountDown.CurrentCount достигать 0 (ноль), и поэтому ваш основной поток «застревает». Вы устанавливаете его на 4, и он уменьшается до 1 (один). Исправить это, и вы должны получить желаемое? Результаты:

class Program 
{ 
    static CountdownEvent CountDown = new CountdownEvent(4); 
    static void Main() 
    { 
     new Thread(() => SaySomething("I am Thread one.")).Start(); 
     new Thread(() => SaySomething("I am thread two.")).Start(); 
     new Thread(() => SaySomethingElse("Hello From a different Thread")).Start(); 
     new Thread(() => SaySomething("I am Thread Three.")).Start(); 

     CountDown.Wait(); 

     Console.WriteLine("Done!"); 
     Console.Read(); 
    } 

    static void SaySomething(string Something) 
    { 
     Thread.Sleep(1000); 
     Console.WriteLine(Something); 
     CountDown.Signal(); 
    } 

    static void SaySomethingElse(string SomethingElse) 
    { 
     Thread.Sleep(1000); 
     Console.WriteLine(SomethingElse); 
     CountDown.Signal(); 
    } 
} 

Выход:

I am Thread one. 
I am thread two. 
Hello From a different Thread 
I am Thread Three. 
Done!