커널 모드
유저 모드에서 커널 오브젝트에 접근을 할 때 시스템은 커널 모드로 변환을 합니다.
커널 오브젝트에는 File, Event, Mutex, Semaphore, Process, Waitable Timer, Job, Thread 가 있습니다.
커널 모드에서 동기화는 커널 오브젝트가 non-Signal인지 Signal 상태인지를 보고 쓰레드를 스케쥴링합니다.
커널 오브젝트가 signal상태이면 쓰레드가 돌아갈 준비가 된 상태이고, non-signal 상태이면 쓰레드는 기다림(Wait)상태 입니다.
이벤트(EVENT)
가장 많이 보편화되고 많이 쓰는 다중 쓰레드 동기화 오브젝트가 이벤트가 아닌가 생각이 됩니다.
이벤트로 다중 쓰레드 동기화 하는 방법에는 두가지 방법이 있습니다.
개발자가 직접 이벤트를 수동으로 signal/non-signal 상태로 변환 하는 것과 시스템이 자동으로 이벤트를 signal/non-signal상태로 변환 하는 방법입니다.
이벤트를 기다리는 방법은 WaitForSingleObjec/WaitForSingleObject 함수를 사용합니다. 이벤트가 non-signal상태가 될 때까지 쓰레드는 Wait상태로 됩니다.
이벤트 및 모든 커널 오브젝트는 사용이 끝나면 CloseHandle로 사용을 종료 해야 합니다.
Event function | Description | ||||
이벤트 오브젝트를 생성하거나 오픈 합니다. | |||||
이벤트 오브젝트를 생성하거나 오픈 합니다.(접근 권한을 줄수 있습니다.) | |||||
존재하는 이름이 있는 이벤트 오브젝트를 오픈 합니다. | |||||
특정 이벤트 오브젝트를 signal 상태로 바꾸고 일정시간 후 non-signal상태로 바끕니다. | |||||
이벤트 오브젝트를 non-signal 상태로 놓습니다. | |||||
이벤트 오브젝트를 signal 상태로 놓습니다. |
간단 하게 SDI 프로그램에서 수동 모드(passive mode) 이벤트를 이용하여 사각형과 원을 그리는 멀트 쓰레드 프로그램을 보겠습니다.
BOOL CEventSampleView::PreCreateWindow(CREATESTRUCT& cs) { // TODO: CREATESTRUCT cs를수정하여여기에서 // Window 클래스또는스타일을수정합니다. srand( (unsigned)time( NULL ) );
//종료조건을초기화합니다. m_bContinue = TRUE; //수동모드이벤트오브젝트를생성합니다. m_DrawEvent = CreateEvent(0, TRUE, TRUE, _T("DrawEvent"));
//시그널상태로둡니다. SetEvent(m_DrawEvent);
return CView::PreCreateWindow(cs); }
/*OnDraw 메시지 핸들러에서 사각형을 그리는 쓰레드와 원을 그리는 쓰레드를 생성합니다.*/ void CEventSampleView::OnDraw(CDC* /*pDC*/) { CEventSampleDoc* pDoc = GetDocument(); ASSERT_VALID(pDoc); if (!pDoc) return; m_RectThrd = AfxBeginThread(RectThreadProc,reinterpret_cast<LPVOID>(this)); m_CricleThrd = AfxBeginThread(CircleThreadProc, reinterpret_cast<LPVOID>(this)); // TODO: 여기에원시데이터에대한그리기코드를추가합니다. }
/*사각형을 그리는 쓰레드 프로시져*/ UINT CEventSampleView::RectThreadProc(__in LPVOID lpParameter) { CEventSampleView* pView = reinterpret_cast<CEventSampleView*>(lpParameter); int x=0,y=0, cx=0, cy=0; cx = 100; cy = 100; while(pView->m_bContinue) { //시그널상태가될때까지기다립니다. WaitForSingleObject(pView->m_DrawEvent, INFINITE); //이벤트오브젝트를받아오면넌시그널상태로둡니다. ResetEvent(pView->m_DrawEvent);
HDC hDC = ::GetDC(pView->GetSafeHwnd()); x= rand()%300; y = rand()%300; ::Rectangle(hDC,x, y, x+cx, y+cy); ::ReleaseDC(pView->GetSafeHwnd(),hDC); //작업이끝나면이벤트를시그널상태로두어다음쓰레드가가질수 //있도록합니다. SetEvent(pView->m_DrawEvent); } DWORD dCode=0; GetExitCodeThread(pView->m_CricleThrd->m_hThread, &dCode); AfxEndThread(dCode, TRUE); return 0; }
/*원을 그리는 쓰레드 프로시져*/ UINT CEventSampleView::CircleThreadProc(__in LPVOID lpParameter) { CEventSampleView* pView = reinterpret_cast<CEventSampleView*>(lpParameter); int x=0,y=0, cx=0, cy=0; cx = 100; cy = 100; while(pView->m_bContinue) { WaitForSingleObject(pView->m_DrawEvent, INFINITE); ResetEvent(pView->m_DrawEvent); HDC hDC = ::GetDC(pView->GetSafeHwnd()); x= rand()%300; y = rand()%300; ::Ellipse(hDC,x, y, x+cx, y+cy); ::ReleaseDC(pView->GetSafeHwnd(),hDC); SetEvent(pView->m_DrawEvent); } DWORD dCode=0; GetExitCodeThread(pView->m_CricleThrd->m_hThread, &dCode); AfxEndThread(dCode, TRUE); return 0; }
//프로그램이 종료할 때 종료조건을 맞춰 주고 쓰레드 종료 메시지를 주어 정상적으로 //종료하도록 하고, 이벤트 핸들을 닫습니다. void CEventSampleView::OnDestroy() { CView::OnDestroy(); m_bContinue = FALSE; DWORD dExitCode = 0; GetExitCodeThread(m_CricleThrd->m_hThread,&dExitCode); PostQuitMessage(dExitCode);
GetExitCodeThread(m_RectThrd->m_hThread,&dExitCode); PostQuitMessage(dExitCode);
CloseHandle(m_DrawEvent); } |
뮤텍스(MUTEX)
뮤텍스는 하나의 공유자원에 대한 상호 배타(mutual exclusive)적으로 동기화 하는 방법입니다. 뮤텍스는 서로 다른 프로세스의 쓰레드의 동기화를 할수 있습니다. 이 특성을 이용해서 보통 하나 이상의 프로그램을 실행하기 위해 뮤텍스를 이용합니다.(이걸 깨는 방법도 있죠.)
뮤텍스는 다음과 같은 규칙이 있습니다.
Ø 쓰레드의 ID가 0(유효하지 않은 쓰레드 ID)이면 뮤텍스의 소유권은 어느 쓰레드에게도 없다는 의미 이고 뮤텍스 오브젝트는 시그널된 상태입니다.
Ø 쓰레드 ID가 0이 아닌 값이면, 해당쓰레드(생성 시킨 쓰레드)가 소유권을 가지면 뮤텍스 오브젝트는 non-signal상태 입니다.
Ø 다른 커널 오브젝트와는 달리 뮤텍스는 소유권(thread ownership)이라는 개념이 있습니다.
뮤텍스를 해제할 때(ReleaseMutex), 쓰레드 ID와 생성할 때 설정한 쓰레드의 ID가 맞지 않으면 해제에 실패하고 시스템은 해당 뮤텍스의 시그널 상태를 기다리는 다른 쓰레드를 스케쥴링 합니다.
뮤텍스의 소유권을 가진 쓰레드가 뮤텍스를 해제 하지 않고 종료 되면, 시스템은 해당 뮤텍스를 “abandoned”상태로 두고, 이 뮤텍스를 기다리는 쓰레드를 찾아 기다리고 있는 쓰레드에 뮤텍스의 소유권을 주고 해당 쓰레드를 스케쥴링 합니다.
Mutex function | Description |
뮤텍스 오브젝트를 생성하거나 오픈 합니다. | |
뮤텍스 오브젝트를 생성하거나 오픈합니다. 접근 권한 속성을 둘 수 있습니다. | |
이름이 있는 뮤텍스 오브젝트를 오픈 합니다. | |
뮤텍스 오브젝트를 해제합니다. |
http://msdn2.microsoft.com/en-us/library/ms686927(VS.85).aspx
세마포어(SEMAPHORE)
세마포어는 공유 자원의 카운팅의 용도로 사용합니다.
세마포어는 사용 개수(usage count)이외에 signed 32비트 값 2개를 더 가지고 있습니다.
Ø 최대 리소스 카운트(maximum resource count) : 세마포어가 관리할 수 있는 최대 리소스의 개수.
Ø 현재 리소스 카운트(current resource count) : 현재 사용 가능한 리소스의 개수.
세마포어는 다음과 같은 규칙을 가지고 동작을 합니다.
Ø 현재 리소스 카운터가 0보다 크면(>0) 세마포어 오브젝트는 signal 상태입니다.
Ø 현재 리소스 카운터가 0이면, 세마포어 오브젝트는 non-signal상태입니다.
Ø 시스템은 현재 리소스카운터를 – 값이 되지 않도록 합니다.
Ø 현재 리소스 카운터는 최대 리소스 카운터 보다 클 수 없습니다.
Semaphore function | Description |
세마포어를 생성/오픈 합니다. | |
세마포어를 생성/오픈 합니다. 접근 권한을 둘 수 있습니다. | |
이름이 있는 세마포어 오브젝트를 오픈합니다. | |
사용 가능한 리소스 개수를 증가 시킵니다.. |
세마포어 사용 예는 아래 사이트를 참조 하세요.
http://msdn2.microsoft.com/en-us/library/ms686946(VS.85).aspx
Waitable Timer
Waitable Timer 오브젝트는 특정 시간이 되면 오브젝트가 시드널 됩니다.
특정 시간 마다 어떤 동작을 해야할 때 사용할 수 있습니다.
Waitable-timer function | Description |
Waitable Timer 오브젝트를 비활성화 시킵니다. | |
Waitable Timer를 생성하거나 오픈 합니다. | |
Waitable Timer를 생성/오픈 합니다. | |
이름이 붙여진 Waitable Timer 오브젝트를 오픈 합니다. | |
Waitable Timer 오브젝트를 활성화 시키거나, Waitable Timer 오브젝트가 시그널 되었을 때 완료 통보 프로시져를 등록 할 수 있습니다.. | |
SetWaitableTimer 함수로 등로한 완료 통보 프로시져 선언. |
Timer-queue Timer
Timer queue Timer 오브 젝트는 일정시간이 지나면 시그널되는 동작은 Waitable Timer 와 같습니다.
Timer Queue Timer 오브젝트는 일정 시간이 지나면 시그널 되는 오브젝트이고, Timer Queue오브젝트가 Timer Queue Timer 오브젝트를 큐 형태로 관리하면서
해당 프로 시져를 호출 합니다.
위의 그림은 Timer Queue오브젝트가 Timer Queue Timer 오브젝트를 관리하고,
Timer Queue Timer가 시그널 되면 해당 프로시져를 호출하는 모습입니다.
Timer-queue timer function | Description |
Timer queue timer 오브젝트의 속성을 변경 합니다.. | |
Timer Queue 오브젝트를 생성합니다. | |
Timer Queue Timer 오브젝트를 생성합니다. | |
타이머 큐 오브젝트를 삭제 합니다. | |
타이머 큐 오브젝트를 삭제 합니다. | |
Timer Queue 에 있는 Timer Queue Timer 오브젝트를 삭제 합니다. |
쓰레드간 통신
마지막으로 쓰레드간 통신 하는 방법을 알아 보겠습니다.
윈도우 프로그래밍을 하면 윈도우에 SendMessage/PostMessage 함수로 메시지를 보내 듯이 쓰레드에 메시지를 보내고 받으면서 쓰레드간 통신을 할 수 있습니다.
쓰레드에 메시지를 보내는 함수는 PostThreadMessage 입니다.
BOOL PostThreadMessage(
DWORD idThread, /*해당 쓰레드 ID*/
UINT Msg, /*메시지 ID*/
WPARAM wParam, /*메시지를 받는 쓰레드로 넘겨주는 WPARAM 인자*/
LPARAM lParam /* 메시지를 받는 쓰레드로 넘겨주는 LPARAM 인자*/
);
PostThread로 보낸 메시지는 쓰레드 프로시져에서 PeekMessage/GetMessage로 받을 수 있습니다.
http://msdn2.microsoft.com/en-us/library/ms644936(VS.85).aspx
BOOL GetMessage(
LPMSG lpMsg, //MSG 구조체의 포인터 타입
HWND hWnd, //윈도우 핸들
UINT wMsgFilterMin, //필터링할 최소 메시지 ID
UINT wMsgFilterMax //필터링할 최대 메시지 ID
);
http://msdn2.microsoft.com/en-us/library/ms644943.aspx
BOOL PeekMessage(
LPMSG lpMsg, //MSG 구조체의 포인터 타입
HWND hWnd, //윈도우 핸들
UINT wMsgFilterMin, //필터링할 최소 메시지 ID
UINT wMsgFilterMax, //필터링할 최대 메시지 ID
UINT wRemoveMsg //메시지 큐에 해당 메시지를 지울지 안지울지 설정
);
PeekMessage와 GetMessage의 차이점은, GetMessage는 메시지가 메시지 큐에 들어 올때가지 블록되고 Peek메시지는 메시지가 없으면 FALSE를 리턴 합니다.
더 자세한 사항은 차고 사이트를 참고 하세요.
아래 예제 코드는 쓰레드 프로시져에서 메시지를 확인하고, 다른 작업을 수행 하는 예제 코드입니다.
unsigned _stdcall CallThreadHandlerProc(void *pThreadHandler) { while (bExit == FALSE) { MSG msg; BOOL res = PeekMessage(&msg, NULL, 0, 0, PM_REMOVE); if (res) { //0x404메세지 가 들어오면 특정 작업 수행 if (msg.message = 0x404) { std::cout<<"Message Received"<<std::endl; } }
//다른 작업 수행 } DWORD exitCode; GetExitCodeThread(InputThrd, &exitCode); _endthreadex(exitCode); return 0; } …………………………………………. //다른 쓰레드에서 쓰레드에 메시지를 보냅니다. BOOL res = PostThreadMessage(ID1, 0x00404, 0,0 ); |
참고 사이트 및 서적
Windows Via C/C++
http://msdn2.microsoft.com/en-us/library/aa904937(VS.85).aspx
http://windows-programming.suite101.com/article.cfm/win32_message_processing_primer