STM32

分享一个好用的Fifo队列

2019-12-12 18:23发布

站内问答 / STM32/STM8
12255 19 20
可以移植在任意单片机或Linux中，挺好~~


  3. #include "CirQueue.h"


  6. CirQueue stQueue;


  9. /*        $Function                :  Init_Queue               
  10. ==  ===============================================================
  11. ==        Description                :       
  12. ==        Argument                :        *Q
  13. ==                                        :       
  14. ==         Return                        :        none
  15. ==        Modification        :        2014-03-05        xu_chenhua                Create
  16. ==  ===============================================================
  17. */
  18. void InitQueue(CirQueue *Q)
  19. {
  20.    u8 i;       
  21.         Q->front = Q->rear = 0;
  22.         Q->count = 0;
  23.         memset(Q->receive,0,QueueSize);
  24.                
  25. }



  29. /*        $Function                :  QueueEmpty               
  30. ==  ===============================================================
  31. ==        Description                :       
  32. ==        Argument                :        *Q
  33. ==                                        :       
  34. ==         Return                        :        if count =0 is return 1,if not return 0
  35. ==        Modification        :        2014-03-05        xu_chenhua                Create
  36. ==  ===============================================================
  37. */

  39. u16 QueueEmpty(CirQueue *Q)
  40. {
  41.         return Q->count == 0;           
  42. }



  46. /*        $Function                :  QueueFull               
  47. ==  ===============================================================
  48. ==        Description                :       
  49. ==        Argument                :        *Q
  50. ==                                        :       
  51. ==         Return                        :        if count = Queuesize is return 1,if not return 0
  52. ==        Modification        :        2014-03-05        xu_chenhua                Create
  53. ==  ===============================================================
  54. */

  56. u16 QueueFull(CirQueue *Q)
  57. {
  58.         return Q->count == QueueSize;  
  59. }




  64. /*        $Function                :  QueuePushIn               
  65. ==  ===============================================================
  66. ==        Description                :       
  67. ==        Argument                :        *Q,x
  68. ==                                        :       
  69. ==         Return                        :        if queue is full return 0 ,if not return 1
  70. ==        Modification        :        2014-03-05        xu_chenhua                Create
  71. ==  ===============================================================
  72. */

  74. u8 EnQueue(CirQueue *Q,u8 x)   
  75. {
  76.         if(QueueFull(Q))
  77.         {
  78.                 return 0;
  79.         }
  80.         Q->count++;
  81.         Q->receive[Q->rear] = x;                             
  82.         Q->rear = (Q->rear+1)%QueueSize;
  83.         return 1;
  84. }



  88. /*        $Function                :  QueuePushIn               
  89. ==  ===============================================================
  90. ==        Description                :       
  91. ==        Argument                :        *Q ,*dat
  92. ==                                        :       
  93. ==         Return                        :        if queue is empty return 0 ,if not return 1
  94. ==        Modification        :        2014-03-05        xu_chenhua                Create
  95. ==  ===============================================================
  96. */
  97. u8 DeQueue(CirQueue *Q, u8 *dat)
  98. {
  99.         if(QueueEmpty(Q))
  100.         {
  101.                 return 0;
  102.         }
  103.         *dat = Q->receive[Q->front];
  104.         Q->front = (Q->front +1)%QueueSize;
  105.         Q->count--;
  106.         return 1;
  107. }



  111. /*        $Function                :  QueuePushIn               
  112. ==  ===============================================================
  113. ==        Description                :       
  114. ==        Argument                :        *rxdata,length
  115. ==                                        :       
  116. ==         Return                        :        none
  117. ==        Modification        :        2014-03-05        xu_chenhua                Create
  118. ==  ===============================================================
  119. */
  120. u8 QueuePushIn(u8 *rxdata,u8 length)
  121. {
  122.         u8 i;
  123.         if(QueueFull(&stQueue))
  124.         {
  125.                 return 0;
  126.         }
  127.        
  128.         for(i=0;i<length;i++)
  129.         {
  130.                 EnQueue(&stQueue,*rxdata++);
  131.         }
  132.         return 1;
  133. }


  136. /*        $Function                :  QueuePopOut               
  137. ==  ===============================================================
  138. ==        Description                :       
  139. ==        Argument                :        *buf,length
  140. ==                                        :       
  141. ==         Return                        :        none
  142. ==        Modification        :        2014-03-05        xu_chenhua                Create
  143. ==  ===============================================================
  144. */
  145. u8 QueuePopOut(u8 *buf, u16 length)
  146. {
  147.         u8 i;
  148.         if(QueueEmpty(&stQueue))
  149.         {
  150.                 return 0;
  151.         }
  152.         for(i=0;i<length;i++)
  153.         {
  154.                 DeQueue(&stQueue, &buf[i]);
  155.         }
  156.         return 1;
  157. }

复制代码

头文件：

  2. #ifndef __CIRQUEUE_H_
  3. #define __CIRQUEUE_H_

  5. #include  "usr_define.h"
  6. #include <string.h>
  7. #include <stdlib.h>


  10. #define QueueSize  64

  12. typedef struct _TagCirQueue
  13. {
  14.         u16 front;
  15.         u16 rear;
  16.         u16 count;
  17.         u8  receive[QueueSize];
  18. }CirQueue;

  20. extern CirQueue stQueue;

  22. u8 QueuePopOut(u8 * buf,u16 length);
  23. u8 QueuePushIn(u8 * rxdata,u8 length);
  24. void InitQueue(CirQueue * Q);





  30. #endif
复制代码
友情提示: 此问题已得到解决，问题已经关闭,关闭后问题禁止继续编辑，回答。
19条回答
pengtaoABC
2019-12-14 10:02

学习一下，感谢楼主！

一周热门 更多>