queue.h

EVC下的串口测试工具

#pragma once

typedef struct Qdata
{
	BYTE *data;
	unsigned int size;
}QNode;

class CQueue
{
public:
	CQueue(int cnt);
	int GetCount();
	BOOL Push(QNode *data);
	BOOL Pop(QNode *data);
	DWORD QueueReader(BYTE *buff, unsigned int size, DWORD timeout, char endchar='\n');
	void Clear();
	BOOL IsEmpty();
	BOOL IsFull();
	void SetReady();
	DWORD WaitForData(DWORD time);
	DWORD WaitForSpace(DWORD time);
	~CQueue(void);

	HANDLE hNotEmpty[2];
	HANDLE hNotFull[2];

protected:
	QNode *m_data;
	unsigned int buffCounter;
	unsigned int m_count;
	unsigned int m_head;
	unsigned int m_tale;
	unsigned int m_size;
};