mfc_Thread_3 - 8BitsCoding/RobotMentor GitHub Wiki

// Dlg.h
struct ThreadData 
{
    HWND h_wnd;
    CListBox* p_list_box;
    HANDLE h_kill_event;
    HANDLE h_thread;
    DWORD thread_id;
    unsigned int start_step, end_step, thread_count;
    __int64* p_sum;
};

private:
    unsigned int m_step = 1600000;
    int m_thread_count = 32;
    __int64 m_sum = 0;              // 모든 Thread가 공유할 자원
    unsigned int m_start_tick;

if(m_thread_list.GetCount() > 0) return;

m_sum = 0;
m_start_tick = GetTickCount();

ThreadData * p;

for(int i = 0; i < m_thread_count; i++) {
    p = new ThreadData;
    p->h_wnd = m_hWnd;
    p->start_step = 2 + i;
    p->end_step = m_step;
    p->p_list_box = &m_data_list;
    p->thread_count = m_thread_count;
    p->p_sum = &m_sum;
    p->h_kill_event = CreateEvent(NULL, 1, 0, NULL);
    p->h_thread = CreateThread(NULL, 0, InsertItemToList, p, 0, &p->thread_id);

    CString str;
    str.Format(L"%08x : (%u ~ %u)까지 합산", p->thread_id, p->start_step, p->end_step);
    m_thread_list.InsertString(i, str);
    m_thread_list.SetItemData(i, p);
}

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

    int start_tick = GetTickCount(), kill_flag = 0;
    int index;

    unsigned int i ;
    for(i = p_data->start_step; i <= p_data->end_step; i += p_data->thread_count) {
        if(WaitForSingleObject(p_data->h_kill_event, 0) == WAIT_OBJECT_0) {
            kill_flag = 1;
            break;
        }

        if(IsPrime(i)) *p_data->p_sum += i;
    }

    CloseHandle(p_data->h_)
}

// On27001
ThreadData * p = (ThreadData *)lParam;
int count = m_thread_list.GetCount();
for(int i = 0; i < count; i++) {
    if(m_thread_list.GetItemDataPtr(i) == p) {
        m_thread_list.DeleteString(i);
        CloseHandle(p->h_kill_event);

        if(wParam == 0) delete p;
        else p->thread = NULL;

        break;
    }

if(count == 1) {
    CString str;
    str.Format(L"2~%u까지 소수의 합은 %lld이다. (%ums)", m_step, m_sum, GetTickCount() - m_start_tick);
    int index = m_data_list.InsertString(-1, str);
    m_data_list.SetCurSel(index);
}
}

// Dlg.cpp
CRITICAL_SETCTION gh_sum_lock;

// OnInitDlg
InitializeCriticalSection(&gh_sum_lock);

// OnDestroy
DeleteCriticalSection(&gh_sum_lock);

DWORD WINAPI InsertItemToList(void* ap_data)
{
    // ...

    if(IsPrime(i)) {
        EnterCriticalSection(&gh_sum_lock);
        *p_data->p_sum += i;
        LeaveCriticalSection(&gh_sum_lock);
    }

    // ...

EnterCriticalSection(&gh_sum_lock);
if(IsPrime(i)) *p_data->p_sum += i;
LeaveCriticalSection(&gh_sum_lock);