RT-Thread-[第二期空气质量分析仪] 第3周作业RT-Thread问答社区

[第二期空气质量分析仪] 第3周作业

发布于 2019-09-12 22:38:41 浏览：1099 订阅该版

由于以前没学过消息队列、信号量、互斥量、事件、邮箱这些，这周把野火的《RT-Thread内核实现与应用开发实战指南》看了一编
学习笔记：
1、创建线程两种方法：①先把所有的线程创建完成后再开启调度②创建一个开启一个调度
2、硬件仿真时先执行启动文件里由汇编写的复位函数Rest_Handler，然后调用C库函数__main，之后跳转到main函数的扩展函数$Sub$$main函数（在component.c文件中，$Sub$$main函数的末尾必须调用$Super$$main函数回到原函数，当需要扩展的函数不是main函数时只需把main换成要扩展的函数名即可）
3、消息队列mq，信号量sem，互斥量mutex，事件event
4、一般来说处理时间更短的线程优先级应设置更高一些
5、SPI IIC为同步通信  UART为异步通信
6、邮箱的初始化与脱离（rt_mb_detach）是针对静态邮箱的，删除创建是针对动态邮箱的。
一、邮箱创建
```/*定义线程控制块*/
rt_thread_t receive_thread = RT_NULL;
rt_thread_t send_thread = RT_NULL;
/*定义动态邮箱控制块*/
rt_mailbox_t test_mail = RT_NULL;

struct msg
{
  char *tag;
  rt_uint32_t dat;
};

void myloginit(void)
{
		/*创建一个动态邮箱*/
	test_mail = rt_mb_create("test_mail",
													10,
													RT_IPC_FLAG_FIFO);
	if(test_mail != RT_NULL)
		rt_kprintf("动态邮箱创建成功 ");
	/*接收线程*/
	receive_thread = rt_thread_create("receive",
																		receive_thread_entry,
																		RT_NULL,
																		512,
																		13,
																		30);
	if(receive_thread != RT_NULL)
		rt_thread_startup(receive_thread);
}

static void receive_thread_entry(void* parameter)
{
	rt_err_t uwRet=RT_EOK;
	struct msg *r_str;
	while(1)
	{
		uwRet=rt_mb_recv(test_mail,
										(rt_ubase_t*)&r_str,
										RT_WAITING_FOREVER);
		if(RT_EOK == uwRet) /* 如果接收完成并且正确 */
 {
 if(rt_strcmp("TEMP",r_str->tag)==0)
					rt_kprintf ( "[%s] data is:%d ℃ ",r_str->tag,r_str->dat);	
				if(rt_strcmp("HUMI",r_str->tag)==0)
					rt_kprintf ( "[%s] data is:%d %% ",r_str->tag,r_str->dat);	
				if(rt_strcmp("MQ135",r_str->tag)==0)
					rt_kprintf ( "[%s] data is:%d.%d ",r_str->tag,r_str->dat/100,r_str->dat%100);
				if(rt_strcmp("PM25",r_str->tag)==0)
					rt_kprintf ( "[%s] data is:%d.%d mg/m3 ",r_str->tag,r_str->dat/100,r_str->dat%100);		
 }
 else
 rt_kprintf ( "邮箱接收错误！错误码是0x%x ",uwRet);
			rt_free(r_str);
	}
}

void mylog(char* tag, rt_uint32_t data)
{
	struct msg *amsg;
  
  amsg = (struct msg *)rt_malloc(sizeof(struct msg));
  amsg->tag = tag;
  amsg->dat = data;
  rt_mb_send(test_mail, (rt_uint32_t)amsg); 
}```二、事件创建
```void led_blink_event(rt_uint32_t p)
{
	switch(p) 
	{
		case EVENT_FLAG_TEMPHUMI:
		temp_thread_read();
			break;
		case EVENT_FLAG_PM25:
		pm25_thread_read();
			break;
		case EVENT_FLAG_MQ135:
		mq135_thread_read();
			break;
	}
}

static void led_entry(void* parameter)
{
    while(1)
    {
        if (rt_event_recv(led_event, 
														EVENT_FLAG_TEMPHUMI | EVENT_FLAG_PM25 | EVENT_FLAG_MQ135,
                          RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
                          RT_WAITING_FOREVER, &e) == RT_EOK)
        {
            led_blink_event(e);
        }
    }
}

void key_cb0(void *args)
{ 
	static rt_uint8_t t0=1;
	
	if( rt_pin_read(KEY0) == PIN_LOW)
	{
		rt_thread_mdelay(20);//防抖处理
		if( rt_pin_read(KEY0) == PIN_LOW)
		{
			t0++;
			if(t0%2 == 0)
			{
				rt_event_send(led_event,EVENT_FLAG_TEMPHUMI);
				rt_kprintf("KEY0 奇数次按下! ");
				led_on(0);
			}
			else	
			{
				rt_kprintf("KEY0 偶数次按下! ");
				led_off(0);
			}
		} 
	}
}

void key_cb1(void *args)
{
	static rt_uint8_t t1=1;
	
	if( rt_pin_read(KEY1) == PIN_LOW)
	{
		rt_thread_mdelay(20);//防抖处理
		if( rt_pin_read(KEY1) == PIN_LOW)
		{
			t1++;
			if(t1%2 == 0)
			{
				rt_event_send(led_event,EVENT_FLAG_PM25);				
				rt_kprintf("KEY1 奇数次按下! ");
								led_on(1);
			}
			else
			{
				rt_kprintf("KEY1 偶数次按下! ");
								led_off(1);
			}
		} 
	}
}

void key_cb2(void *args)
{
	static rt_uint8_t t2=1;
	
	if( rt_pin_read(KEY_UP) == PIN_HIGH)
	{
		rt_thread_mdelay(20);//防抖处理
		if( rt_pin_read(KEY_UP) == PIN_HIGH)
		{
			t2++;
			if(t2%2 == 0)
			{
				rt_event_send(led_event,EVENT_FLAG_MQ135);
				rt_kprintf("KEY2 奇数次按下! ");
								beep_on();
			}
			else
			{
				rt_kprintf("KEY2 偶数次按下! ");
								beep_off();
			}
		} 
	}
}```三、三个驱动读
只写一个温度湿度吧，其他类似
```void temp_thread_read()
{
	while(1)
	{		
			mylog("HUMI",humidity);
			mylog("TEMP",temperature);
		rt_thread_mdelay(1000);
	}
}```四、实验结果

![110,0](https://www.rt-thread.org/qa/forum.php?mod=image&aid=10952&size=300x300&key=2f620f735185d647&nocache=yes&type=fixnone)
![TIM截图20190912222425.png](/uploads/201909/12/222445mf3dr443lfv399lq.png)![1.png](/uploads/201909/12/223732xjpyfxcbcix8c88i.png)

![TIM截图20190912222110.png](https://oss-club.rt-thread.org/uploads/201909/12/222121xxqotzbmuoouboqb.png)