messagequeue.h

开发环境为VC++ 的数据库管理系统

#ifndef _MESSAGE_QUEUE
#define _MESSAGE_QUEUE

#include <afxtempl.h>
#include <afxmt.h>
typedef struct
{
	CWinThread *pthread;
	UINT message;
	bool waiting;
	CString strNote;
	int waitEventNum;
	int varSpare;
}THREAD_MSG;
class MESSAGE_QUEUE
{
private:
	CList<THREAD_MSG,THREAD_MSG &> m_msg_list;
	CCriticalSection m_section;
public:
	MESSAGE_QUEUE();
	~MESSAGE_QUEUE();
	bool IsEmpty(void);
	void GetHead(THREAD_MSG & msg);
	void AddTail(CWinThread *pthread,UINT message,bool waiting,CString strNote,int eventNum,int varSpare);
	void RemoveHead(void);
};
#endif