“环形队列”和“消息队列”在嵌入式领域有应用非常广泛,相信有经验的嵌入式软件工程师对它们都不陌生。
但经常看到一些初学者问一些相关的问题,今天就来分享一下关于“环形队列”和“消息队列”的内容。
当head赶上tail,队列空,则令tag=0 当tail赶上head,队列满,则令tag=1
队列空: head==tail 队列满: (tail+1)% MAXN ==head
q->head = q->tail = q->tag = 0;
( q->head == q->tail) && (q->tag == 0)
((q->head == q->tail) && (q->tag == 1))
q->tail = (q->tail + 1) % q->size ;
q->head = (q->head + 1) % q->size
extern "C" {
typedef struct ringq{
int head; /* 头部,出队列方向*/
int tail; /* 尾部,入队列方向*/
int tag ; /* 为空还是为满的标志位*/
int size ; /* 队列总尺寸 */
int space[QUEUE_MAX]; /* 队列空间 */
}RINGQ;
/*
第一种设计方法:
当head == tail 时,tag = 0 为空,等于 = 1 为满。
*/
extern int ringq_init(RINGQ * p_queue);
extern int ringq_free(RINGQ * p_queue);
/* 加入数据到队列 */
extern int ringq_push(RINGQ * p_queue,int data);
/* 从队列取数据 */
extern int ringq_poll(RINGQ * p_queue,int *p_data);
}
#include <stdio.h>
#include "ringq.h"
int ringq_init(RINGQ * p_queue)
{
p_queue->size = QUEUE_MAX ;
p_queue->head = 0;
p_queue->tail = 0;
p_queue->tag = 0;
return 0;
}
int ringq_free(RINGQ * p_queue)
{
return 0;
}
int ringq_push(RINGQ * p_queue,int data)
{
print_ringq(p_queue);
if(ringq_is_full(p_queue))
{
printf("ringq is full\n");
return -1;
}
p_queue->space[p_queue->tail] = data;
p_queue->tail = (p_queue->tail + 1) % p_queue->size ;
/* 这个时候一定队列满了*/
if(p_queue->tail == p_queue->head)
{
p_queue->tag = 1;
}
return p_queue->tag ;
}
int ringq_poll(RINGQ * p_queue,int * p_data)
{
print_ringq(p_queue);
if(ringq_is_empty(p_queue))
{
printf("ringq is empty\n");
return -1;
}
*p_data = p_queue->space[p_queue->head];
p_queue->head = (p_queue->head + 1) % p_queue->size ;
/* 这个时候一定队列空了*/
if(p_queue->tail == p_queue->head)
{
p_queue->tag = 0;
}
return p_queue->tag ;
}
看到源代码,相信大家就明白其中原理了。其实还有不采用tag,或者其他一些标志的方法,这里就不进一步展开讲述了,感兴趣的读者可以自行研究一下。
消息支持先进先出方式排队,支持异步读写工作方式。 读写队列均支持超时机制。 消息支持后进先出方式排队,往队首发送消息(LIFO)。 可以允许不同长度(不超过队列节点最大值)的任意类型消息。 一个任务能够从任意一个消息队列接收和发送消息。 多个任务能够从同一个消息队列接收和发送消息。 当队列使用结束后,可以通过删除队列函数进行删除。
xQueue = xQueueCreate(QUEUE_LEN, QUEUE_SIZE);