RT-Thread-15天rt-thread入门学习 - 第十天（消息队列的使用）RT-Thread问答社区

15天rt-thread入门学习 - 第十天（消息队列的使用）

发布于 2018-05-26 13:24:17 浏览：3814 订阅该版

* 本帖最后由 coolbor 于 2018-5-28 08:49 编辑 *

消息队列的使用
主要内容：
1、结合邮箱相关API 介绍消息队列相关API
   初始化（静态创建）/创建（动态创建）、删除/脱离、发送/接收
   ----------------------------------------------------------------
   邮箱             消息队列
   -------------------------------
   rt_mb_init       rt_mq_init
   rt_mb_create     rt_mq_create
   rt_mb_delete     rt_mq_delete
   rt_mb_detach     rt_mq_detach
   rt_mb_send       rt_mq_send
   rt_mb_send_wait  rt_mq_urgent
   rt_mb_recv       rt_mq_recv
2、例程源码解析
   ----------------------------------------------------------------
   静态定义消息队列：
   static struct rt_messagequeue mq;
   /* 消息队列中用到的放置消息的内存池 */
   static rt_uint8_t msg_pool[2048];
   动态定义消息队列：
   static rt_mq_t mq_d = RT_NULL;
   ----------------------------------------------------------------
   静态初始化消息队列：
   /* 初始化消息队列 */
    result = rt_mq_init(&mq,                        /* 消息队列控制块 */
                        "mqt",
                        &msg_pool[0],               /* 内存池指向msg_pool */
                        1,                          /* 每个消息的大小是 1 字节 */
                        sizeof(msg_pool),           /* 内存池的大小是msg_pool的大小 */
                        RT_IPC_FLAG_FIFO);          /* 如果有多个线程等待，按照先来先得到的方法分配消息 */
   动态创建消息队列：
   mq_d = rt_mq_create("mq_d",
                       1,
					   sizeof(msg_pool),
                       RT_IPC_FLAG_FIFO);
   ----------------------------------------------------------------
   脱离消息队列:
   rt_mq_detach(&mq);
   删除消息队列对象:
   rt_mq_delete(mq_d);
   ----------------------------------------------------------------
   发送紧急消息:
   result = rt_mq_urgent(&mq, &buf, 1);
   发送消息:
   result = rt_mq_send(&mq, &buf, 1);
   接收消息:
   result = rt_mq_recv(&mq, &buf, sizeof(buf), RT_WAITING_FOREVER);
   
3、邮箱和消息队列的几点区别
   邮箱：
   邮件尽量不要定义为局部变量，而应定义为全局变量
   邮件的大小只能为4个字节
   消息队列：
   消息既可以定义为局部变量，也可定义为全局变量
   消息的长度可以是任意字节
   消息队列包含了一个发送紧急消息的函数接口。
   当创建的是一个所有消息的最大长度是4字节的消息队列时，消息队列对象将蜕化成邮箱。
4、消息队列的同步问题
   消息队列是一种异步通信方式。
   接收方需要告诉发送方自身已经接收到消息了。（可以使用mailbox、semaphore等方式）
   消息队列可以应用于发送不定长度消息的场合，包括线程与线程间的消息交换，以及中断服务例程中发送给线程的消息（中断服务例程不可能接收消息）。
=================================================================================================
作业：
1、使用消息队列进行实际操作
   比如：key和led的配合。
-------------------------------------------------------------------------------------------------
```
#include <rtthread.h>

#define KEY_0	0xa0
#define KEY_1	0xa1

#define LED_0	0
#define LED_1	1

static struct rt_messagequeue mq;
static rt_uint8_t msg_pool[2048];

ALIGN(RT_ALIGN_SIZE)
static char thread1_stack[1024];
static struct rt_thread thread1;
/* 线程1入口 */
static void thread1_entry(void *parameter)
{
    rt_uint8_t keyValue;
	rt_err_t result;
	
	led_init();/* led初始化 */

while (1)
    {
        /* 从邮箱中收取邮件 */
		result = rt_mq_recv(&mq, &keyValue, sizeof(keyValue), RT_WAITING_FOREVER);
        if (result == RT_EOK)
        {
            switch(keyValue)
			{
				case KEY_0:
					ledToggle(LED_0);/* LED显示程序，调用一次，LED的状态反转一次 */
					break;
				case KEY_1:
					ledToggle(LED_1);/* LED显示程序，调用一次，LED的状态反转一次 */
					break;
				default:
					break;
			}
        }
    }
}

ALIGN(RT_ALIGN_SIZE)
static char thread2_stack[1024];
static struct rt_thread thread2;
/* 线程2入口 */
static void thread2_entry(void *parameter)
{
    rt_uint8_t keyValue = 0;
	
	key_init();/* 按键初始化 */

while (1)
    {
        rt_thread_delay(20);      /* 此处假设#define RT_TICK_PER_SECOND 1000 */
		keyValue = KeyScanning(); /* 按键扫描程序，无按键按下时返回0，有按键按下时返回相应的键值 */
        result = rt_mq_send(&mq, &keyValue, 1);
    }
}

int messagequeue_sample_init()
{
    rt_err_t result;

/* 初始化消息队列 */
    result = rt_mq_init(&mq,
                        "mqt",
                        &msg_pool[0],               /* 内存池指向msg_pool */
                        1,                          /* 每个消息的大小是 1 字节 */
                        sizeof(msg_pool),           /* 内存池的大小是msg_pool的大小 */
                        RT_IPC_FLAG_FIFO);          /* 如果有多个线程等待，按照先来先得到的方法分配消息 */
						
    if (result != RT_EOK)
    {
        rt_kprintf("init message queue failed.<br>");
        return -1;
    }

rt_thread_init(&thread1,
                   "led",
                   thread1_entry,
                   RT_NULL,
                   &thread1_stack[0],
                   sizeof(thread1_stack), 10, 5);
    rt_thread_startup(&thread1);

rt_thread_init(&thread2,
                   "key",
                   thread2_entry,
                   RT_NULL,
                   &thread2_stack[0],
                   sizeof(thread2_stack), 10, 5);
    rt_thread_startup(&thread2);
    return 0;
}
/* 如果设置了RT_SAMPLES_AUTORUN，则加入到初始化线程中自动运行 */
#ifdef RT_SAMPLES_AUTORUN
    INIT_APP_EXPORT(mailbox_messagequeue_init);
#endif
/* 导出到 msh 命令列表中 */
MSH_CMD_EXPORT(messagequeue_sample_init, messagequeue sample);
```