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

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

发布于 2019-09-16 00:26:48 浏览：1544 订阅该版

* 本帖最后由 Zachary 于 2019-9-16 00:26 编辑 *

[align=center]**RT-Thread邮箱、事件的使用**
[align=center]

第三周的任务是将整个系统跑起来，各模块之间使用邮箱或者是事件来传递数据。1、邮箱的使用使用邮箱，实现每个传感器数据使用异步打印数据。最初写完这部分代码，测试时，发现了问题。本来应该是连续输出数据，但是，运行一段时间之后，系统不打印输出任何东西，但是命令仍然可以输入使用，由于接了屏幕，所以可以知道，每个传感器模块也都在运行，但就是停止打印输出了。经过检查发现，是线程中忘记调用rt_thread_delay()这个函数，导致该线程卡死。加上这条语句之后，恢复正常。下面是相关配置代码：```ALIGN(RT_ALIGN_SIZE)

static struct rt_mailbox mylog_mb;      /* 邮箱控制块(句柄) */

static rt_uint32_t mylog_mb_pool[512];  /* 用于放邮件的内存池 */

//=====================================================

static void mylog_entry(void *parameter)

{
    struct log_msg *mylogs;
    for(;;)
    {
        if(rt_mb_recv(&mylog_mb, (rt_ubase_t *)&mylogs, RT_WAITING_FOREVER) == RT_EOK)
        {
            if(rt_strcmp("MQ-135",mylogs->str) == 0)

{
 rt_kprintf("[%s] data is:%d.%02d ",mylogs->str, mylogs->datah, mylogs->datal);
 }

else if(rt_strcmp("DHT11",mylogs->str) == 0)
 {
 rt_kprintf("[%s] data temp:%d, humi:%d " ,mylogs->str, mylogs->datah, mylogs->datal);
 }

else if(rt_strcmp("PM2.5",mylogs->str) == 0)
 {
 rt_kprintf("[%s] : %d.%03d mg/m3 ", mylogs->str, mylogs->datah, mylogs->datah);
 }

else
 {
 //rt_kprintf("[%s] data : %d ",mylog->datah);
 }
 }
 else 
 {
 rt_kprintf("mylog_recv_error! ");
 }
 
 rt_thread_delay(500);//一定要加上。
 }
}

//======================================================
rt_err_t mylog(char* tag, uint32_t data1,uint32_t data2)

{

//发送数据结构体指针变量

struct log_msg *data2send;

data2send = (struct log_msg *)rt_malloc(sizeof(struct log_msg));

data2send->str = tag;

data2send->datah = data1;

data2send->datal = data2;

rt_mb_send(&mylog_mb,(rt_ubase_t)data2send);

return 0;

}```2、事件的使用事件的使用，我有些迷糊，事件产生了到底什么时候传递到接受端，要是多个线程都需要接收，那么哪个线程先使用。在接收代码rt_event_recv()中到底接收过来的到底是什么数据。初始化event```
int event_initial(void)
{
rt_err_t result;
 
 result = rt_event_init(&event, "event", RT_IPC_FLAG_FIFO);
 if (result != RT_EOK)
 {
 rt_kprintf("init event failed. ");
 return -1;
 }
 return 0;
}```LED线程接收

```static void led_entry(void *parameter)
{
 rt_uint32_t e;
 
 for(;;)
 {
 if(rt_event_recv(&event,KEY_UP_FLAG | KEY_UP_DOUBLE_CLICK,RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
 RT_WAITING_FOREVER,&e) == RT_EOK)
 {
 rt_kprintf("receive success ");
 }
 if(e & KEY_UP_FLAG)
 {
 led1_blink();
 }
 if(e & KEY_UP_DOUBLE_CLICK)
 {
 led2_blink();
 }
 else
 {
 }
 }
}```