Microsoft MVP성태의 닷넷 이야기
ThreadPool 조인에 관해 [링크 복사], [링크+제목 복사]
조회: 1345
글쓴 사람
농상
홈페이지
첨부 파일
 
'시작하세요! C# 7.1 프로그래밍'으로 공부하는 중입니다.
450쪽 ThreadPool을 공부하고 453쪽의 EventWaitHandle로 조인을 하려고 합니다.

제가 작성한 코드입니다.

class Thread_Pool_Class
{
    public static void Main(string[] args)
    {
        EventWaitHandle[] ewh = new EventWaitHandle[4];

        // 이벤트핸들 4개 생성
        ewh[0] = new EventWaitHandle(false, EventResetMode.ManualReset);
        ewh[1] = new EventWaitHandle(false, EventResetMode.ManualReset);
        ewh[2] = new EventWaitHandle(false, EventResetMode.ManualReset);
        ewh[3] = new EventWaitHandle(false, EventResetMode.ManualReset);

        // 람다로 스레드 4개 생성
        ThreadPool.QueueUserWorkItem(_ => Hello(ewh[0]));
        ThreadPool.QueueUserWorkItem(_ => Hello(ewh[1]));
        ThreadPool.QueueUserWorkItem(_ => Hello(ewh[2]));
        ThreadPool.QueueUserWorkItem(_ => Hello(ewh[3]));

        // 모든 이벤트핸들 기다림
        ewh[0].WaitOne();
        ewh[1].WaitOne();
        ewh[2].WaitOne();
        ewh[3].WaitOne();

        WriteLine("끝");
    }

    static void Hello(object o)
    {
        EventWaitHandle ewh = o as EventWaitHandle;

        WriteLine("안녕하세요");

        ewh.Set();
    }
}

스레드풀에 메서드와 이벤트핸들을 4번 전달하여 스레드 4개가 병렬로 작업하는 코드입니다.
이러면 안녕하세요가 4번 출력되면서 마지막 끝 출력까지 정상으로 작동합니다.
지금은 안녕하세요라는 문자열을 4번 출력하지만 나중에는 하나의 작업을 병렬로 작업하게 해서 성능을 올리는 방법으로 바꾸려고 합니다.
코드 길이가 긴거 같아서 for문으로 축소해봤습니다.

class Thread_Pool_Class
{
    public static void Main(string[] args)
    {
        EventWaitHandle[] ewh = new EventWaitHandle[4];

        for (int i = 0; i < 4; ++i)
        {
            ewh[i] = new EventWaitHandle(false, EventResetMode.ManualReset); // 이벤트핸들 4개 생성
        }

        for (int i = 0; i < 4; ++i)
        {
            ThreadPool.QueueUserWorkItem(_ => Hello(ewh[i])); // 람다로 스레드 4개 생성
        }

        // foreach로 이벤트핸들을 기다리기 해도 되고
        //foreach (var v in ewh)
        //{
        // v.WaitOne();
        //}

        WaitHandle.WaitAll(ewh); // WaitAll로 모든 이벤트핸들을 기다리게 해도 된다.

        WriteLine("끝");
    }

    static void Hello(object o)
    {
        EventWaitHandle ewh = o as EventWaitHandle;

        WriteLine("안녕하세요");

        ewh.Set();
    }
}

이 코드로 바꾸었더니 예외가 발생합니다.
예외 메세지는 너무 많아서 다 말씀을 못드리겠습니다.
예외가 발생하는 위치는 for문에서 람다로 ThreadPool에 스레드를 생성하는 위치입니다.
ThreadPool.QueueUserWorkItem(_ => Hello(ewh[i]));를 ThreadPool.QueueUserWorkItem(Hello, ewh[i]);로 람다가 아니라 메서드 이름과 이벤트핸들을 직접 전달하게 바꾸면 잘 작동하더군요.
아무래도 람다를 사용해서 스레드 할당하는 것과 이벤트핸들을 사용해서 기다리는 작업을 같이 하면 예외가 발생하는 듯 합니다.

그래서 어떤 상황에서 예외가 발생하는지 하나씩 확인해봤습니다.
1. ThreadPool에 직접 4번 람다로 스레드 할당, 이벤트핸들 기다리기
2. ThreadPool에 for문으로 4번 람다로 스레드 할당, 이벤트핸들 기다리기
3. ThreadPool에 직접 4번 람다로 스레드 할당, 이벤트 기다리지 않기
4. ThreadPool에 for문으로 람다로 4번 스레드 할당, 이벤트핸들 기다리지 않기

오직 2번 상황에서만 예외가 발생했습니다.
3, 4번은 서브 스레드들이 작업을 끝내기도 전에 메인스레드가 끝나서인지 화면에는 끝이라는 문자열만 출력됩니다.

다른 방법으로 생각한게 ThreadPool에 스레드를 할당하고 바로 WaitOne()을 하는 방법입니다.

