이벤트를 사용한 예제

스레드 세 개가 각각 + -  그리고 print 를 해서 값을 유지하는 하는 것을 보여주는 코드였다..

그것을 수동 Event를 통해 관리 했던 코드다. 그런데 정상적으로 종료하는 것에 대해선 고민하지 않았던 것 같다.

#include <iostream>
#include <Windows.h>
using namespace std;
 
DWORD WINAPI decrease(LPVOID pParam);
DWORD WINAPI increase(LPVOID pParam);
DWORD WINAPI print(LPVOID pParam);
int g_total = 1000;
 
 
struct Thread {
    HANDLE hEvent[3];
    HANDLE hThread[3];
    DWORD dwThreadId[3];
 
    void Initialize() {
        hEvent[0] = CreateEvent(NULL, TRUE, TRUE, NULL);
        hEvent[1] = CreateEvent(NULL, TRUE, FALSE, NULL);
        hEvent[2] = CreateEvent(NULL, TRUE, FALSE, NULL);
 
    }
 
    void excute() {
        while (true) {
            hThread[0] = CreateThread(NULL, 0, increase, this, NULL, &dwThreadId[0]);
            hThread[1] = CreateThread(NULL, 0, decrease, this, NULL, &dwThreadId[1]);
            hThread[2] = CreateThread(NULL, 0, print, this, NULL, &dwThreadId[2]);
            Sleep(2000);
        }
    }
};
DWORD WINAPI increase(LPVOID pParam) {
    Thread* t = (Thread*)pParam;
    WaitForSingleObject(t->hEvent[0], INFINITE);
    ResetEvent(t->hEvent[0]);
    g_total++;
    cout <<  "increase :" <<g_total << endl;
    SetEvent(t->hEvent[1]);
    return 0;
}
DWORD WINAPI decrease(LPVOID pParam) {
    Thread* t = (Thread*)pParam;
    WaitForSingleObject(t->hEvent[1], INFINITE);
    ResetEvent(t->hEvent[1]);
    g_total--;
 
    cout << "decrease :" << g_total << endl; ;
    SetEvent(t->hEvent[2]);
    return 0;
}
DWORD WINAPI print(LPVOID pParam) {
    Thread* t = (Thread*)pParam;
    WaitForSingleObject(t->hEvent[2], INFINITE);
    ResetEvent(t->hEvent[2]);
    cout << "print : " << g_total << endl;
    SetEvent(t->hEvent[0]);
    return 0;
}
 
int main() {
    Thread t;
    t.Initialize();
    t.excute();
    return 0;
}