쓰레드 - 임곙영역2

임계영역 기반 동기화

주의>
임계영역으로 동기화할 변수를 함수에서 리턴하면 다른 곳에서 진입하지 못하는 문제가 발생하니
반드시, 내부변수를 만들어 동기화할 변수 값을 내부변수에 저장하고, 내부 변수를 리턴해야 한다.

앞선 코드(http://petra.tistory.com/1043)에 블록체 코드만 추가한 것이다.

하나의 쓰레드가 사용중이면 다른 쓰레드는 사용 못하고 대기한다.

1. CRITICAL_SECTION 변수 선언
2. 초기화 함수 호출, InitializeCriticalSection(&hCriticalSection);
3. 동기화 할 변수에 진입할때 EnterCriticalSection() 호출
4. 변수 사용이 끝나면 LeaveCriticalSection() 호출
5. 초기화에 할당된 리소스 해제 함수 호출, DeleteCriticalSection(&hCriticalSection)

중요 : CRITICAL_SECTION 변수는 1개만 선언 가능한듯...
이미 외부 변수로 선언된 상태에서 또 다른 CRITICAL_SECTION 외부 변수 선언하면 컴파일 에러 발생하니 내부 변수로 바꿔서 해야 했다.

#include "stdafx.h"
#include <Windows.h>
#include <process.h>
#include <tchar.h>
#include <locale.h>
 
#define NUM_OF_GATE 6
LONG gTotalCount = 0;
CRITICAL_SECTION hCriticalSection;
 
void IncreaseCount()
{
 EnterCriticalSection(&hCriticalSection);
 gTotalCount++;
 LeaveCriticalSection(&hCriticalSection);
}
 
unsigned int WINAPI ThreadProc(LPVOID lParam)
{
 for (int i = 0; i < 1000; i++)
  IncreaseCount();
 _tprintf(_T("현재 카운터 : %d\n"), gTotalCount);
 return 0;
}
int main()
{
 _wsetlocale(LC_ALL, L"korean"); // #include <locale.h>필요, 유니코드에서 한글출력, wprintf(), fputws() 호출 전에 먼저 호출되야한다.
 
 DWORD dwThreadId[NUM_OF_GATE];
 HANDLE hThread[NUM_OF_GATE];
 
 InitializeCriticalSection(&hCriticalSection);
 
 for (int i = 0; i < NUM_OF_GATE; i++)
 {
  hThread[i] = (HANDLE)_beginthreadex(NULL, 0, ThreadProc, NULL, CREATE_SUSPENDED, (unsigned*)&dwThreadId[i]);
  if (hThread[i] == NULL)
  {
   _tprintf(_T("쓰레드 생성 실패!\n"));
   return -1;
  }
 }
 
 for (int i = 0; i < NUM_OF_GATE; i++)
  ResumeThread(hThread[i]);
 WaitForMultipleObjects(NUM_OF_GATE, hThread, TRUE, INFINITE);
 _tprintf(_T("\nTotal Count : %d\n"), gTotalCount);
 for (int i = 0; i < NUM_OF_GATE; i++)
  CloseHandle(hThread[i]);
 
 DeleteCriticalSection(&hCriticalSection);
 
 _tprintf(_T("키 입력 후 엔터키를 치세요....\n"));
 getchar();
 return 0;
}
 
 

 

 

원하던 Total Count 값이 6,000 이 된다.

단순하게 변수값만 증감이 필요한 경우라면 더 간단한 동기화 방법이 있다. - http://petra.tistory.com/1045