RT-Thread-第10天：消息队列的使用 [15天rt-thread入门学习]RT-Thread问答社区

第10天：消息队列的使用 [15天rt-thread入门学习]

发布于 2018-06-04 21:12:23 浏览：1615 订阅该版

* 本帖最后由 wolfgang2018 于 2018-6-4 22:16 编辑 *

1、	使用消息队列进行实际操作，比如：key 和Led配合；感受消息队列的相同点和不同点
实验现象：

![01.jpg](/uploads/201806/04/210904wntmwowfz3xfxzff.jpg)
按钮1在释放的时候产生的下降沿中断使线程3向队列发送1条消息 序号0，这时LED0灯亮起；

![02.jpg](/uploads/201806/04/210910ee9wkd6hz512s1eh.jpg)
按钮2在释放的时候产生的中断使线程向队列发送10条消息，序号从1
到10，线程1从消息队列中逐步获取10条消息；同时LED1亮起

按钮3在释放的时候产生的中断使线程向队列发送1条消息，序号是21，因为消息是紧急的，该消息让线程1在15和16条消息之间从消息队列中接收，这时候LED0、LED1同时亮起。
![03.jpg](/uploads/201806/04/210913crsrz2pv4vus3vsk.jpg)

最大的不同就是油箱是传送地址，队列是传送复制数据，可以消息在队列中可以插队

作业代码：
在msq.c中增加以下代码
```
//引入RT设备库
#include <rtdevice.h>
//定义三个按键对应的引脚
#define Key_0_Pin_MSG //PA0
#define Key_1_Pin_MSG //PA1
#define Key_2_Pin_MSG //PA2
//邮箱控制块 与三个邮件
static struct rt_messagequeue mq;
/* 消息队列中用到的放置消息的内存池 */
static rt_uint8_t msg_pool[2048];

//定义线程1堆空间 及线程1的结构；
static char thread1_stack_msg[1024];
static struct rt_thread thread1_msg;
//定义消息变量
rt_uint8_t buf_msg = 0;
//定义消息队列中的按键和LED函数
void pass_key1_msg(void *);
void pass_key2_msg(void *);
void pass_key3_msg(void *);
void rt_hw_key_init_msg(void);
void rt_hw_led_init_msg(void);
//线程1实体不变
static void thread1_entry_msg(void *parameter) {
…..
}

//定义按键1，向消息队列发送1条消息。
void pass_key1_msg(void *parameter){
	rt_pin_write(LED_0_PIN, 1);
	rt_pin_write(LED_1_PIN, 0);
	rt_mq_send(&mq, &buf_msg, 1);
	rt_kprintf("key1: send - %d ", buf_msg);
	buf_msg++;
}

//定义按键2，向消息队列发送10条消息，线程1逐条等待。
void pass_key2_msg(void *parameter){
	rt_uint8_t temp=buf_msg;
 rt_pin_write(LED_1_PIN, 1);
 rt_pin_write(LED_0_PIN, 0);
	rt_kprintf("key2: send begin - %d ", buf_msg);
	while (1) {	 
		if (((temp<246)&((buf_msg-temp)>=10)) | ((temp>=246)&((255-temp+buf_msg)>=10))){
			break;
		}
		rt_mq_send(&mq, &buf_msg, 1);
		buf_msg++;
	}	 
 rt_kprintf("key2: send next begin - %d ", buf_msg-1);	
}

//定义按键3，向消息队列发送1条紧急消息，线程1有优先处理紧急消息21，执行完消息后按顺序继续执行按键2的队列内容；
void pass_key3_msg(void *parameter){
	rt_pin_write(LED_0_PIN, 1);
	rt_pin_write(LED_1_PIN, 1);
	rt_err_t result=rt_mq_urgent(&mq, &buf_msg, 1);
	if (result != RT_EOK){
 rt_kprintf("rt_mq_urgent ERR ");
 }
	rt_kprintf("key3: send urgent message - %d ", buf_msg);
	buf_msg++;
}
//初始化LED
void rt_hw_led_init_msg(void)
{
 rt_pin_mode(LED_0_PIN, PIN_MODE_OUTPUT);
 rt_pin_mode(LED_1_PIN, PIN_MODE_OUTPUT);
}

//初始化按键操作
void rt_hw_key_init_msg(void){	  
    rt_pin_mode(Key_0_Pin_MSG, PIN_MODE_INPUT_PULLDOWN);
    rt_pin_mode(Key_1_Pin_MSG, PIN_MODE_INPUT_PULLDOWN);	
  	rt_pin_mode(Key_2_Pin_MSG, PIN_MODE_INPUT_PULLDOWN);
	
		rt_pin_attach_irq(Key_0_Pin_MSG,PIN_IRQ_MODE_FALLING,&pass_key1_msg,RT_NULL);
	  rt_pin_attach_irq(Key_1_Pin_MSG,PIN_IRQ_MODE_FALLING,&pass_key2_msg,RT_NULL);
	  rt_pin_attach_irq(Key_2_Pin_MSG,PIN_IRQ_MODE_FALLING,&pass_key3_msg,RT_NULL);
	
	  rt_pin_irq_enable(Key_0_Pin_MSG,PIN_IRQ_ENABLE);
	  rt_pin_irq_enable(Key_1_Pin_MSG,PIN_IRQ_ENABLE);
    rt_pin_irq_enable(Key_2_Pin_MSG,PIN_IRQ_ENABLE);	
}

//线程三 相关内容：
static char thread3_stack_msg[1024];
static struct rt_thread thread3_msg;
/* 线程3入口 */
static void thread3_entry_msg(void *parameter){
	  rt_hw_key_init_msg();	
	  rt_hw_led_init_msg();
}

/* 消息队列示例的初始化 */
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. ");
 return -1;
 }
 rt_thread_init(&thread1_msg,
 "thread1m",
 thread1_entry_msg,
 RT_NULL,
 &thread1_stack_msg[0],
 sizeof(thread1_stack_msg), 25, 5);
 rt_thread_startup(&thread1_msg);

rt_thread_init(&thread3_msg,
                   "thread3m",
                   thread3_entry_msg,
                   RT_NULL,
                   &thread3_stack_msg[0],
                   sizeof(thread3_stack_msg), 10, 5);
    rt_thread_startup(&thread3_msg);		
    return 0;
}

```

[https://www.rt-thread.org/qa/thread-7210-1-1.html](第01天：初识RT-Thread [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7211-1-1.html](第02天：系统启动代码和用户入口 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7261-1-1.html](第03天：线程的创建与删除 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7262-1-1.html](第04天：空闲任务及其钩子函数 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7263-1-1.html](第05天：中断和临界区保护 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7264-1-1.html](第06天：堆的初始化和使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7265-1-1.html](第07天：信号量的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7266-1-1.html](第08天：互斥量的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7267-1-1.html](第09天：邮箱的使用 [15天rt-thread入门学习])

[https://www.rt-thread.org/qa/thread-7271-1-1.html](第11天：事件的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7272-1-1.html](第12天：生产者-消费者问题 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7273-1-1.html](第13天：生产者-消费者问题 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7274-1-1.html](第14天：软件定时器 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7275-1-1.html](第15天：内存池[15天rt-thread入门学习])