쓰레드 생성, 쓰레드풀링, Task 명시

Rainbow🌈Coder 2022. 4. 15. 21:40

728x90

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread()
        {
            Console.WriteLine("hello Thread!");
        }
        static void Main(string[] args)
        {
            Thread t = new Thread(MainThread);
            t.Start();
            //별도의 쓰레드가 실행됨
            Console.WriteLine("Hello World!");
        }
    }
}

백그라운드 쓰레드

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread()
        {
            while(true)
            Console.WriteLine("hello Thread!");
        }
        static void Main(string[] args)
        {
            Thread t = new Thread(MainThread);
            //백그라운드 쓰레드로, 앞그라운드에서 돌릴지 선택할 수 있음
            t.IsBackground = true;
            t.Start();
            //별도의 쓰레드가 실행됨
            Console.WriteLine("Hello World!");
        }
    }
}

이렇게 하면 실행은 계속되고 종료되지 않는 상황이 펼쳐진다.

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread(object state)
        {
            while(true)
            Console.WriteLine("hello Thread!");
        }
        static void Main(string[] args)
        {
            Thread t = new Thread(MainThread);
            t.Name = "TestThread";
            //백그라운드 쓰레드로, 앞그라운드에서 돌릴지 선택할 수 있음
            t.IsBackground = true;
            t.Start();
            Console.WriteLine("waiting for thread!");
            t.Join(); // 백그라운드가 끝날 때 까지 기다렸다가 다음줄로 가겠다
            //별도의 쓰레드가 실행됨
            Console.WriteLine("Hello World!");
        }
    }
}

일일히 쓰레드를 만들어서 관리하기는 노가다스럽다.

그래서 사용하게 되는 쓰레드풀 개념

<쓰레드풀링>=인력사무소

쓰레드풀로 넘긴 쓰레드는 자동으로 백그라운드 쓰레드가 된다.

new Thread()로 만드는 녀석은 정직원 개념이고(계속 관리 필요)

쓰레드풀로 넘기는 쓰레드는 단기로 고용하는 대기조 알바 개념이라고 생각하면 쉽다.

알바가 넘겨 받은 할 일을 다 수행하고 끝나면 다시 대기풀로 돌아가서 일 받기를 기다리게 된다-

new 로 일일히 만들기 보다 유동적으로 준비가 된 녀석들부터 일을 시킬 수 있으니까 편리하다

또한 쓰레드풀은 최대로 돌릴 수 있을 만큼의 쓰레드가 제한이 된 상태에서 대기중이다.

무작정 쓰레도 새로 생성(고용)하는 것이 아니라 기존에 던져진 쓰레드들이 돌아와서 다음 일감을 처리하러 간다.

~~그런데 특정 일들이 너무 과하면 기존에 던져진 쓰레드들이 돌아오지 않는 문제가 있기는 하다.~~

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread(object state)
        {
            while(true)
            Console.WriteLine("hello Thread!");
        }
        static void Main(string[] args) 
        {
            ThreadPool.QueueUserWorkItem(MainThread);
        }
    }
}

관련 예제

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread(object state)
        {
            for (int i = 0; i < 5; i++)
            {
                Console.WriteLine("hello Thread!");
            }
        }
        static void Main(string[] args)
        {
            ThreadPool.QueueUserWorkItem(MainThread);

            while (true)
            {

            }
        }
    }
}

사실 new thread는 1000개까지 동시 생성, 돌릴 수 있다.(그러나 생성한 모든 쓰레드가 일하지 않음. 부하도 생각하면, 현실적이지 않다)

cpu 코어수랑 맞춰주는게 best

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread(object state)
        {
            for (int i = 0; i < 5; i++)
            {
                Console.WriteLine("hello Thread!");
            }
        }
        static void Main(string[] args)
        {
            //쓰레드를 무작정 생성해내는 것은 최악의 경우이다.
            for (int i = 0; i <1000; i++)
            {
                Thread t = new Thread(MainThread);
                t.Name = "TestThread";
                //백그라운드 쓰레드로, 앞그라운드에서 돌릴지 선택할 수 있음
                t.IsBackground = true;
                t.Start();
            }
            Console.WriteLine("waiting for thread!");
            //t.Join(); // 백그라운드가 끝날 때 까지 기다렸다가 다음줄로 가겠다
            //별도의 쓰레드가 실행됨
            Console.WriteLine("Hello World!");
            while (true)
            {

            }
        }
    }
}