for (int i = 0; i < 4; ++i)
{
      ThreadPool.QueueUserWorkItem(_ => Hello(ewh[i])); // 람다로 스레드 4개 생성
      ewh[i].WaitOne(); // 스레드 할당하자마자 기다리기
}

이렇게 바꾸니까 예외는 발생하는 않습니다.
하지만 스레드 1개 할당하면 스레드가 끝날때까지 기다리고, 다시 스레드 1개 할당하면 스레드가 끝날때까지 기다리고.
저는 병렬기능을 구현해서 성능을 상승시키고 싶기 때문에 이 방법은 아닌것 같습니다.
그냥 스레드풀에 직접 할당할 때는 잘 됬는데 for문으로 할당하면 예외가 발생하는 이유가 뭘까요?
어떻게 해야 조인을 제대로 구현할 수 있을까요?
또한 Thread.Sleep()을 사용하고 싶지 않습니다.
서브스레드들이 모두 끝나야 결과물이 나오는 Thread.Join()과 같은 기능을 구현하고 싶습니다.






[최초 등록일: ]
[최종 수정일: 6/11/2019 ]


비밀번호

댓글 쓴 사람
 



2019-06-11 09시00분
좋은 시행 착오를 거치셨군요. 다음의 글을 읽어보시면 궁금함이 풀릴 것입니다.

C# 람다(Lambda)에서 변수 캡쳐 방식
; http://www.sysnet.pe.kr/2/0/10817

정성태

1  2  3  4  5  [6]  7  8  9  10  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
5243최선호10/18/2019672Screen Capture 와.. Overlay 질문 좀 드릴게요 ㅠ.ㅠ ( 장문 주의..... ) [2]
5241C#초보10/16/20191130C# USB 통신 구현 관련 질문 드립니다! [1]
5240김동규10/15/2019604런타임 시 Encoding.Default를 UTF-8로 설정할 수 있을까요? [3]
5239밤톨이10/13/2019572시놀리지 DSM에 asp.net core 2 웹서버 구축이 가능한가요? [1]
5238권석헌10/2/2019733C# - C++ 간의 Memorymapped file 관련 Data 질문좀 드립니다 선생님 [1]
5237유호성10/1/2019607사용자 정의 컨트롤 VS IDE에서만 Exception 발생 [2]
5234koko9/25/2019905안녕하세요. 64bit WPF -> 32bit C++ DLL Import사용 문의 드립니다. [3]
5232fox3699/24/2019637C# Memorymappedfile 재 업로드 드립니다.(실행순서 및 질문내용 정리) [7]파일 다운로드1
5231fox3699/24/2019559C# 메모리맵드파일 관련 질문드립니다. 최소한의 재현가능코드 첨부후 재질문 드립니다. [2]파일 다운로드1
5230질문9/23/2019692C++ 로 만든 dll 을 C#에서 사용할 때 질문 [2]
5229fox3699/23/2019919C# 메모리맵드파일 관련 질문드립니다. [2]
5227세퉁9/23/2019898WPF Textblock 폰트 크기에 따라 글자 색이 깨지는 현상이 있습니다. [3]파일 다운로드1
5226김대훈9/23/2019886정말 황당한 경우입니다.. [2]
5223김태균9/19/2019691책 소개 링크가 7.1버전판으로 이어집니다. [1]
5222냥냥이9/14/20191068프로그래밍 논리력이 많이 부족합니다 [3]
5219티지레몬9/9/20191267c# PCB 자동화 프로그램(윈도우 폼 위주로 작업) 제작 준비 [3]
5218민성9/9/2019741안녕하세요 WPF에서 xaml 안에 다른 xaml을 넣고 싶습니다. [1]파일 다운로드1
5216WPF9/8/2019944WPF에서 XAML Islands를 사용하여 Win2D를 사용하니 그래픽 품질이 저하됩니다. [2]파일 다운로드1
5215허송세월9/5/2019834중복실행 방지 관련 문의 [2]파일 다운로드1
5214JangHun9/4/20191025[DB 테이블의 데이터 변경에 대한 알림 처리] SQL-Server말고 MySQL은 불가능하겠죠? [1]
5213진우8/31/2019934c# 람다 변수 캡쳐 문의 [2]
5212심성보8/29/20191330Clipboard내 여러개의 이미지를 PictureBox로 불러오는 문제 [2]
5211최휘철8/24/2019690CLR20r3 관련된 윈도우 오류입니다. ㅠㅠ 도와주세요. / 아래글 관련하여 관련 파일 올려 드려요^^ [1]파일 다운로드1
5210최휘철8/23/20192418CLR20r3 관련된 윈도우 오류입니다. ㅠㅠ 도와주세요. [5]
5209세퉁8/21/2019877폰트 파일 속성 값을 가져오는 방법 질문 드립니다. [2]파일 다운로드1
5208홍길동8/19/2019920DebugDiag에서 .Net의 Stack Trace를 Windbg에서는 어떻게 볼 수 있나요? [3]
1  2  3  4  5  [6]  7  8  9  10  11  12  13  14  15  ...