Kernel

消息列队内存池大小如何确定？

发布于 2019-01-18 08:36:29 浏览：2258 订阅该版

8 个回答

gunai 2019-01-18

这家伙很懒，什么也没写！

[i=s] 本帖最后由 gunai 于 2019-1-18 09:00 编辑 [/i]

代码是这样的

```
BOOL
xMBPortEventPost( eMBEventType eEvent )
{
    BOOL            bStatus = TRUE;
    rt_err_t        result;
    if( bMBPortIsWithinException(  ) )
    {
        result=rt_mq_urgent(&mq, &eEvent, sizeof(eEvent));//紧急消息
        if(result==RT_EOK)   bStatus = TRUE;
    }
    else
    {
        result=rt_mq_send(&md, &eEvent, sizeof(eEvent));
        if(result==RT_EOK)
          bStatus = TRUE;
    }
    return bStatus;
}

BOOL
xMBPortEventGet( eMBEventType * peEvent )
{
    BOOL            xEventHappened = FALSE;
    if( rt_mq_recv(&mq, peEvent,sizeof(peEvent), RT_WAITING_FOREVER ) == RT_EOK )
    {
    xEventHappened = TRUE;
    }
    return xEventHappened;
}
```

（eMBEventType eEvent)与 (eMBEventType *peEvent)是个枚举内容是

```
typedef enum
{
    EV_READY,                   /*!< Startup finished. */
    EV_FRAME_RECEIVED,          /*!< Frame received. */
    EV_EXECUTE,                 /*!< Execute function. */
    EV_FRAME_SENT               /*!< Frame sent. */
} eMBEventType;
```

```
/* 消息队列控制块 */ 
static struct rt_messagequeue mq; 
/* 消息队列中用到的放置消息的内存池 */
 static char msg_pool[2048];---我修改的是这里，改成static char msg_pool[30];

```

初始化函数

```

/* 初始化消息队列 */
 rt_mq_init(&mq, "mqt", &msg_pool[0], /* 内存池指向msg_pool */ 
                               128 - sizeof(void*), /* 每个消息的大小是 128 - void* */
                                sizeof(msg_pool), /* 内存池的大小是msg_pool的大小 */ 
                                RT_IPC_FLAG_FIFO); /* 如果有多个线程等待，按照FIFO的方法分配消息 */

```