쓰레드 최소, 최대 설정해보기

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread(object state)
        {
            for (int i = 0; i < 5; i++)
            {
                Console.WriteLine("hello Thread!");
            }
        }
        static void Main(string[] args)
        {
            //최소는 1개이고 최대는 5개이다라고 설정해준셈
            ////즉 5개가 다 돌고있으면 다른 일감이 들어와도
            ///더이상 진행할 수 없다는 뜻
            ThreadPool.SetMinThreads(1, 1);
            ThreadPool.SetMaxThreads(5, 5);
            for (int i = 0; i < 5; i++)
            {
                ThreadPool.QueueUserWorkItem((obj)=> { while (true) { } } );
            }
            ThreadPool.QueueUserWorkItem(MainThread);

            Console.WriteLine("Hello World!");
            while (true)
            {

            }
        }
    }
}

Console.WriteLine("hello Thread!"); 실행이 안되는 이유는 Main 함수 안의 FOR문이 쓰레드를 다 빼갔기 때문이다.

using System;
using System.Threading;
using System.Collections.Generic;

namespace ServerCore
{
    class Program
    {
        static void MainThread(object state)
        {
            for (int i = 0; i < 5; i++)
            {
                Console.WriteLine("hello Thread!");
            }
        }
        static void Main(string[] args)
        {
            //최소는 1개이고 최대는 5개이다라고 설정해준셈
            ////즉 5개가 다 돌고있으면 다른 일감이 들어와도
            ///더이상 진행할 수 없다는 뜻
            ThreadPool.SetMinThreads(1, 1);
            ThreadPool.SetMaxThreads(5, 5);
            for (int i = 0; i < 4; i++)
            {
                ThreadPool.QueueUserWorkItem((obj)=> { while (true) { } } );
            }
            ThreadPool.QueueUserWorkItem(MainThread);

            Console.WriteLine("Hello World!");
            while (true)
            {

            }
        }
    }
}

for문을 4번만 돌리면 Console.WriteLine("hello Thread!"); 실행이 잘되는 모습

쓰레드풀의 일꾼이 1개 남은 상태였고 그 일꾼이 헬로쓰레드를 일하러 갔기때문이다.

이런 식으로 쓰레드풀이 좋기는 한데 특정 작업들이 일꾼들을 다 잡아놓고 안 놔주면 시스템이 먹통이 될 수 있다는 점이 위험 요소가 된다.

이를 극복하는 방법이 Task이다.

Task t; 는

직원을 고용한다는 느낌보다는 직원이 할 일감 단위를 프로그래머가 정의하겠다는 개념이다.

using System;
using System.Threading;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace ServerCore
{
    class Program
    {
        static void MainThread(object state)
        {
            for (int i = 0; i < 5; i++)
            {
                Console.WriteLine("hello Thread!");
            }
        }
        static void Main(string[] args)
        {

            
            //최소는 1개이고 최대는 5개이다라고 설정해준셈
            ////즉 5개가 다 돌고있으면 다른 일감이 들어와도
            ///더이상 진행할 수 없다는 뜻
            ThreadPool.SetMinThreads(1, 1);
            ThreadPool.SetMaxThreads(5, 5);

            for (int i = 0; i < 5; i++)
            {
                                                             //이 작업은 특이하므로 매우 오래걸릴 것이다.
                                                             //즉 기존 설정했던 쓰레드풀에서 뽑아 쓰지 않고
                                                             //별도 처리가 들어갈 것이다.
                Task t = new Task(() => { while (true) { } }, TaskCreationOptions.LongRunning);
                t.Start();
            }

            ThreadPool.QueueUserWorkItem(MainThread);

            Console.WriteLine("Hello World!");
            while (true)
            {

            }
        }
    }
}

놀랍게도 Console.WriteLine("hello Thread!"); 바로 반복문 실행이 되는 것을 볼 수 있다 ^^

물론 TaskCreationOptions.LongRunning 인자를 람다문 다음으로 안 넣었으면 역시 작동이 안된다.

728x90