00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015 #ifndef CSIMPLEEVENTQUEUEBUFFER_H
00016 #define CSIMPLEEVENTQUEUEBUFFER_H
00017
00018 #include "IEventQueueBuffer.h"
00019 #include "IArchMultithread.h"
00020 #include "stddeque.h"
00021
00023
00026 class CSimpleEventQueueBuffer : public IEventQueueBuffer {
00027 public:
00028 CSimpleEventQueueBuffer();
00029 ~CSimpleEventQueueBuffer();
00030
00031
00032 virtual void waitForEvent(double timeout);
00033 virtual Type getEvent(CEvent& event, UInt32& dataID);
00034 virtual bool addEvent(UInt32 dataID);
00035 virtual bool isEmpty() const;
00036 virtual CEventQueueTimer*
00037 newTimer(double duration, bool oneShot) const;
00038 virtual void deleteTimer(CEventQueueTimer*) const;
00039
00040 private:
00041 typedef std::deque<UInt32> CEventDeque;
00042
00043 CArchMutex m_queueMutex;
00044 CArchCond m_queueReadyCond;
00045 bool m_queueReady;
00046 CEventDeque m_queue;
00047 };
00048
00049 #endif