首先我们怀着问题读代码：“进程间是如何传递大数据的？”
消息队列解决任务间大数据的传递。
消息队列，是一种常用于任务间通信的数据结构。队列接收来自任务或中断的不固定长度消息，并根据不同的接口确定传递的消息是否存放在队列空间中。
消息队列提供了异步处理机制，允许将一个消息放入队列，但不立即处理。同时队列还有缓冲消息的作用。
队列用于任务间通信，可以实现消息的异步处理。同时消息的发送方和接收方不需要彼此联系，两者间是解耦的。（设计原则是解耦）
下面我将结合代码来分析它的几大特性：
首先来看一个基本的消息队列：
#ifndef LOSCFG_BASE_IPC_QUEUE_LIMIT
#define LOSCFG_BASE_IPC_QUEUE_LIMIT 1024 //队列个数
#endif
LITE_OS_SEC_BSS LosQueueCB *g_allQueue = NULL;//消息队列池
LITE_OS_SEC_BSS STATIC LOS_DL_LIST g_freeQueueList;//空闲队列链表，管分配的，需要队列从这里申请
typedef struct {
UINT8 *queueHandle; /**< Pointer to a queue handle */ //指向队列句柄的指针
UINT16 queueState; /**< Queue state */ //队列状态
UINT16 queueLen; /**< Queue length */ //队列中消息总数的上限值，由创建时确定，不再改变
UINT16 queueSize; /**< Node size */ //消息节点大小，由创建时确定，不再改变，即定义了每个消息长度的上限.
UINT32 queueID; /**< queueID */ //队列ID
UINT16 queueHead; /**< Node head */ //消息头节点位置（数组下标）
UINT16 queueTail; /**< Node tail */ //消息尾节点位置（数组下标）
UINT16 readWriteableCnt[OS_QUEUE_N_RW];
//队列中可写或可读消息数，0表示可读，1表示可写
LOS_DL_LIST readWriteList[OS_QUEUE_N_RW]; /**< the linked list to be read or written， 0:readlist， 1:writelist */
//挂的都是等待读/写消息的任务链表，0表示读消息的链表，1表示写消息的任务链表
LOS_DL_LIST memList;
} LosQueueCB;//读写队列分离
具有以下特性
[√]消息以先进先出的方式排队，支持异步读写。
[√]读队列和写队列都支持超时机制。
[√]每读取一条消息，就会将该消息节点设置为空闲。
[√]发送消息类型由通信双方约定，可以允许不同长度的消息。
[√]一个任务能够从任意一个消息队列接收和发送消息。
[√]多个任务能够从同一个消息队列接收和发送消息。
[√]创建队列时所需的队列空间，默认支持接口内系统自行动态申请内存的方式，同时也支持将用户分配的队列空间作为接口入参传入的方式。
建立过程依次是：初始化队列->创建队列->任务A调用写队列接口发送消息，任务B通过读队列接口接收消息。
下面将举例分析初始化队列的过程
LITE_OS_SEC_TEXT_INIT UINT32 OsQueueInit(VOID)//消息队列模块初始化
{
LosQueueCB *queueNode = NULL;
UINT32 index;
UINT32 size;
size = LOSCFG_BASE_IPC_QUEUE_LIMIT * sizeof(LosQueueCB);//支持1024个IPC队列
/* system resident memory， don't free */
g_allQueue = (LosQueueCB *)LOS_MemAlloc(m_aucSysMem0， size);//常驻内存
if (g_allQueue == NULL) {
return LOS_ERRNO_QUEUE_NO_MEMORY;
}
(VOID)memset_s(g_allQueue， size， 0， size);//清0
LOS_ListInit(&g_freeQueueList);//初始化空闲链表
for (index = 0; index < LOSCFG_BASE_IPC_QUEUE_LIMIT; index++) {//循环初始化每个消息队列
queueNode = ((LosQueueCB *)g_allQueue) + index;//一个一个来
queueNode->queueID = index;//队列的身份证
LOS_ListTailInsert(&g_freeQueueList， &queueNode->readWriteList[OS_QUEUE_WRITE]);//通过写节点挂到空闲队列链表上
}//这里要注意是用 readWriteList 挂到 g_freeQueueList链上的，要通过 GET_QUEUE_LIST 来找到 LosQueueCB
if (OsQueueDbgInitHook() != LOS_OK) {//调试队列使用的.
return LOS_ERRNO_QUEUE_NO_MEMORY;
}
return LOS_OK;
}
总结：消息队列解决任务间大数据的传递，以一种异步，解耦的方式实现任务通讯。
原作者：夏贤凤
更多回帖
