윈도우즈 멀티 쓰레드 프로그래밍

HANDLE WINAPI CreateThread(
  __in_opt   LPSECURITY_ATTRIBUTES lpThreadAttributes,
  __in       SIZE_T dwStackSize,
  __in       LPTHREAD_START_ROUTINE lpStartAddress,
  __in_opt   LPVOID lpParameter,
  __in       DWORD dwCreationFlags,
  __out_opt  LPDWORD lpThreadId
);

#include <windows.h> 
#include <tchar.h> 
#include <strsafe.h> 
 
#define MAX_THREADS 3 
#define BUF_SIZE 255 
 
DWORD WINAPI MyThreadFunction( LPVOID lpParam ); 
void ErrorHandler(LPTSTR lpszFunction); 
 
/* 
  쓰레드에 넘겨 줄 간단한 유저 쓰레드 데이터 
 */ 
typedef struct MyData { 
    int val1; 
    int val2; 
} MYDATA, *PMYDATA; 
 
 
int _tmain() 
{ 
    PMYDATA pDataArray[MAX_THREADS]; 
    DWORD   dwThreadIdArray[MAX_THREADS]; 
    HANDLE  hThreadArray[MAX_THREADS];  
 
    // Create MAX_THREADS worker threads. 
 
    for( int i=0; i<MAX_THREADS; i++ ) 
    { 
        // 쓰레드 데이터를 위한 메모리 할당 
        pDataArray[i] = (PMYDATA) HeapAlloc(GetProcessHeap(), HEAP_ZERO_MEMORY, 
                sizeof(MYDATA)); 
 
        if( pDataArray[i] == NULL ) 
        { 
            // 메모리 할당에 실패하면 종료한다. 
            ExitProcess(2); 
        } 
 
        // 각 쓰레드에 넘겨 줄 데이터의 값을 설정한다. 
        pDataArray[i]->val1 = i; 
        pDataArray[i]->val2 = i+100; 
 
        // 쓰레드를 생성한다. 
        hThreadArray[i] = CreateThread(  
            NULL,                   // default security attributes 
            0,                      // use default stack size   
            MyThreadFunction,       // thread function name 
            pDataArray[i],          // argument to thread function  
            0,                      // use default creation flags  
            &dwThreadIdArray[i]);   // returns the thread identifier  
 
        // 쓰레드가 성공적으로 생성되었는지를 확인한다. 
        // 생성에 실패하면 프로세스를 종료한다. 
        if (hThreadArray[i] == NULL)  
        { 
           ErrorHandler(TEXT("CreateThread")); 
           ExitProcess(3); 
        } 
    } 
 
    // 쓰레드 종료를 기다린다. 
    WaitForMultipleObjects(MAX_THREADS, hThreadArray, TRUE, INFINITE); 
 
    // 모든 쓰레드 핸들러를 닫고, 메모리를 해제한다. 
    for(int i=0; i<MAX_THREADS; i++) 
    { 
        CloseHandle(hThreadArray[i]); 
        if(pDataArray[i] != NULL) 
        { 
            HeapFree(GetProcessHeap(), 0, pDataArray[i]); 
            pDataArray[i] = NULL;  
        } 
    } 
 
    return 0; 
} 
 
 
// 쓰레드 함수 
DWORD WINAPI MyThreadFunction( LPVOID lpParam )  
{  
    HANDLE hStdout; 
    PMYDATA pDataArray; 
 
    TCHAR msgBuf[BUF_SIZE]; 
    size_t cchStringSize; 
    DWORD dwChars; 
 
    // 표준출력을 제어하기 위한 콘솔을 만든다. 
    hStdout = GetStdHandle(STD_OUTPUT_HANDLE); 
    if( hStdout == INVALID_HANDLE_VALUE ) 
        return 1; 
 
    // Cast the parameter to the correct data type. 
    // The pointer is known to be valid because  
    // it was checked for NULL before the thread was created. 
     pDataArray = (PMYDATA)lpParam; 
 
    // Print the parameter values using thread-safe functions. 
    StringCchPrintf(msgBuf, BUF_SIZE, TEXT("Parameters = %d, %d\n"),  
        pDataArray->val1, pDataArray->val2);  
    StringCchLength(msgBuf, BUF_SIZE, &cchStringSize); 
    WriteConsole(hStdout, msgBuf, (DWORD)cchStringSize, &dwChars, NULL); 
 
    return 0;  
}  
 
 
 
void ErrorHandler(LPTSTR lpszFunction)  
{  
    // Retrieve the system error message for the last-error code. 
 
    LPVOID lpMsgBuf; 
    LPVOID lpDisplayBuf; 
    DWORD dw = GetLastError();  
 
    FormatMessage( 
        FORMAT_MESSAGE_ALLOCATE_BUFFER |  
        FORMAT_MESSAGE_FROM_SYSTEM | 
        FORMAT_MESSAGE_IGNORE_INSERTS, 
        NULL, 
        dw, 
        MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), 
        (LPTSTR) &lpMsgBuf, 
        0, NULL ); 
 
    // Display the error message. 
 
    lpDisplayBuf = (LPVOID)LocalAlloc(LMEM_ZEROINIT,  
        (lstrlen((LPCTSTR) lpMsgBuf) + lstrlen((LPCTSTR) lpszFunction) + 40) * sizeof(TCHAR));  
    StringCchPrintf((LPTSTR)lpDisplayBuf,  
        LocalSize(lpDisplayBuf) / sizeof(TCHAR), 
        TEXT("%s failed with error %d: %s"),  
        lpszFunction, dw, lpMsgBuf);  
    MessageBox(NULL, (LPCTSTR) lpDisplayBuf, TEXT("Error"), MB_OK);  
 
    // Free error-handling buffer allocations. 
 
    LocalFree(lpMsgBuf); 
    LocalFree(lpDisplayBuf); 
}