멀티쓰레드 세마포어 연습

#include <iostream> #include <windows.h> #include <process.h> #define THREAD_COUNT 4 #define SEMAPHORE_START 2 #define SEMAPHORE_MAX 2 HANDLE g_semaphore = NULL; int number = 0; unsigned int __stdcall threadFun(void *lpVoid) { //함수 입장 std::cout << "Enter : " << __FUNCTION__ << std::endl; for (int i = 0; i < 10; i++) { WaitForSingleObject(g_semaphore, INFINITE); //std::cout << "EnterSemaphore : " << __FUNCTION__ << std::endl; std::cout << number << __FUNCTION__ << std::endl; number++; //std::cout << "EndSemaphore: " << __FUNCTION__ << std::endl; ReleaseSemaphore(g_semaphore, 1, NULL); //세마포어 카운트를 1올려줌 } //함수 종료 std::cout << "End : " << __FUNCTION__ << std::endl; //_endthreadex(0); 생략 가능 return 0; } int main() { HANDLE hThread[THREAD_COUNT]; g_semaphore = CreateSemaphore(NULL, SEMAPHORE_START, SEMAPHORE_MAX, NULL); //세마포어를 초기값 2, 최대값 2로 설정 //쓰레드 생성 for (int i = 0; i < THREAD_COUNT; i++) { hThread[i] = (HANDLE)_beginthreadex(NULL, 0, threadFun, NULL, 0, NULL); } WaitForMultipleObjects(THREAD_COUNT, hThread, true, INFINITE); for (int i = 0; i < THREAD_COUNT; i++) { CloseHandle(hThread[i]); } CloseHandle(g_semaphore); return 0; }

결과 화면 

세마포어 특성상 여러개의 쓰레드에서 접근할 수 있다.

이 때문에 값 동기화가 제대로 이루어지지 않은 부분이 보인다

(네이버 블로그 - 2016.02.14. 22:23)