1# 消息队列 2 3 4## 基本概念 5 6消息队列又称队列，是一种任务间通信的机制。消息队列接收来自任务或中断的不固定长度消息，并根据不同的接口确定传递的消息是否存放在队列空间中。 7 8任务能够从队列里面读取消息，当队列中的消息为空时，挂起读取任务；当队列中有新消息时，挂起的读取任务被唤醒并处理新消息。任务也能够往队列里写入消息，当队列已经写满消息时，挂起写入任务；当队列中有空闲消息节点时，挂起的写入任务被唤醒并写入消息。 9 10可以通过调整读队列和写队列的超时时间来调整读写接口的阻塞模式，如果将读队列和写队列的超时时间设置为0，就不会挂起任务，接口会直接返回，这就是非阻塞模式。反之，如果将读队列和写队列的超时时间设置为大于0的时间，就会以阻塞模式运行。 11 12消息队列提供了异步处理机制，允许将一个消息放入队列，但不立即处理。同时队列还有缓冲消息的作用，可以使用队列实现任务异步通信，队列具有如下特性： 13 14- 消息以先进先出的方式排队，支持异步读写。 15- 读队列和写队列都支持超时机制。 16- 每读取一条消息，就会将该消息节点设置为空闲。 17- 发送消息类型由通信双方约定，可以允许不同长度（不超过队列的消息节点大小）的消息。 18- 一个任务能够从任意一个消息队列接收和发送消息。 19- 多个任务能够从同一个消息队列接收和发送消息。 20- 创建普通队列时所需的队列空间，由系统自行动态申请内存。 21- 创建静态队列时所需的队列空间，由用户传入。这块空间在队列删除之后也由用户去释放。 22 23 24## 运行机制 25 26### 队列控制块 27 28队列会在初始化时给分配一个属于自己的控制块，控制块包含了队列的名称、状态等信息。删除队列时会释放该控制块。 29 30队列控制块数据结构如下： 31 32 33``` 34typedef struct 35{ 36 UINT8 *queue; /* 队列消息内存空间的指针 */ 37 UINT8 *queueName /* 队列名称 */ 38 UINT16 queueState; /* 队列状态 */ 39 UINT16 queueLen; /* 队列中消息节点个数，即队列长度 */ 40 UINT16 queueSize; /* 消息节点大小 */ 41 UINT16 queueID; /* 队列ID */ 42 UINT16 queueHead; /* 消息头节点位置（数组下标）*/ 43 UINT16 queueTail; /* 消息尾节点位置（数组下标）*/ 44 UINT16 readWriteableCnt[OS_READWRITE_LEN]; /* 数组下标0的元素表示队列中可读消息数， 45 数组下标1的元素表示队列中可写消息数 */ 46 LOS_DL_LIST readWriteList[OS_READWRITE_LEN]; /* 读取或写入消息的任务等待链表， 47 下标0：读取链表，下标1：写入链表 */ 48 LOS_DL_LIST memList; /* 内存块链表 */ 49} LosQueueCB; 50``` 51 52每个队列控制块中都含有队列状态，表示该队列的使用情况： 53 54- OS_QUEUE_UNUSED：队列未被使用。 55 56- OS_QUEUE_INUSED：队列被使用中。 57 58 59### 队列运作原理 60 61- 创建队列时，创建队列成功会返回队列ID。 62 63- 在队列控制块中维护着一个消息头节点位置Head和一个消息尾节点位置Tail，用于表示当前队列中消息的存储情况。Head表示队列中被占用的消息节点的起始位置。Tail表示被占用的消息节点的结束位置，也是空闲消息节点的起始位置。队列刚创建时，Head和Tail均指向队列起始位置。 64 65- 写队列时，根据readWriteableCnt[1]判断队列是否可以写入，不能对已满（readWriteableCnt[1]为0）队列进行写操作。写队列支持两种写入方式：向队列尾节点写入，也可以向队列头节点写入。尾节点写入时，根据Tail找到起始空闲消息节点作为数据写入对象，如果Tail已经指向队列尾部则采用回卷方式。头节点写入时，将Head的前一个节点作为数据写入对象，如果Head指向队列起始位置则采用回卷方式。 66 67- 读队列时，根据readWriteableCnt[0]判断队列是否有消息需要读取，对全部空闲（readWriteableCnt[0]为0）队列进行读操作会引起任务挂起。如果队列可以读取消息，则根据Head找到最先写入队列的消息节点进行读取。如果Head已经指向队列尾部则采用回卷方式。 68 69- 删除队列时，根据队列ID找到对应队列，把队列状态置为未使用，把队列控制块置为初始状态，并释放队列所占内存。 70 71 **图1** 队列读写数据操作示意图 72 73  74 75上图对读写队列做了示意，图中只画了尾节点写入方式，没有画头节点写入，但是两者是类似的。 76 77 78## 接口说明 79 80| 功能分类 | 接口描述 | 81| -------- | -------- | 82| 创建/删除消息队列 | LOS_QueueCreate：创建一个消息队列，由系统动态申请队列空间。<br/>LOS_QueueCreateStatic：创建一个消息队列，由用户传入队列空间。<br/> LOS_QueueDelete：根据队列ID删除一个指定队列，静态消息队列删除后，队列空间需要用例自行处理。 | 83| 读/写队列（不带拷贝） | LOS_QueueRead：读取指定队列头节点中的数据（队列节点中的数据实际上是一个地址）。<br/> LOS_QueueWrite：向指定队列尾节点中写入入参bufferAddr的值（即buffer的地址）。<br/> LOS_QueueWriteHead：向指定队列头节点中写入入参bufferAddr的值（即buffer的地址）。 | 84| 读/写队列（带拷贝） | LOS_QueueReadCopy：读取指定队列头节点中的数据。<br/> LOS_QueueWriteCopy：向指定队列尾节点中写入入参bufferAddr中保存的数据。<br/> LOS_QueueWriteHeadCopy：向指定队列头节点中写入入参bufferAddr中保存的数据。 | 85| 获取队列信息 | LOS_QueueInfoGet：获取指定队列的信息，包括队列ID、队列长度、消息节点大小、头节点、尾节点、可读节点数量、可写节点数量、等待读操作的任务、等待写操作的任务。 | 86 87 88## 开发流程 89 901. 用LOS_QueueCreate创建队列。创建成功后，可以得到队列ID。 91 922. 通过LOS_QueueWrite或者LOS_QueueWriteCopy写队列。 93 943. 通过LOS_QueueRead或者LOS_QueueReadCopy读队列。 95 964. 通过LOS_QueueInfoGet获取队列信息。 97 985. 通过LOS_QueueDelete删除队列。 99 100 101>  **说明：** 102> - 系统支持的最大队列数是指：整个系统的队列资源总个数，而非用户能使用的个数。例如：系统软件定时器多占用一个队列资源，那么用户能使用的队列资源就会减少一个。 103> 104> - 创建队列时传入的队列名和flags暂时未使用，作为以后的预留参数。 105> 106> - 队列接口函数中的入参timeOut是相对时间。 107> 108> - LOS_QueueReadCopy和LOS_QueueWriteCopy及LOS_QueueWriteHeadCopy是一组接口，LOS_QueueRead和LOS_QueueWrite及LOS_QueueWriteHead是一组接口，每组接口需要配套使用。 109> 110> - 鉴于LOS_QueueWrite和LOS_QueueWriteHead和LOS_QueueRead这组接口实际操作的是数据地址，用户必须保证调用LOS_QueueRead获取到的指针所指向的内存区域在读队列期间没有被异常修改或释放，否则可能导致不可预知的后果。 111> 112> - LOS_QueueReadCopy接口的读取长度如果小于消息实际长度，消息将被截断。 113> 114> - 鉴于LOS_QueueWrite和LOS_QueueWriteHead和LOS_QueueRead这组接口实际操作的是数据地址，也就意味着实际写和读的消息长度仅仅是一个指针数据，因此用户使用这组接口之前，需确保创建队列时的消息节点大小，为一个指针的长度，避免不必要的浪费和读取失败。 115 116 117## 编程实例 118 119 120### 实例描述 121 122创建一个队列，两个任务。任务1调用写队列接口发送消息，任务2通过读队列接口接收消息。 123 1241. 通过LOS_TaskCreate创建任务1和任务2。 125 1262. 通过LOS_QueueCreate创建一个消息队列。 127 1283. 在任务1 SendEntry中发送消息。 129 1304. 在任务2 RecvEntry中接收消息。 131 1325. 通过LOS_QueueDelete删除队列。 133 134 135### 示例代码 136 137示例代码如下： 138 139本演示代码在 ./kernel/liteos_m/testsuites/src/osTest.c 中编译验证，在TestTaskEntry中调用验证入口函数ExampleQueue。 140 141 142``` 143#include "los_task.h" 144#include "los_queue.h" 145 146STATIC UINT32 g_queue; 147#define BUFFER_LEN 50 148 149VOID SendEntry(VOID) 150{ 151 UINT32 ret = 0; 152 CHAR abuf[] = "test message"; 153 UINT32 len = sizeof(abuf); 154 155 ret = LOS_QueueWriteCopy(g_queue, abuf, len, 0); 156 if (ret != LOS_OK) { 157 printf("send message failure, error: %x\n", ret); 158 } 159} 160 161VOID RecvEntry(VOID) 162{ 163 UINT32 ret = 0; 164 CHAR readBuf[BUFFER_LEN] = {0}; 165 UINT32 readLen = BUFFER_LEN; 166 167 /* 休眠1s */ 168 usleep(1000000); 169 ret = LOS_QueueReadCopy(g_queue, readBuf, &readLen, 0); 170 if (ret != LOS_OK) { 171 printf("recv message failure, error: %x\n", ret); 172 } 173 174 printf("recv message: %s.\n", readBuf); 175 176 ret = LOS_QueueDelete(g_queue); 177 if (ret != LOS_OK) { 178 printf("delete the queue failure, error: %x\n", ret); 179 } 180 181 printf("delete the queue success.\n"); 182} 183 184UINT32 ExampleQueue(VOID) 185{ 186 printf("start queue example.\n"); 187 UINT32 ret = 0; 188 UINT32 task1; 189 UINT32 task2; 190 TSK_INIT_PARAM_S taskParam1 = { 0 }; 191 TSK_INIT_PARAM_S taskParam2 = { 0 }; 192 193 LOS_TaskLock(); 194 195 taskParam1.pfnTaskEntry = (TSK_ENTRY_FUNC)SendEntry; 196 taskParam1.usTaskPrio = 9; 197 taskParam1.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 198 taskParam1.pcName = "SendQueue"; 199 ret = LOS_TaskCreate(&task1, &taskParam1); 200 if(ret != LOS_OK) { 201 printf("create task1 failed, error: %x\n", ret); 202 return ret; 203 } 204 205 taskParam2.pfnTaskEntry = (TSK_ENTRY_FUNC)RecvEntry; 206 taskParam2.usTaskPrio = 10; 207 taskParam2.uwStackSize = LOSCFG_BASE_CORE_TSK_DEFAULT_STACK_SIZE; 208 taskParam2.pcName = "RecvQueue"; 209 ret = LOS_TaskCreate(&task2, &taskParam2); 210 if(ret != LOS_OK) { 211 printf("create task2 failed, error: %x\n", ret); 212 return ret; 213 } 214 215 ret = LOS_QueueCreate("queue", 5, &g_queue, 0, 50); 216 if(ret != LOS_OK) { 217 printf("create queue failure, error: %x\n", ret); 218 } 219 220 printf("create the queue success.\n"); 221 LOS_TaskUnlock(); 222 return ret; 223} 224``` 225 226 227### 结果验证 228 229编译运行得到的结果为： 230 231 232 233``` 234start queue example. 235create the queue success. 236recv message: test message. 237delete the queue success. 238``` 239
