プロセス間通信をしてみた(3)
サーバ側をマルチスレッド化してみた

using namespace std;

typedef struct _PIPE_HANDLES {
    HANDLE  hPipe;
    HANDLE  hEvent;
} PIPE_HANDLES, * PPIPE_HANDLES;

DWORD   WINAPI  ServerThreadProc(LPVOID threadParam);

int main()
{
    int nRetCode = 0;
    
    //
    //  ...(省略)...
    //
    int recvCount = 0;
    while (recvCount < 10) {
        pipeHandles.hPipe = INVALID_HANDLE_VALUE;
        pipeHandles.hPipe = CreateNamedPipe(_T("\\\\.\\pipe\\sample_pipe"),
            PIPE_ACCESS_INBOUND,
            PIPE_TYPE_BYTE | PIPE_WAIT,
            1,
            0,
            0,
            100,
            NULL);
        if (INVALID_HANDLE_VALUE == pipeHandles.hPipe) {
            _tprintf(_T("The pipe can not open.\r\n"));
        }
        else {
            _tprintf(_T("The pipe can open.\r\n"));
        }
        DWORD threadId = 0;
        pipeHandles.hEvent = CreateEvent(NULL, FALSE, FALSE, _T("IPC_SAMPLE"));
        HANDLE threadHandle = (HANDLE)_beginthreadex(
            NULL, 
            0, 
            (_beginthreadex_proc_type)ServerThreadProc, 
            (LPVOID)((PPIPE_HANDLES)(&pipeHandles)), 
            0,
            (unsigned int*)&threadId);
        if (NULL == threadId) {
            _tprintf(_T("Thread can not create.\r\n"));
            return (-1);
        }
        else {
            _tprintf(_T("Thread created.\r\n"));
        }
        WaitForSingleObject(threadHandle, INFINITE);
        if (CloseHandle(threadHandle)) {
            _tprintf(_T("Thread (and its handle) closed.\r\n"));
        }
        _tprintf(_T("Program end.\r\n"));
        Sleep(100);
        recvCount++;
    }
    //
    //  ...(省略)...
    //
    return nRetCode;
}

DWORD WINAPI    ServerThreadProc(LPVOID threadParam)
{
    _TCHAR  readBuffer[256];
    DWORD   readBufferSizeInByte = sizeof(readBuffer);
    ZeroMemory(readBuffer, readBufferSizeInByte);

    PPIPE_HANDLES   pipeHandles = (PPIPE_HANDLES)threadParam;
    int loopCount = 0;

    while (1)
    {
        WaitForSingleObject(pipeHandles->hEvent, INFINITE);
        DWORD   readDataSize = 0;
        BOOL readResult = ReadFile(pipeHandles->hPipe, readBuffer, readBufferSizeInByte, (LPDWORD)&readDataSize, NULL);
        ResetEvent(pipeHandles->hEvent);
        if (FALSE == readResult) {
            _tprintf(_T("Can not read data.\r\n"));
            break;
        }
        else {
            _tprintf(_T("Read data : %s\r\n"), readBuffer);
        }

        if (0 == readBuffer[0]) {
            break;
        }
    }

    _tprintf(_T("Exit loop\r\n"));
    SetEvent(pipeHandles->hEvent);

    if (CloseHandle(pipeHandles->hPipe)) {
        _tprintf(_T("Pipe close.\r\n"));
        _tprintf(_T("Exit loop thread.\r\n"));
    }
    return 0;
}