RT-Thread-【第三期空气质量分析仪】-第3周作业RT-Thread问答社区

【第三期空气质量分析仪】-第3周作业

发布于 2019-10-29 20:25:52 浏览：846 订阅该版

这周任务目标：实现异步日志，空气质量分析仪的系统跑起来（熟悉邮箱，事件集的使用）

一、为了保护rt_kprintf()在被任务调用，不被其他任务抢占中断，而造成打印串码的情况，通过邮箱进行传递信息，使用mylog（）完成异步日志打印；

在工程项目新增mylog.c   mylog.h，在日志打印线程里，通过名称字符串区分开温度、湿度、PM2.5三个信息；

![1572347714(1).jpg](/uploads/201910/29/191624xxaszelyrfsesa4i.jpg)

```#include "mylog.h"

/* 异步日志结构体 */
struct mailbox_mesg
{
	char *tag;	//数据对象标识
	rt_uint32_t  data;	//接收数据的指针成员变量
};

static struct mailbox_mesg mbsg;

/* 邮箱控制块 */
static struct rt_mailbox mb;
/* 用于放邮件的内存池 */
static char mb_pool[128];
static void mylog_entry(void);
static void mylog_entry(void)
{
	struct mailbox_mesg *mb_msg;
	rt_uint32_t temp_humi; 
	while(1)
	{
		
		 /* 从邮箱中收取邮件 */
 if (rt_mb_recv(&mb, (rt_uint32_t *)&mb_msg, RT_WAITING_FOREVER) == RT_EOK)
 {
					
					if(strcmp(mb_msg->tag,"Temp") == 0)
					{
						
						rt_kprintf("<mytemp %d> ",(int)(mb_msg->data));
					}
					else if(strcmp(mb_msg->tag,"Humi") == 0)
					{
						
						rt_kprintf("<myhumi %d> ",mb_msg->data);
						
					}
					else 
					{
						
						rt_kprintf("<pm2.5 %dug/m3> ",(mb_msg->data));
					}
 
 
 }
		
	}
	
}

rt_int8_t mylog_init(void)
{
		rt_thread_t mylog_th;
		rt_err_t result;
		result = rt_mb_init(&mb,
 "mbt", /* 名称是 mbt */
 &mb_pool[0], /* 邮箱用到的内存池是 mb_pool */
 sizeof(mb_pool) / 4, /* 邮箱中的邮件数目，因为一封邮件占 4 字节 */
 RT_IPC_FLAG_FIFO); /* 采用 FIFO 方式进行线程等待 */
 if (result != RT_EOK)
 {
 rt_kprintf("init mailbox failed. ");
 return -1;
 }
	 mylog_th = rt_thread_create("mylog",mylog_entry,RT_NULL,1024, RT_THREAD_PRIORITY_MAX / 2,20);
	
		rt_thread_startup(mylog_th);
		return 0;
}

void mylog(char * tag, rt_uint32_t data)
{

mbsg.tag = tag;
	mbsg.data = (int)data;
	
	
	rt_mb_send(&mb,(rt_ubase_t)&mbsg);
}```

二、将空气质量分析仪整个系统跑起来
硬件外设（两个按键，两个LED灯，对应温湿度和PM2.5）

使用事件集将按键，指示灯等关联起来；
在指示灯中使用两个线程，一个负责解析事件标志和指示灯的常亮（运行）和常灭（停止），另一个线程负责led的闪烁（不在设定值的范围内）

