코드 참조
http://tong.nate.com/haru3173/24195740
http://blog.naver.com/gamed21/70015497269
코드 받기
수행 화면
코드 설명
세개의 스레드가 mutex 로 공유된 변수를 접근하는 내용입니다. 장점과 문제점을 동시에 가지고 있는 코드입니다.
코드 내용
http://tong.nate.com/haru3173/24195740
http://blog.naver.com/gamed21/70015497269
코드 받기
invalid-file수행 화면
세개의 스레드가 mutex 로 공유된 변수를 접근하는 내용입니다. 장점과 문제점을 동시에 가지고 있는 코드입니다.
코드 내용
/*
스레드 프로그래밍 연습 - 4 : mutex
mutex_ex.cpp
저작권
http://cakel.tistory.com
참조 코드
http://tong.nate.com/haru3173/24195740
http://blog.naver.com/gamed21/70015497269
교육용을 목적으로 자유롭게 사용하실수 있습니다.
WIN32 로 만들어진 간단한 mutex 가 사용된 스레드 프로그램입니다.
1번 스레드는 10을 더하는 내용을
2번 스레드는 5를 빼는 내용을
3번 스레드는 지정된 검사값을 탐지하는 내용을 갖고 있습니다.
mutex 의 성질을 십분 활용했습니다. 문제점도 가지고 있습니다.
*/
#include <stdio.h> // printf()
#include <windows.h> // Sleep(), HANDLE, CloseHandle(), WaitForSingleObject(), ReleaseHandle()
#include <process.h> // _beginthread()
// Mutex 용 handle 은 전 스레드에서 쓰기 때문에 중복 선언 하는 거 보다 전역을 빼어
// 썼습니다. 스레드 내에서 쓰셔도 무방합니다. 단 CreateMutex() 함수 수행은
// main 내에서 해야지 디버그하기 용이 합니다.
HANDLE hMutex = 0;
// 이번에 공유할 변수
int nShare = 0;
// 스레드 후보 함수들의 prototype (선선언 하여 이후에 참조해도 문법상 문제가 없게 합니다.
// 문법상 문제가 없더라도 정의를 하지 않는다면 Link 오류가 생깁니다.
void tPlus(void*); // 덧셈
void tMinus(void*); // 뺄셈
void tDetect(void*); // 감지용
int main()
{
HANDLE hTh1, hTh2, hTh3;
hMutex = CreateMutex(NULL, FALSE, NULL);
// 생성된 mutex 가 유효한지 확인합니다.
if(hMutex == NULL)
{
printf("뮤택스 생성 실패 했습니다.\n");
return 1;
}
// 변화 시킬 값입니다. //
int nPlus = 10; // tPlus 수행시 증가될 값
int nMinus = 5; // nMinus 수행시 감소될 값
int nDetect = 30; // 30을 감지 합니다.
// 단계를 밟을 값입니다.
int i = 0;
while(i < 10) // 예상은 총 10회 (0 ~ 9)
{
// 스레드를 받아 유효한지 확인도 하고 종료를 기다리게 만들 핸들을 선언합니다.
hTh1 = (HANDLE) _beginthread(tPlus,0,(void*)&nPlus);
hTh2 = (HANDLE) _beginthread(tMinus,0,(void*)&nMinus);
hTh3 = (HANDLE) _beginthread(tDetect,0,(void*)&nDetect);
// 유효성 검토
if (hTh1 == 0 || hTh2 == 0 || hTh3 == 0) // 하나라도 불량이면 나가 떨어집니다.
{
printf("스레드 생성 오류 입니다.\n");
return 1;
}
// hTh3 만 막아 줘야지 만약 그렇지 않고 계산 중의 수를 변화 탐지 할수가 없을수 있습니다.
// hTh3 가 수행되기 전에 먼저 hTh1 과 hTh2 가 먼저 계산이 될수 있기 때문입니다.
// WaitForSingleObject(hTh1, INFINITE);
// WaitForSingleObject(hTh2, INFINITE);
WaitForSingleObject(hTh3, INFINITE);
i++; // 스레드의 수행이 끝나면 한단계를 증가 합니다.
}
// 마지막으로 열어둔 핸들을 닫습니다.
CloseHandle(hTh1);
CloseHandle(hTh2);
CloseHandle(hTh3);
CloseHandle(hMutex);
return 0;
}
void tPlus(void *pData)
{
// void 포인터로 받으면 받을 값을 미리 알아 둬야 할 불편함이 있습니다.
// 형변환을 해야 하니깐요.
// Mutex 핸들을 활성화 하여 전역 변수를 단일 스레드만 접근할수 있게 합니다.
// WAIT_FAILED 는 WaitForSingleObject() 함수 수행 결과가 실패 했으면 스레드가 정상
// 수행 되지 않기 때문에 안전 장치로 추가했습니다.
if(WaitForSingleObject(hMutex, INFINITE) == WAIT_FAILED)
{
printf("스레드 Wait 오류\n 스레드 종료\n");
return;
}
// Dereference 값 참조 (void* -> int*) int 형 주소로 void 형 주소를 강제
// 변환한후 값을 가져 오는 방식입니다. 바로 void* 를 값 참조 할수 없습니다.
nShare += *(int*)pData;
printf("스레드 1 : Plus 계산후 nShare, : %d\n", nShare);
// Sleep() 을 ReleaseMutex 밖에서 하니깐 문제가 발생했습니다.
// hMutex 를 전역위치에서 CreateMutex() 쓰니깐 Sleep() 에서 문제가 발생했습니다.
// 작동을 하지 않았습니다.
Sleep(1000);
// Mutex 를 풀어서 전역 변수의 독점을 해제 합니다.
ReleaseMutex(hMutex);
}
void tMinus(void *pData)
{
// tPlus 함수와 크게 다르지 않습니다.
if(WaitForSingleObject(hMutex, INFINITE) == WAIT_FAILED)
{
printf("스레드 Wait 오류\n 스레드 종료\n");
return;
}
nShare -= *(int*)pData;
printf("스레드 2 : Minus 계산후 nShare : %d\n", nShare);
// Mutex 를 풀어서 전역 변수의 독점을 해제 합니다.
Sleep(200);
ReleaseMutex(hMutex);
}
void tDetect(void *nDetect)
{
// tDetect 비교
if(WaitForSingleObject(hMutex, INFINITE) == WAIT_FAILED)
{
printf("스레드 Wait 오류\n 스레드 종료\n");
return;
}
printf("스레드 3 : 검사 - %d == %d\n", *(int*)nDetect, nShare);
if (nShare == *(int*)nDetect)
{ // Mutex 의 한계로 덧셈 뺄샘 한 결과가 저장된 nShare 값을 탐지하므로 값이 실시간으로 잡지 못합니다.
printf("%d 이 검사값과 일치\n", *(int*)nDetect);
}
// Mutex 를 풀어서 전역 변수의 독점을 해제 합니다.
ReleaseMutex(hMutex);
return;
}
