CSync.cpp

Go to the documentation of this file.

#include "stdafx.h"

namespace AxPipe {
    CSync::CSync() {
        m_hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
        ASSAPI(m_hEvent != NULL);
    }
    
    CSync::~CSync() {
        ASSAPI(CloseHandle(m_hEvent));
    }
    
    bool
    CSync::Wait(int iMs) {
        DWORD dwStatus = WaitForSingleObject(m_hEvent, iMs == -1 ? INFINITE : (DWORD)iMs);
        ASSAPI(dwStatus != WAIT_FAILED);
        return dwStatus == WAIT_OBJECT_0;
    }
    
    bool
    CSync::Signal() {
        ASSAPI(SetEvent(m_hEvent));
        return true;
    }

    CThreadSync::CThreadSync() {
        ASSAPI((m_hSemaphore = CreateSemaphore(NULL, 1, 1, NULL)) != NULL);
    }

    CThreadSync::~CThreadSync() {
        ASSAPI(CloseHandle(m_hSemaphore));
    }
    void
    CThreadSync::WorkStart() {
        WaitForSingleObject(m_hSemaphore, INFINITE);
    }

    void
    CThreadSync::WorkSignal() {
        m_Work.Signal(); m_Accepted.Wait();
    }
    
    void
    CThreadSync::WorkWait() {
        m_Work.Wait(); m_Accepted.Signal();
    }
    
    void
    CThreadSync::WorkEnd() {
        ReleaseSemaphore(m_hSemaphore, 1, NULL);
    }
};

---