티스토리 뷰
쓰레드 - 이벤트 + 뮤텍스
뮤텍스로 2개의 쓰레드로 동기화 했기에 출력은 반드시 하나의 쓰레드만 가능하므로 출력 문자열이 한줄에 겹치는 문제를 해결한다.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78 |
#include "stdafx.h"
#include <Windows.h>
#include <process.h>
#include <tchar.h>
#include <locale.h>
typedef struct _SyncString {
TCHAR string[100];
HANDLE hEvent;
HANDLE hMutex;
} SyncString;
SyncString gSyncString;
unsigned int WINAPI ThreadProc2(LPVOID lParam)
{
WaitForSingleObject(gSyncString.hEvent, INFINITE); // hEvent 가 대기상태가 된다.
WaitForSingleObject(gSyncString.hMutex, INFINITE); // hMutex 가 대기상태가 된다.
_tprintf(_T("Output string length : %d\n"), _tcslen(gSyncString.string) - 1);
ReleaseMutex(gSyncString.hMutex);
return 0;
}
unsigned int WINAPI ThreadProc(LPVOID lParam)
{
WaitForSingleObject(gSyncString.hEvent, INFINITE); // hEvent 가 대기상태가 된다.
WaitForSingleObject(gSyncString.hMutex, INFINITE); // hMutex 가 대기상태가 된다.
_fputts(_T("Output string : "), stdout);
_fputts(gSyncString.string, stdout);
ReleaseMutex(gSyncString.hMutex);
return 0;
}
int main()
{
_wsetlocale(LC_ALL, L"korean"); // #include <locale.h>필요, 유니코드에서 한글출력, wprintf(), fputws() 호출 전에 먼저 호출되야한다.
DWORD dwThreadID[2];
HANDLE hThread[2];
gSyncString.hEvent = CreateEvent(
NULL, // 상속불가
TRUE, // 수동모드
FALSE, // non-signal 상태로 생성
NULL);
gSyncString.hMutex = CreateMutex(
NULL, // 상속불가
FALSE,
NULL);
if (gSyncString.hEvent == NULL || gSyncString.hMutex == NULL)
_fputts(_T("이벤트 혹은 뮤텍스 생성실패 %d"), stdout);
hThread[0] = (HANDLE)_beginthreadex(NULL, 0, ThreadProc, NULL, 0, (unsigned*)&dwThreadID);
hThread[1] = (HANDLE)_beginthreadex(NULL, 0, ThreadProc2, NULL, 0, (unsigned*)&dwThreadID);
if (hThread[0] == NULL && hThread[1] == NULL)
{
_fputts(_T("쓰레드 생성 실패\n"), stdout);
return -1;
}
_fputts(_T("insert string : "), stdout);
_fgetts(gSyncString.string, 30, stdin);
SetEvent(gSyncString.hEvent); // 위에서 키 입력이 되면 대기중인 hEvent를 Singnal 상태로 바꾼다.
WaitForMultipleObjects(2, hThread, TRUE, INFINITE); // hThread 가 끝날때까지 대기한다.
CloseHandle(hThread[0]);
CloseHandle(hThread[1]);
CloseHandle(gSyncString.hEvent);
CloseHandle(gSyncString.hMutex);
_tprintf(_T("키 입력 후 엔터키를 치세요....\n"));
getchar();
return 0;
}
|
cs |