cpl queue.h

#ifndef _CPL_QUEUE_H_
#define _CPL_QUEUE_H_

#include <Windows.h>
#include <queue>
#include <type_traits>


template <class T>
class CQueue
{
public:
    CQueue(HANDLE hEvent) {m_hEvent= hEvent; InitializeCriticalSection(&m_rLock);}
    virtual ~CQueue() {DeleteCriticalSection(&m_rLock);}

    void Push(T pHead){
        EnterCriticalSection(&m_rLock);
        if (m_hEvent && !m_cPacketQueue.size())
            SetEvent(m_hEvent);
        m_cPacketQueue.push(pHead);
        LeaveCriticalSection(&m_rLock);
    }

    T Front(bool bPop, bool &bValid){
        T pHead= T();
        bValid= false;
        EnterCriticalSection(&m_rLock);
        if (m_cPacketQueue.size() != 0){
            pHead= m_cPacketQueue.front();
            if (bPop)
                m_cPacketQueue.pop();
            bValid= true;
        }
        LeaveCriticalSection(&m_rLock);
        return pHead;
    }
    int GetSize(){
        EnterCriticalSection(&m_rLock);
        int nSize= (int)m_cPacketQueue.size();
        LeaveCriticalSection(&m_rLock);
        return nSize;
    }
    void ResetIfEmpty(){
        EnterCriticalSection(&m_rLock);
        if (!m_cPacketQueue.size())
            ResetEvent(m_hEvent);
        LeaveCriticalSection(&m_rLock);
    }
private:
    std::queue<T>       m_cPacketQueue; // Queue holding the objects
    CRITICAL_SECTION    m_rLock;        // Protects reading/writing to queue
    HANDLE              m_hEvent;   // Signals when added to queue
};

#endif