SmartPDCode/control/STS/HARDWARE/Uart1/Queue.c

/*********************************************************************************************************
* 模块名称：Queue.c
* 摘    要：Queue模块
* 当前版本：1.0.0
* 作    者：Leyutek(COPYRIGHT 2018 - 2021 Leyutek. All rights reserved.)
* 完成日期：2021年07月01日
* 内    容：
* 注    意：                                                                  
**********************************************************************************************************
* 取代版本：
* 作    者：
* 完成日期：
* 修改内容：
* 修改文件：
*********************************************************************************************************/

/*********************************************************************************************************
*                                              包含头文件
*********************************************************************************************************/
#include "Queue.h"

/*********************************************************************************************************
*                                              宏定义
*********************************************************************************************************/

/*********************************************************************************************************
*                                              枚举结构体
*********************************************************************************************************/

/*********************************************************************************************************
*                                              内部变量定义
*********************************************************************************************************/

/*********************************************************************************************************
*                                              内部函数声明
*********************************************************************************************************/

/*********************************************************************************************************
*                                              内部函数实现
*********************************************************************************************************/

/*********************************************************************************************************
*                                              API函数实现
*********************************************************************************************************/

/*********************************************************************************************************
* 函数名称：InitQueue
* 函数功能：初始化队列 
* 输入参数：pQue-结构体指针，即指向结构体变量的地址，pBuf-队列的元素存储区地址，len-队列的容量
* 输出参数：pQue-结构体指针，即指向结构体变量的地址
* 返 回 值：void
* 创建日期：2021年07月01日
* 注    意：
*********************************************************************************************************/
void InitQueue(StructCirQue* pQue, DATA_TYPE* pBuf, short len)
{
  short i;

  pQue->front   = 0;      //队头
  pQue->rear    = 0;      //队尾
  pQue->bufLen  = len;    //缓冲区长度（队列容量）
  pQue->elemNum = 0;      //当前队列中元素的个数
  pQue->pBuffer = pBuf;   //指针变量pBuf赋给指针变量pQue->pBuffer
  
  for(i = 0; i < len; i++)
  {
    pQue->pBuffer[i] = 0; //对指针变量pQue->pBuffer所指向的元素均赋初值0
  }
}

/*********************************************************************************************************
* 函数名称：ClearQueue
* 函数功能：清队列 
* 输入参数：pQue-结构体指针，即指向结构体变量的地址
* 输出参数：pQue-结构体指针，即指向结构体变量的地址
* 返 回 值：void
* 创建日期：2021年07月01日
* 注    意：
*********************************************************************************************************/
void ClearQueue(StructCirQue* pQue)
{
  pQue->front   = 0; //队头
  pQue->rear    = 0; //队尾
  pQue->elemNum = 0; //当前队列中元素的个数
}

/*********************************************************************************************************
* 函数名称：QueueEmpty
* 函数功能：判断队列是否为空，1为空，0为非空 
* 输入参数：pQue-结构体指针，即指向结构体变量的地址
* 输出参数：pQue-结构体指针，即指向结构体变量的地址
* 返 回 值：返回队列是否为空，1为空，0为非空
* 创建日期：2021年07月01日
* 注    意：
*********************************************************************************************************/
unsigned char QueueEmpty(StructCirQue* pQue)
{
  return(0 == pQue->elemNum);
}

/*********************************************************************************************************
* 函数名称：QueueLength
* 函数功能：返回队列中元素个数 
* 输入参数：pQue-结构体指针，即指向结构体变量的地址
* 输出参数：pQue-结构体指针，即指向结构体变量的地址
* 返 回 值：队列中元素的个数
* 创建日期：2021年07月01日
* 注    意：
*********************************************************************************************************/
short QueueLength(StructCirQue* pQue)
{
  return(pQue->elemNum);
}

/*********************************************************************************************************
* 函数名称：EnQueue
* 函数功能：插入len个元素（存放在起始地址为pInput的存储区中）到队列 
* 输入参数：pQue-结构体指针，即指向结构体变量的地址，pInput-待入队数组的地址，len-期望入队元素的数量
* 输出参数：pQue-结构体指针，即指向结构体变量的地址
* 返 回 值：成功入队的元素的数量
* 创建日期：2021年07月01日
* 注    意：每次插入一个元素，rear自增，当rear的值大于等于队列容量bufLen时，rear值变为0。需要注意的是，当队
*           列中的元素数量加上待写入的元素数量超过队列容量时，队列允许写入的元素数量等于队列中的元素数量+新写
*           入的元素数量-队列的容量，即EnQueue函数对于超出元素采取不理睬的态度。
*********************************************************************************************************/
short EnQueue(StructCirQue* pQue, DATA_TYPE* pInput, short len)
{
  short wLen = 0; //待入队的元素有len个，wLen从0增加到len-1
  
  while((pQue->elemNum < pQue->bufLen) && (wLen < len))
  {
    pQue->pBuffer[pQue->rear] = pInput[wLen]; //将待入队的第wLen个元素pInput[wLen]插入队列
    pQue->rear++;                             //队尾rear自增，即指向队尾元素的下一个位置
    
    if(pQue->rear >= pQue->bufLen)
    {
      pQue->rear = 0; //如果队尾元素的下一个位置为pQue->bufLen，则rear指向队头，循环体现在此处
    }

    wLen++;
    pQue->elemNum++;  //当前队列中的元素总数
  }

  return wLen;  //如果返回值wLen为0，表示没有元素入队
}

/*********************************************************************************************************
* 函数名称：DeQueue
* 函数功能：从队列中取出len个元素，放入起始地址为pOutput的存储区 
* 输入参数：pQue-结构体指针，即指向结构体变量的地址，len-预期出队元素的数量
* 输出参数：pQue-结构体指针，即指向结构体变量的地址，pOutput-出队元素存放的数组的地址
* 返 回 值：成功出队的元素的数量
* 创建日期：2021年07月01日
* 注    意：每次取出一个元素，front自增，当front的值大于等于队列容量bufLen时，front值变为0。需要特别注意，从
*           队列中读取元素的前提是队列中需要至少有一个元素，当期望取出的元素数量len小于或等于队列中元素的数量
*           时，可以按期望取出len个元素，否则，只能取出队列中已有的所有元素。 
*********************************************************************************************************/
short DeQueue(StructCirQue* pQue, DATA_TYPE* pOutput, short len)
{
  short rLen = 0;     //期望取出len个元素，最终能取出rLen个元素
  
  while((pQue->elemNum > 0) && (rLen < len))
  {
    pOutput[rLen] = pQue->pBuffer[pQue->front];
    pQue->front++;
    
    if( pQue->front >= pQue->bufLen )
    {
      pQue->front = 0;//如果队头元素的下一个位置为pQue->bufLen，则front指向队头，循环体现在此处
    }

    rLen++;
    pQue->elemNum--;  //当前队列中的元素总数
  }

  return rLen;        //如果返回值rLen为0，表示队列中没有元素
}