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

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

发布于 2019-11-01 23:24:12 浏览：1178 订阅该版

异步日志mylog
线程中将传感器的数据发送到邮箱之中，再通过一个线程将这些数据打印出来。
这个邮箱相当于一个缓存区，将这些数据全部都接收下，等待空闲时将数据打印出来。
具体代码：
```#include <rtthread.h>
#include <rtdevice.h>
#include "mylog.h"

#define MYLOG_THREAD_STACK_SIZE	1000	
#define MYLOG_PRIORITY			25
static rt_thread_t mylog_thread = RT_NULL;

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

static struct rt_mailbox mb;	//邮箱控制块
static char mb_pool[512];

static void mylog_entry(void * parameter)
{
	struct msg *msg_ptr;
	
	while(1)
	{
		if(rt_mb_recv(&mb,(rt_ubase_t *)&msg_ptr,RT_WAITING_FOREVER) == RT_EOK)
		{
			rt_kprintf("[%s] data is : %d ",msg_ptr->tag,msg_ptr->dat);		//接收邮件
			
			rt_free(msg_ptr);
		}
	}
}

//异步日志初始化
void mylog_init(void)
{
	rt_err_t result;
	//创建线程
	mylog_thread = rt_thread_create("mylog",			
									mylog_entry,
									RT_NULL,
									MYLOG_THREAD_STACK_SIZE,
									MYLOG_PRIORITY,
									40);
	
	if(mylog_thread != RT_NULL)
	{
		//启动线程
		rt_thread_startup(mylog_thread);
	}
	//创建邮箱
	result = rt_mb_init(&mb,					//静态邮箱
						"mbt",
						&mb_pool[0],
						sizeof(mb_pool)/4,
						RT_IPC_FLAG_FIFO);
	if(result != RT_EOK)
	{
		rt_kprintf("init mailbox failed. ");
			
		return;
	}
	
	rt_kprintf("init mylog succeed. ");
}

//中断中不能调用rt_malloc，因此在中断中不能够使用
void mylog(char* TAG, rt_uint32_t data)
{
	static struct msg* mb_data_send;
	mb_data_send = (struct msg*)rt_malloc(sizeof(struct msg));		
	
	mb_data_send->tag = TAG;
	mb_data_send->dat = data;
	
	rt_mb_send(&mb,(rt_ubase_t)mb_data_send);
	
}```

在调试的过程中出现过“Function [rt_malloc] shall not be used in ISR”错误，在网上查找之后得到是中断中使用了rt_malloc函数导致的。于是在中断中使用的mylog函数屏蔽之后，没有在出现报错。
现象：
![mmexport1572621295089.png](/uploads/201911/01/231556fl8ovio7loiku8zl.png)

想着如何解决这个问题，参考他人写的mylog函数，有些没有使用rt_malloc函数申请地址，当时感觉这样会造成指针隐患的。尝试着不对申明的（static struct msg* mb_data_send;）mb_data_send初始化，结果出现问题了。
现象：
![mmexport1572621299962.png](/uploads/201911/01/231647ljj660ochv0rftot.png)

