mfc_Thread - 8BitsCoding/RobotMentor GitHub Wiki

(주의)

MFC에서 GetDlgItem과 같은 Temporary 객체를 반환하는 함수는 사용하면 안된다.

Thread가 동작하는 동안 Main Thread에서는 임시객체(GetDlgItem에서 반환된 객체)의 메모리는 모두 지우기 때문!

---

Thread가 필요한 Example

하나의 버튼을 누르면 아래와 같은 작업을 한다고 가정해보자.

// Button Click
CString str;
int index;

for(int i = 0; i < 10000; i++)
{
    str.Format(L"item %05d", i);
    index = m_data_listbox.InsertString(-1, str);
    m_data_listbox.SetCurSel(index);
}

위 for문이 모두 동작하기 전 메인 다이얼로그를 움직이거나 추가 클릭이 불가능하다.

Thread를 통하여 개선해 보자.

---

Thread 생성

DWORD WINAPI InsertItemToList(void* ap_data)
{
    CString str;
    int index;

    for(int i = 0; i < 10000; i++)
    {
        str.Format(L"item %05d", i);
        index = ap_data->InsertString(-1, str);
        ap_data->SetCurSel(index);
    }

    return 0;
}

HANDLE h_thread;
h_thread = CreateThread(NULL, 0, InsertItemToList, &m_data_listbox, 0, NULL);

if(h_thread != NULL) {
    // Thread 생성
    
}

CreateThread에 대한 설명

HANDLE CreateThread(
  LPSECURITY_ATTRIBUTES   lpThreadAttributes,
  SIZE_T                  dwStackSize,
  LPTHREAD_START_ROUTINE  lpStartAddress,
  __drv_aliasesMem LPVOID lpParameter,
  DWORD                   dwCreationFlags,
  LPDWORD                 lpThreadId
);

• lpThreadAttributes : 사용자 계정 컨트롤, 관리자모드, 일반사용자 모드 등
• dwStackSize : 각 Thread의 Stack Size, 0으로 두면 1MB (보통 1MB임) 32bit 운영체제 기준으로 최대 사용가능 메모리가 4GB이고 2GB는 OS에서 사용하기에 2GB 중 1700MB 정도만 사용이 가능 따라서 StackSize를 1MB로 두면 Thread 1700개 정도사용이 가능
• lpStartAddress : ThreadFunc 주소
• lpParameter : Thread에 넘길 인자
• dwCreationFlags : Thread 생성 시 Flag 지정
• lpThreadId : 반환되는 Thread ID

---

정말 쉽네?? 뭐가 문제지???

1. Main Thread가 종료된다고 내부 Thread가 모두 종료되는것이 아니다!

For문이 모두 돌아가기 전 MainWindow를 죽이면?? -> Thread는 그대로 살아있는다.

// Dlg.h
HANDLE mh_thread = NULL;

mh_thread = CreateThread(NULL, 0, InsertItemToList, &m_data_listbox, 0, NULL);

if(mh_thread != NULL) {
    // Thread 생성
    
}

클래스 마법사 -> WM_DESTROY 생성

// OnDestroy()
CDialogEx::OnDestroy();

if(mh_thread != NULL)
{
    TerminateThread(mh_thread, 0);
}

위 처럼 하면 될까??

문제는 Thread 내부에서 동적 할당된 메모리를 회수하지 않고 비정상 종료를 해버리게 된다.

이런 비정상 종료의 가장 큰 문제점은 Mutex영역을 설정하면 비정상 종료된 Mutex에 의해서 lock이 발생할 수 있다는 점이다.

정말 급하게 일을 처리해야할때 TerminateThread를 쓰자...

그럼 어쩌라고?

EVENT를 이용해보자.

// Dlg.h
struct ThreadData
{
    CListBox* p_list_box;
    HANDLE h_kill_event;
    HANDLE h_thread;
};

private:
    ThreadData m_thread_data;

// OnInitDialog
m_thread_data.p_list_box = &m_data_list;
m_thread_data.h_kill_event = CreateEvent(NULL, 1, 0, L"Tips001");
m_thread_data.h_thread = NULL;

코드설명 (CreateEvent)

HANDLE CreateEventA(
  LPSECURITY_ATTRIBUTES lpEventAttributes,
  BOOL                  bManualReset,
  BOOL                  bInitialState,
  LPCSTR                lpName
);

• lpEventAttributes : 사용자 계정 컨트롤, 관리자모드, 일반사용자 모드 등
• bManualReset : 1(ManualReset)로 두면 내가 SetEvent하면 Set 설정 / 0으로 두면 일정 시간이 지나면 CloseEvent
• bInitialState : 처음에 0으로 시작할지 1로 시작할지, 0으로 두면 0으로 시작
• lpName : 이벤트객체 이름, 이벤트 이름을 알면 OpenEvent()를 통해서 이벤트를 공유할 수 있다.

m_thread_data.h_thread = CreateThread(NULL, 0, InsertItemToList, &m_thread_data, 0, NULL);

if(m_thread_data.h_thread != NULL) {
    // Thread 생성
    
}

DWORD WINAPI InsertItemToList(void* ap_data)
{
    ThreadData * p_data = (ThreadData *)ap_data;

    CString str;
    int index;

    for(int i = 0; i < 10000; i++)
    {
        if(WaitForSingleObject(p_data->h_kill_event, 1) == WAIT_OBJECT_0)
        {
            // Event가 Set 상태이면 == WAIT_OBJECT_0
            // Event가 Set 상태가 아니면 == WAIT_TIMEOUT
            break;
        }
        str.Format(L"item %05d", i);
        index = p_data->p_list_box->InsertString(-1, str);
        p_data->p_list_box->SetCurSel(index);
    }

    CloseHandle(p_data->h_thread);
    p_data->h_thread = NULL;

    return 0;
}

// OnDestroy()
CDialogEx::OnDestroy();

if(m_thread_data.h_thread != NULL)
{
    SetEvent(m_thread_data.h_kill_event);
    while(m_thread_data.h_thread != NULL);
}

이렇게 하면 또 다른 문제점이 발생

while(m_thread_data.h_thread != NULL); 에서는 Thread가 죽기를 기다리고 있고

Thread의 index = p_data->p_list_box->InsertString(-1, str);는 Main Thread에서 메시지 처리후 응답을 주기를 기다리면서 데드락 상태가 발생하게 된다.

---

해결방안??

// OnDestroy()
CDialogEx::OnDestroy();

if(m_thread_data.h_thread != NULL)
{
    SetEvent(m_thread_data.h_kill_event);

    MSG msg;

    while(m_thread_data.h_thread != NULL && GetMessage(&msg, NULL, 0, 0)) {
        TranslateMessge(&msg);
        DispatchMessage(&msg);
    }
}

메시지를 처리하는 구문을 넣어준다.

---

하지만 이번 예제의 치명적 문제점이 있음.

Thread에서 p_data->p_list_box->InsertString(-1, str); 메인 Thread의 동작을 요구하게 되는데,

이렇게 동작할 경우 Thread가 몇개 안되면 정상적으로 동작하나

Thread의 개수가 많아 질수록 Main Thread의 부하가 커지게 된다.

다음강좌에서 해결방법을 모색해본다.