具有Reset功能的多线程同步队列 - 1

具有Reset功能的多线程同步队列

前一段时间写了一个多线程同步队列，并且加入了Reset功能。可以保证线程读到的不会是不可识别的数据。自己自测过，不过还是不能保证没有bug：）

// -------------------------头文件：ThreadSafeQueue.h---------------------------//

#include <wtypes.h>

typedef struct _MsgItem // 8 bytes size

{

USHORT MsgID;

USHORT wParam; // 2 bytes

ULONG lParam; // 4 bytes

} MsgItem;

class CTreadSafeMsgQueue

{

private:

// 同步

int m_HeaderToWrite;

int m_TailToRead;

HANDLE m_S_Producer;

HANDLE m_S_Consumer;

HANDLE m_E_Queue;

// 初始化

BOOL m_bInitedOK;

// Reset

int m_WritingThreadNum; // 当前正在调用PostMsg，且已进入同步操作状态的线程数目

int m_ReadingThreadNum; // 当前正在调用GettMsg，且已进入同步操作状态的线程数目

BOOL m_bStop; // 正在Reset

// 消息缓冲区

int MAX_QUE_SIZE;

MsgItem *m_Queue;

// 非法消息类型

USHORT INVALID_MSG_TYPE;

// 常数

typedef enum { SLEEP_TIME = 20 };

public:

CTreadSafeMsgQueue(int QueSize = 64, USHORT InvalidMsgType = 0xFFFF);

~CTreadSafeMsgQueue();

BOOL Reset();

BOOL GetMsg(MsgItem &Msg, int WaitTime);

BOOL PostMsg(const MsgItem Msg, int WaitTime);

private:

CTreadSafeMsgQueue(const CTreadSafeMsgQueue*);

CTreadSafeMsgQueue(const CTreadSafeMsgQueue&);

const CTreadSafeMsgQueue& operator = (const CTreadSafeMsgQueue&);

};