스레드 우선순위

스레드 우선순위

 

스레드 우선순위에 대한 다른 가능한 옵션을 설명하며,또한 스레드에 CPU 시간을 어떻게 할당할지 결정하는 스레드 우선 순위를 설정하는 방법을 제시한다.

 

 

 

 

 

class Program

       {

              static void Main(string[] args)

              {

                 // 다른 두 스레드를 정의한 메인 프로그램을 시작한다.

                      //메인 스레드 우선순위 값을 출력한후,활용가능 한 모든 코어에서 두 스레드를 실행한다.

                     //연산 코어가 하나 이상이 있다면, 2초 안에 첫 결과를 얻는다.

                    //가장 높은 우선순위인 스레드는 보통 더 반복해서 계산 해야한다.

                  //다만, 두값이 서로 가까워야 한다. 하지만 어떤 다른 프로그램이

                   //모든 CPU 코어를 적재해 실행하고 있을 때는 상황이 상당히 달라질수 있다.

                     Console.WriteLine("Current thread priority: {0}", Thread.CurrentThread.Priority);

                     Console.WriteLine("Running on all cores available");

                     

                     RunThreads();

                     Thread.Sleep(TimeSpan.FromSeconds(2));

                     Console.WriteLine("Running on a single core");

           //이상황을 재연하기 위해 운영체제가 단일 코거 (번호1)에서 모든 스레드를 싱행하도록 지시하는

          //.ProcessorAffinity 옵션을 설정한다.

         //지금 결과가 아주 달라져야 하며, 계산에만 2초이상이 걸린다. 

         //이런 일이 발생하는 이유는 CPU 코어가 높은 우선순위를 갖는 스레드를 대부분 실행하되, 나머지 스레드에 매우 적은 시간을 주기 때문이다.

        //운영체제가 스레드에 어떻게 우선수위를 매기는지 보여주는것에 주목하길 바란다.

                     Process.GetCurrentProcess().ProcessorAffinity = new IntPtr(1);

                     RunThreads();

              }

              static void RunThreads()

              {

                     var sample = new ThreadSample();

                     var threadOne = new Thread(sample.CountNumbers);

                     threadOne.Name = "ThreadOne";

                     var threadTwo = new Thread(sample.CountNumbers);

                     threadTwo.Name = "ThreadTwo";

                   //첫 번째 스레드는 가장 높은 우선 순위인  ThreadPriority.Highest를 갖는 반면에

                     threadOne.Priority = ThreadPriority.Highest;

                     //두번째 스레드는 가장 낮은 threadTwo.Priority = ThreadPriority.Lowest;를 갖는다

                     threadTwo.Priority = ThreadPriority.Lowest;

                     threadOne.Start();

                     threadTwo.Start();

                     Thread.Sleep(TimeSpan.FromSeconds(2));

                     sample.Stop();

 

              }

              class ThreadSample

              {

                     private bool _isStopped = false;

                     public void Stop()

                     {

                           _isStopped = true;

                     }

                     public void CountNumbers()

                     {

                           long counter = 0;

                           while (!_isStopped)

                           {

                                  counter++;

                           }

                           Console.WriteLine("{0} with {1,11} priority " +

                                                "has a count = {2,13}", Thread.CurrentThread.Name,

                                                Thread.CurrentThread.Priority,

                                                counter.ToString("N0"));

                     }

              }

       }

결과