RTT消息队列的使用问题

发布于 2018-12-22 17:35:56 浏览：2926 订阅该版

* 本帖最后由 吉帅虎 于 2018-12-22 17:38 编辑 *

刚开始使用RT_thread，一直跑独立的线程。现在进行到需要做一个带触摸的串口屏，因此需要接受屏的数据并执行相应的指令。
我的思路是这样的，当然主要是参考了编程手册里关于串口设备的使用方法：
在串口的回调函数里发送一个消息。在串口的进程中一致接受这个消息队列，然后执行相应的处理。现在的问题是消息队列使用方法可能不正确，无法正常工作。
提示这样的错误，(mq != RT_NULL) assertion failed at function:rt_mq_init, line number:1802 
代码如下：
```/*
 * 程序清单：HMI显示
 *
 *
 * 
 * 
 */

#include <rtthread.h>
#include <rtdevice.h>
#include "StructDefine.h"
#include "sys_thread.h"
#include "GlobalVar.h"

struct rx_msg
{
    rt_device_t dev;
    rt_size_t size;
};

/* 用于接收消息的消息队列*/
static rt_mq_t rx_mq;
rt_uint8_t mempool[512];
/*****************************************************************************/
//开关量输入处理相关的代码
/*****************************************************************************/
void RamCopy(rt_uint8_t *Tp,rt_uint8_t *Sp,rt_uint8_t len)
{
    while(len--)
    {
        *Tp++ = *Sp++;
    }
    
}

static rt_err_t uart_input(rt_device_t dev, rt_size_t size)
{
    struct rx_msg msg;
    msg.dev = dev;
    msg.size = size;
    /* 发送消息到消息队列中*/
    rt_mq_send(rx_mq, &msg, sizeof(struct rx_msg));
    return RT_EOK;
}
//******************************************************************************
// 函数名称:        static void kr_thread_entry(void *parameter)
// 功能描述:        开关量输入处理线程
//
// 输  入:        void *parameter,参数指针无
// 输　出:                无
// 返  回:        无
//------------------------------------------------------------------------------
// 作　者: JSH
// 日　期: 2018-10-10
//------------------------------------------------------------------------------
// 修改人:
// 日　期:
//******************************************************************************
ALIGN(RT_ALIGN_SIZE)
rt_uint8_t hmi_stack[HMI_STACK_LENGTH];
struct rt_thread hmi_thread;// 线程的TCB控制块 ,句柄

void hmi_thread_entry(void *parameter)
{
    struct rx_msg msg;
    rt_err_t result = RT_EOK;
    
    rt_device_t HMI_uart;
    rt_uint8_t  HMI_tx_buffer[64];
  
    rt_mq_init(rx_mq,"HMI_mq",&mempool[0],256,sizeof(mempool),RT_IPC_FLAG_FIFO);

HMI_uart = rt_device_find("uart4");  
    if (HMI_uart != RT_NULL)
    {
        rt_device_set_rx_indicate(HMI_uart, uart_input); //设置回调函数
        rt_device_open(HMI_uart, RT_DEVICE_OFLAG_RDWR | RT_DEVICE_FLAG_STREAM); //打开设备
    }
    
    while (1)
    {
        /* 从消息队列中读取消息*/
        result = rt_mq_recv(rx_mq, &msg, sizeof(struct rx_msg), RT_TICK_PER_SECOND);
        
        if (result == RT_EOK)
        {
            while(1);
        }
        else
        {
             HMI_tx_buffer[0] = 0x5A;
            HMI_tx_buffer[1] = 0xA5;        //帧头

RamCopy(&HMI_tx_buffer[2],(rt_uint8_t *)&MeasureData.Data[0],48);

rt_device_write(HMI_uart, 0,&HMI_tx_buffer[0], 50);

rt_thread_delay(RT_TICK_PER_SECOND);    //1s钟刷新一次
        }

}
}

//*********************************************************************************************
// end the file
//*********************************************************************************************
```
断言错误是在这一句遇到的 rt_mq_init(rx_mq,"HMI_mq",&mempool[0],256,sizeof(mempool),RT_IPC_FLAG_FIFO);具体的行的代码是这一句   RT_ASSERT(mq != RT_NULL);
第一次在项目中使用RTT，也是第一次使用消息队列。不知道是哪儿的问题，希望大神给指导一下，谢谢！！