西安道桥建设有限公司网站发布软文平台

参考内容

• C语言数据结构———循环队列(静态数组实现方式)
• C语言数据结构———循环队列(动态数组实现方式)
• C语言数据结构———链式队列(链表实现方式)
• C语言数据结构———循环队列(数组实形式用宏定义方式实现)
• C语言数据结构——循环队列，数组方式实现

---

消息队列数据类型结构体

typedef struct
{u16 Type; /* 消息类型 */u16 Data; /* 消息值 */
}xSuper_Message_TypeDef;typedef struct
{       u8 Front, Rear;                   //队首 队尾u8 Size;                          //大小xSuper_Message_TypeDef * pMsgDat; //数据指针
}xSuper_MesgQueue_TypeDef;

---

一、初始化消息队列

/* 初始化消息队列 */
void vMesgQueue_Init(xSuper_MesgQueue_TypeDef * pQueue, xSuper_Message_TypeDef * pMesg, u8 size)
{pQueue->Front   = pQueue->Rear = 0;pQueue->Size    = size;pQueue->pMsgDat = pMesg;
}

二、消息队列是否为空

/* 消息队列是否为空 */
u8 xMesgQueue_IsEmpty(xSuper_MesgQueue_TypeDef * pQueue)
{/* 队首与队尾相等队列为空 */if (pQueue->Front == pQueue->Rear) return 1;else                               return 0;
}

三、消息队列是否已满

/* 消息队列是否已满 */
u8 xMesgQueue_IsFull(xSuper_MesgQueue_TypeDef * pQueue)
{/* 队尾下一个元素为队首队列已满 */if (((pQueue->Rear + 1) % pQueue->Size) == pQueue->Front) return 1;else                                                      return 0;
}

四、消息入队

/* 消息入队 */
static void vSuper_MesgQueue_Enter(xSuper_MesgQueue_TypeDef * pQueue, u16 msgType, u16 msgData)
{pQueue->pMsgDat[pQueue->Rear].Type = msgType;pQueue->pMsgDat[pQueue->Rear].Data = msgData;pQueue->Rear = (pQueue->Rear + 1) % pQueue->Size;
}/* 消息入队 */
u8 xMesgQueue_Enter(xSuper_MesgQueue_TypeDef * pQueue, u16 msgType, u16 msgData)
{/* 队列已满 */if (xMesgQueue_IsFull(pQueue)) return 1;/* 消息入队 */vSuper_MesgQueue_Enter(pQueue, msgType, msgData);return 0;
}/* 获取队尾前索引 */
static u16 xSuper_MesgQueue_RearBeforIndex(xSuper_MesgQueue_TypeDef * pQueue)
{return ((pQueue->Rear - 1 + pQueue->Size) % pQueue->Size);
}/* 强制消息入队 */
void vMesgQueue_Enter_Force(xSuper_MesgQueue_TypeDef * pQueue, u16 msgType, u16 msgData)
{u8 i = 0;/* 队列已满 */if (xMesgQueue_IsFull(pQueue)) {i = xSuper_MesgQueue_RearBeforIndex(pQueue);pQueue->pMsgDat[i].Type = msgType;pQueue->pMsgDat[i].Data = msgData;}else                           {vSuper_MesgQueue_Enter(pQueue, msgType, msgData);}
}

五、消息出队

/* 消息出队 */
static xSuper_Message_TypeDef * xSuper_MesgQueue_Output(xSuper_MesgQueue_TypeDef * pQueue)
{xSuper_Message_TypeDef * pMsg = NULL;pMsg = &pQueue->pMsgDat[pQueue->Front];pQueue->Front = (pQueue->Front + 1) % pQueue->Size;return pMsg;
}/* 消息出队 */
xSuper_Message_TypeDef * xMesgQueue_Output(xSuper_MesgQueue_TypeDef * pQueue)
{/* 队列为空 */if (xMesgQueue_IsEmpty(pQueue)) return NULL;/* 消息出队 */return xSuper_MesgQueue_Output(pQueue);
}

六、其他函数

/* 获取消息队列元素个数 */
u16 xMesgQueue_GetCount(xSuper_MesgQueue_TypeDef * pQueue)
{return ((pQueue->Rear - pQueue->Front + pQueue->Size) % pQueue->Size);
}/* 清除消息队列 */
void vMesgQueue_Clear(xSuper_MesgQueue_TypeDef * pQueue)
{pQueue->Front = pQueue->Rear = 0;
}

七、函数汇总

void vMesgQueue_Init(xSuper_MesgQueue_TypeDef * pQueue, xSuper_Message_TypeDef * pMesg, u8 size);
void vMesgQueue_Enter_Force(xSuper_MesgQueue_TypeDef * pQueue, u16 msgType, u16 msgData);
void vMesgQueue_Clear(xSuper_MesgQueue_TypeDef * pQueue);u8 xMesgQueue_Enter(xSuper_MesgQueue_TypeDef * pQueue, u16 msgType, u16 msgData);
u8 xMesgQueue_IsEmpty(xSuper_MesgQueue_TypeDef * pQueue);
u8 xMesgQueue_IsFull(xSuper_MesgQueue_TypeDef * pQueue);xSuper_Message_TypeDef * xMesgQueue_Output(xSuper_MesgQueue_TypeDef * pQueue);
u16 xMesgQueue_GetCount(xSuper_MesgQueue_TypeDef * pQueue);