线程
通过调用led_blink_note()发送事件标志，通过不同的标志实现灯的亮灭和闪烁，各线程使用mylog打印信息数据
```#include "led_alert.h"

#define EVENT_FLAG0 (1 << 0)
#define EVENT_FLAG1 (1 << 1)
#define EVENT_FLAG2 (1 << 2)
#define EVENT_FLAG3 (1 << 3)
#define EVENT_FLAG4 (1 << 4)
#define EVENT_FLAG5 (1 << 5)

#define EVENT_TEMP_HUMI_ON		EVENT_FLAG0
#define EVENT_TEMP_HUMI_OFF		EVENT_FLAG1
#define EVENT_TEMP_HUMI_ALERT	EVENT_FLAG2
#define EVENT_PM25_ON					EVENT_FLAG3
#define EVENT_PM25_OFF				EVENT_FLAG4
#define EVENT_PM25_ALERT			EVENT_FLAG5

#define TEMP_HUMI_ON 					EVENT_FLAG0
#define TEMP_HUMI_OFF 				EVENT_FLAG1
#define TEMP_HUMI_ALERT 			EVENT_FLAG2
#define PM25_ON								EVENT_FLAG3
#define PM25_OFF							EVENT_FLAG4
#define PM25_ALERT						EVENT_FLAG5

char led_blink_flag1 = 0;
char led_blink_flag2 = 0;
static struct rt_event event;
static void event_entry(void);
static void led_entry(void);
static void event_entry(void)
{
	rt_uint32_t event_msg;
	while(1)
	{
		if(rt_event_recv(&event,(EVENT_TEMP_HUMI_ON|EVENT_TEMP_HUMI_OFF|EVENT_TEMP_HUMI_ALERT|EVENT_PM25_ON|EVENT_PM25_OFF|EVENT_PM25_ALERT),RT_EVENT_FLAG_OR|RT_EVENT_FLAG_CLEAR,RT_WAITING_FOREVER,&event_msg) == RT_EOK)
		{

if(event_msg & EVENT_TEMP_HUMI_ON)
				{
					led_blink_flag1 = 0;
					led_on(LED_0);
					
				}
				if(event_msg & EVENT_TEMP_HUMI_OFF)
				{
					led_blink_flag1 = 0;
					led_off(LED_0);
				}
				if(event_msg & EVENT_TEMP_HUMI_ALERT)
				{
					
					led_blink_flag1 = 1;
				}
				if(event_msg & EVENT_PM25_ON)
				{
					led_blink_flag2 = 0;
					led_on(LED_1);
				}
				if(event_msg & EVENT_PM25_OFF)
				{
					led_blink_flag2 = 0;
					led_off(LED_1);
					
				}
				if(event_msg & EVENT_PM25_ALERT)
				{
					
					led_blink_flag2 = 1;
				}
			
		}
	}
	
}

static void led_entry(void)
{
	char status;
	while(1)
	{
		
		if(led_blink_flag1)
		{
				status = rt_pin_read(LED0);
				rt_pin_write(LED0,!status);
			
		}

if(led_blink_flag2)
		{
				status = rt_pin_read(LED1);
				rt_pin_write(LED1,!status);
			
		}
			
		rt_thread_delay(300);
	}
	
	
}

void led_init()
{
		rt_err_t result;
		rt_thread_t event_th;
		rt_thread_t led_th;
		result = rt_event_init(&event, "event", RT_IPC_FLAG_FIFO);
		if (result != RT_EOK)
 {
 rt_kprintf("init event failed. ");
 return ;
 }
	
	 rt_pin_mode(LED0, PIN_MODE_OUTPUT);
	 rt_pin_mode(LED1, PIN_MODE_OUTPUT);

rt_pin_write(LED0, PIN_HIGH);
	  rt_pin_write(LED1, PIN_HIGH);
	
		event_th = rt_thread_create("event_th",event_entry,RT_NULL,1024, RT_THREAD_PRIORITY_MAX / 2,20);
		rt_thread_startup(event_th);
		led_th = rt_thread_create("led_th",led_entry,RT_NULL,1024, RT_THREAD_PRIORITY_MAX / 2,20);
		rt_thread_startup(led_th);
		
}

void led_blink_note(char opt)
{
	switch(opt)
	{
		case TEMP_HUMI_ON:
			
			rt_event_send(&event, EVENT_TEMP_HUMI_ON);
		break;
		
		case TEMP_HUMI_OFF:
			rt_event_send(&event, EVENT_TEMP_HUMI_OFF);
		break;
		
		case TEMP_HUMI_ALERT:
			rt_event_send(&event, EVENT_TEMP_HUMI_ALERT);
		break;
		
		case PM25_ON:
			rt_event_send(&event, EVENT_PM25_ON);
		break;
		
		case PM25_OFF:
			rt_event_send(&event, EVENT_PM25_OFF);
		break;
		
		case PM25_ALERT:
			rt_event_send(&event, EVENT_PM25_ALERT);
		break;

}
	
	
}

void led_on(char sw)
{
	
	switch(sw)
	{
		case LED_0:
			rt_pin_write(LED0, PIN_LOW);
		break;
		
		case LED_1:
			rt_pin_write(LED1, PIN_LOW);
		break;
		
	}
}

void led_off(char sw)
{
	switch(sw)
	{
		case LED_0:
			rt_pin_write(LED0, PIN_HIGH);
		break;
		
		case LED_1:
			rt_pin_write(LED1, PIN_HIGH);
		break;
		
	}
}

```

![5d575304e8ff554e2fbc42ce1c34e91.png](/uploads/201910/29/202454uha1sf8lzulu588l.png)