CSync.h

Go to the documentation of this file.

#pragma once
#ifndef AXPIPE_CSYNC_H
#define AXPIPE_CSYNC_H

#include "AxPipe.h"
#include "AxPipeAssert.h"

namespace AxPipe {
class CSync {
private:
    HANDLE m_hEvent;                        
public:
    CSync();                                
    ~CSync();                               
    bool Wait(int iMs = -1);                
    bool Signal();                          
};
class CThreadSync {
    HANDLE m_hSemaphore;                    
    CSync m_Work,                           
          m_Accepted;                       
public:
    CThreadSync();                          
    ~CThreadSync();                         
    void WorkStart();                       
    void WorkSignal();                      
    void WorkWait();                        
    void WorkEnd();                         
};

template <class T> class CThreadMain : public T {
    DWORD m_dwThreadId;                     
    HANDLE m_hThread;                       
private:
    static DWORD WINAPI Main(LPVOID lpParam) {
        return ((CThreadMain<T> *)lpParam)->Main();
    }

    virtual int Main() {
        ASSCHK(false, _T("Override of 'virtual int Main()' missing"));
        return 0;
    }
public:
    CThreadMain() {
        // As we can't set a proper process prio below 2k version, we manually inherit current
        // thread priority.
        int iCurPrio = GetThreadPriority(GetCurrentThread());
        ASSAPI((m_hThread = CreateThread(NULL, 0, Main, this, CREATE_SUSPENDED, &m_dwThreadId))!= NULL);
        SetThreadPriority(m_hThread, iCurPrio);
    }

    virtual ~CThreadMain() {
        ASSAPI(WaitForSingleObject(m_hThread, INFINITE) == WAIT_OBJECT_0);
        ASSAPI(CloseHandle(m_hThread));
    }

    void Run() {
        ResumeThread(m_hThread);
    }

    void Wait() {
        WaitForSingleObject(m_hThread, INFINITE);
    }
};
}; // namespace AxPipe
#endif AXPIPE_CSYNC_H

---