指针最好是初始化，不然可能会造成意想不到的后果。
对于上面的问题，可以转化为如何在中断中使用邮箱发送邮件。在文档中心对邮件的使用范围中有中断，那么中断中使用一定是可以的。网上浏览下别人使用经验再解决这个问题。
系统跑起来
按照系统框架图编写程序
主要程序如下：
led相关
```void led_entry(void *param)
{
	while(1)
	{
		if(rt_event_recv(&alarm_event,EVENT_LED0_BLINK,
					RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
					100,RT_NULL) == RT_EOK )
		{
				 led_blink(1);
		}
		if(rt_event_recv(&alarm_event,LED0_ON,
					RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
					100,RT_NULL) == RT_EOK )
		{
				 led_on(1);
		}
		if(rt_event_recv(&alarm_event,LED0_OFF,
		RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
		100,RT_NULL) == RT_EOK )
		{
				 led_off(1);
		}
		
		
		if(rt_event_recv(&alarm_event,EVENT_LED1_BLINK,
					RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
					100,RT_NULL) == RT_EOK )
		{
				 led_blink(2);
		}
		if(rt_event_recv(&alarm_event,LED1_ON,
					RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
					100,RT_NULL) == RT_EOK )
		{
				 led_on(2);
		}
		if(rt_event_recv(&alarm_event,LED1_OFF,
		RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
		100,RT_NULL) == RT_EOK )
		{
				 led_off(2);
		}
		rt_thread_mdelay(100);
	}
}

rt_err_t led_init(void)
{
	rt_err_t result;
	rt_thread_t led_tid; 
	//初始化事件	
	result = rt_event_init(&alarm_event, //事件集对象句柄
				"event", //事件集名称
				RT_IPC_FLAG_FIFO);								//先进先出模式 
	if(result != RT_EOK)
	{
		rt_kprintf("Init event failed! ");
	}
	//设置LED模式
	rt_pin_mode(LED0_PIN,PIN_MODE_OUTPUT);		//LED0
	rt_pin_mode(LED1_PIN,PIN_MODE_OUTPUT);		//LED1
	//初始化LED
	rt_pin_write(LED0_PIN, PIN_LOW);
	rt_pin_write(LED1_PIN, PIN_LOW);
	//创建报警线程
	led_tid = rt_thread_create("led", //线程名称
				led_entry, 						//线程入口函数
				RT_NULL, 		//线程入口函数参数
				1024, //线程栈大小
				26, //线程优先级
				10); //线程时间片大小
	if(led_tid == RT_NULL)
	{
		rt_kprintf("创建LED接收事件集线程失败 ");
		return -RT_ERROR;
	}
	rt_kprintf("创建LED接收事件集线程成功 ");
	//启动报警线程
	if(rt_thread_startup(led_tid) != RT_EOK)	//启动LED接收事件集线程如果失败
	{
		rt_thread_delete(led_tid); //删除LED接收事件集线程 
		rt_kprintf("启动LED接收事件集线程失败 ");
		return -RT_ERROR;
	}
	rt_kprintf("启动LED接收事件集线程成功 ");
	
	rt_kprintf("LED Init! ");
	return RT_EOK;
}

void led_on(rt_uint8_t led_number)
{
	if(led_number == 1)
	{
		led0_on();
	}
	if(led_number == 2)
	{
		led1_on();
	}
}

void led_off(rt_uint8_t led_number)
{
	if(led_number == 1)
	{
		led0_off();
	}
	if(led_number == 2)
	{
		led1_off();
	}
}

void led_blink(rt_uint8_t led_number)
{
	if(led_number == 1)
	{
		led0_blink();
	}
	if(led_number == 2)
	{
		led1_blink();
	}
}

void led0_on(void)
{

rt_pin_write(LED0_PIN, PIN_HIGH);
	rt_kprintf("turn on led0! ");

}

void led1_on(void)
{
	rt_pin_write(LED1_PIN, PIN_HIGH);
	rt_kprintf("turn on led1! ");

}

void led0_off(void )
{
	rt_pin_write(LED0_PIN, PIN_LOW);
	rt_kprintf("turn off led0! ");	
}

void led1_off(void )
{
	 rt_pin_write(LED1_PIN, PIN_LOW);
	 rt_kprintf("turn off led1! ");	 
}

void led0_blink(void )
{
	rt_pin_write(LED0_PIN, PIN_HIGH);
	rt_thread_mdelay(200);
	rt_pin_write(LED0_PIN, PIN_LOW);
	rt_thread_mdelay(200);
	rt_pin_write(LED0_PIN, PIN_HIGH);
	rt_thread_mdelay(200);
	rt_pin_write(LED0_PIN, PIN_LOW);
	rt_thread_mdelay(200);
	rt_kprintf("led0 blink! ");
}

void led1_blink(void)
{
	rt_pin_write(LED1_PIN, PIN_HIGH);
	rt_thread_mdelay(200);
	rt_pin_write(LED1_PIN, PIN_LOW);
	rt_thread_mdelay(200);
	rt_pin_write(LED1_PIN, PIN_HIGH);
	rt_thread_mdelay(200);
	rt_pin_write(LED1_PIN, PIN_LOW);
	rt_thread_mdelay(200);
	rt_kprintf("led1 blink! ");
}
```传感器相关（PM2.5传感器和这个修改类似）
```#define TEMP_HUMI_THREAD_STACK_SIZE	1000	
#define TEMP_HUMI_PRIORITY			4

static rt_thread_t temp_huim_thread = RT_NULL;

//线程入口
void temp_humi_entry(void * paramter)
{
	rt_uint8_t dh_temp = 0;
	rt_uint8_t dh_humi = 0;
	while(1)
	{
		if(TH_State == KEY_TURN_ON)
		{
			dh_temp = dht11_read_temp();
			dh_humi = dht11_read_humi();
			rt_thread_mdelay(1000);
			
			if(dh_temp < 45)		
			{
				 rt_event_send(&alarm_event, EVENT_LED0_BLINK);
			}
			else
			{
				 rt_event_send(&alarm_event, LED0_ON);			//	温度超过45°报警
			}
			
			if(dh_humi < 50)
			{
				 rt_event_send(&alarm_event, EVENT_LED0_BLINK);
			}
			else
			{
				 rt_event_send(&alarm_event, LED0_ON);			//	湿度低于 50 报警
			}
		}
		 else if(TH_State == KEY_TURN_OFF)
		{
 rt_event_send(&alarm_event, LED0_OFF);
 }
		
		
	}
	
}

//创建温湿度传感器线程
void temp_humi_init(void)
{
	dht11_hw_init();
	//创建动态线程
	temp_huim_thread = rt_thread_create("temp_humi",temp_humi_entry,RT_NULL,
										RT_MAIN_THREAD_STACK_SIZE,RT_MAIN_THREAD_PRIORITY,40);
	if(temp_huim_thread != RT_NULL)
	{
		//启动线程
		rt_thread_startup(temp_huim_thread);
		rt_kprintf("创建创建温湿度线程成功 ");
	}
}
```实现现象：
![mmexport1572621302816.png](/uploads/201911/01/232118eyydcdjc22sosp09.png)