message.h

嵌入式下的自己实现的消息队列,可以运行在51单片机下面

#ifndef __MESSAGE__
#define __MESSAGE__

typedef unsigned char BYTE;
typedef unsigned int WORD;

#define MSGBODYLEN 20

struct MESSAGE_tag
{
	struct MESSAGE_tag *pre;
	struct MESSAGE_tag *next;
	WORD timer;
	WORD src;
	WORD dst;
	WORD port;
	WORD type;
	WORD id;
	BYTE msg[MSGBODYLEN];
};

typedef struct MESSAGE_tag MESSAGE;




extern WORD g_msg_size;

extern void init_msg_q(MESSAGE *pmsg, WORD len);
MESSAGE * enqueue(MESSAGE *pmsg, WORD len, BYTE *psrc);
MESSAGE * dequeue(MESSAGE *pmsg, WORD len, MESSAGE *pdst);
void timer_msg_q(MESSAGE *pmsg, WORD len);
MESSAGE *cancel_msg(MESSAGE *pmsg, WORD len, MESSAGE *pcancel);

#endif