消息队列

更新时间：2019-01-25 14:11:23

概述

多任务系统中，任务间互相同步等待共享资源，我们一般会使用信号量，如果需要互斥，则使用互斥量。而任务间互相收发消息则可以使用消息队列。消息队列（queue）使用类似信号量的机制进行任务间的同步，并使用环形缓冲池（ring buffer）来进行消息的队列缓冲管理，以达到任务间收发消息的阻塞和通知管理。Queue的实现目的在于任务间互相收发消息。一般如果有信号量机制，用户就可以自己实现一套任务间的阻塞和通知收发功能，其本质在于接收方通过信号量的获取来开始接收消息，发送方通过信号量的释放来通知接收方处理。接收任务在无消息时被阻塞，消息到来时被唤醒处理。Queue就是基于这样一种类信号量机制来进行消息的收发。再加上ring buffer的缓冲机制来缓存任务间的消息队列，就组合成了本章的消息队列（queue）。其既包含消息的缓冲队列，又包含了消息的通知机制。
消息队列模块整体受宏RHINO_CONFIG_BUF_QUEUE开关控制，
对应的AOS API接口实现位于：osal/aos/aos_rhino.c中RHINO_CONFIG_BUF_QUEUE宏定义包含实现；
对应的krhino内部实现位于：kernel/rhino/k_buf_queue.c。

包含头文件

#include <aos/aos.h>      //总头文件
#include <aos/kernel.h>   //直接对应头文件

API列表

API详情

int aos_queue_new(aos_queue_t *queue, void *buf, unsigned int size, int max_msg)

输入参数

返回参数

调用示例

static aos_queue_t  g_queue;
static char  queue_buf[TEST_CONFIG_QUEUE_BUF_SIZE];
ret = aos_queue_new(&g_queue, queue_buf, 1000, 50);

void aos_queue_free(aos_queue_t *queue)

输入参数

返回参数

无

调用示例

aos_queue_free(&g_queue);

int aos_queue_send(aos_queue_t *queue, void *msg, unsigned int size)

输入参数

返回参数

调用示例

char *msg_send = "hello,queue!";
ret = aos_queue_send(&g_queue, msg_send, strlen(msg_send));

int aos_queue_recv(aos_queue_t *queue, unsigned int ms, void *msg, unsigned int*size)

返回参数

调用示例

char msg_recv[16] = {0};
unsigned int size_recv = 16;
memset(msg_recv, 0, size_recv);
ret = aos_queue_recv(&g_queue, 100, msg_recv, &size_recv);

int aos_queue_is_valid(aos_queue_t *queue)

返回参数

调用示例

ret = aos_queue_is_valid(&g_queue);

void* aos_queue_buf_ptr(aos_queue_t *queue)

返回参数

调用示例

void* bufstart;
bufstart = aos_queue_buf_ptr(&g_queue);

相关定义

相关宏定义

typedef struct
{
    void *hdl;
} aos_hdl_t;
typedef aos_hdl_t aos_queue_t;