---

RainMessageQueue.h

Go to the documentation of this file.

#ifndef __MSGQ
#define __MSGQ



#include "RainDefines.h"
#include "RainMutex.h"
#include "RainAutoArray.h"


struct SRainMessage
{
        UINT nID;
        UINT rgnData[4];        
};


class CRainMessageQueue
{
public:
        CRainMessageQueue();
        ~CRainMessageQueue();

        bool Init(UINT nSize);






        bool    Push(const SRainMessage* pIn);
        int             Pop(SRainMessage* pOut);//-1 on error, else number of items when this was called

private:
        void Cleanup();


        CRainAutoArray<SRainMessage>    m_Buffer;
        UINT                                                    m_nSize;
        UINT                                                    m_nPopPos;//points to the 'head'
        UINT                                                    m_nPushPos;//points to an empty spot

        CRainMutex                                              m_Mutex;
};






#endif

---