RT-Thread-15天入门-第9次-邮箱的使用RT-Thread问答社区

15天入门-第9次-邮箱的使用

发布于 2018-05-27 02:31:09 浏览：2349 订阅该版

本次课程主要讲邮箱(IPC 对象)的使用，包含：(
1、例说邮箱:任务间数据交换.没有说必须是单个邮件,一次可能有很多封.
发件人
收件人
内容     交换信息   
单个邮件大小的限制(4个字节)     邮箱总大小(可以先写默认的)128/4=32

2、例程源码解析及邮箱的相关操作
size  邮箱总大小
初始化/创建   发送      接收    脱离(静态)/删除(动态)
任务2:顺序执行
任务1:循环执行
 /* 初始化一个mailbox */
    
result = rt_mb_init(&mb,
"mbt",/* 名称是mbt */

&mb_pool[0],                /* 邮箱用到的内存池是mb_pool */
 128/4 = 32 封邮件
                       sizeof(mb_pool) / 4,        /* 邮箱中的邮件数目，因为一封邮件占4字节 */

RT_IPC_FLAG_FIFO);          /* 采用FIFO方式进行线程等待 */
 /* 发送mb_str1地址到邮箱中 */
           
 rt_mb_send(&mb, (rt_uint32_t)&mb_str1[0]);
/* 从邮箱中收取邮件 */

if (rt_mb_recv(&mb, (rt_uint32_t *)&str, RT_WAITING_FOREVER) == RT_EOK)
 /* 执行邮箱对象脱离 */
   
 rt_mb_detach(&mb);
3、邮箱的使用注意事项
不可以在中断中接收receive;
可以在中断中发送邮箱 wait 的不行.

作业:使用邮箱进行实际操作:
比如key 四个 和 四个 led 的配合
 对应键值 读取对应键值 亮对应的灯
 发送任务 接收任务
如果开四个任务,会报内存溢出的错误.
 ```/*
 * 程序清单：邮箱例程
 *
 * 这个程序会创建2个动态线程，一个静态的邮箱对象，其中一个线程往邮箱中发送邮件，
 * 一个线程往邮箱中收取邮件。
 */
#include <rtthread.h>
#include "stm32f1xx.h"
#include "stm32f1xx_hal.h"

/* 邮箱控制块 */
static struct rt_mailbox mb;
/* 用于放邮件的内存池 */
static char mb_pool[128];//32 封邮件

static char mb_str1[] = "I'm a mail!";
static char mb_str2[] = "this is another mail!";
static char mb_str3[] = "over";

/*ALIGN(RT_ALIGN_SIZE)
static char thread1_stack[1024];
static struct rt_thread thread1;

/* 线程1入口 
static void thread1_entry(void *parameter)
{
    char *str;

while (1)
 {
 rt_kprintf("thread1: try to recv a mail ");

/* 从邮箱中收取邮件 
 if (rt_mb_recv(&mb, (rt_uint32_t *)&str, RT_WAITING_FOREVER) == RT_EOK)
 {
 rt_kprintf("thread1: get a mail from mailbox, the content:%s ", str);
 if (str == mb_str3)
 break;

/* 延时10个OS Tick 
            rt_thread_delay(10);
        }
    }
    /* 执行邮箱对象脱离 
    rt_mb_detach(&mb);
}
*/
/*ALIGN(RT_ALIGN_SIZE)
static char thread2_stack[1024];
static struct rt_thread thread2;
/* 线程2入口 
static void thread2_entry(void *parameter)
{
    rt_uint8_t count;

count = 0;
 while (count < 10)
 {
 count ++;
 if (count & 0x1)
 {
 /* 发送mb_str1地址到邮箱中 
 rt_mb_send(&mb, (rt_uint32_t)&mb_str1[0]);
 }
 else
 {
 /* 发送mb_str2地址到邮箱中 
 rt_mb_send(&mb, (rt_uint32_t)&mb_str2[0]);
 }

/* 延时20个OS Tick 
        rt_thread_delay(20);
    }

/* 发送邮件告诉线程1，线程2已经运行结束 
    rt_mb_send(&mb, (rt_uint32_t)&mb_str3[0]);
}*/
ALIGN(RT_ALIGN_SIZE)
static char thread3_stack[1024];
static struct rt_thread thread3;

/* 线程3入口 */
static void thread3_entry(void *parameter)
{
    char *str;
	  GPIO_InitTypeDef  GPIO_InitStruct;
	 	/* Enable the BUTTON Clock */
  __HAL_RCC_GPIOB_CLK_ENABLE();

/* Configure Button pin as input */
    GPIO_InitStruct.Pin = GPIO_PIN_4 | GPIO_PIN_5;
    GPIO_InitStruct.Mode = GPIO_MODE_OUTPUT_PP;
    GPIO_InitStruct.Pull = GPIO_NOPULL;
    GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_HIGH;
    HAL_GPIO_Init(GPIOB, &GPIO_InitStruct);

while (1)
 {
 rt_kprintf("thread1: try to recv a mail ");

/* 从邮箱中收取邮件 */
 if (rt_mb_recv(&mb, (rt_uint32_t *)&str, RT_WAITING_FOREVER) == RT_EOK)
 {
 
					 rt_kprintf("thread1: get a mail from mailbox, the content:%s ", str);
					 if(str == mb_str1)
						{
							 HAL_GPIO_WritePin(GPIOB, GPIO_PIN_4, GPIO_PIN_RESET);
 HAL_GPIO_WritePin(GPIOB, GPIO_PIN_4, GPIO_PIN_RESET);
							 rt_kprintf("LED OFF");
						}
						if(str == mb_str2)
						{
							HAL_GPIO_WritePin(GPIOB, GPIO_PIN_4, GPIO_PIN_SET);
							rt_kprintf("LED_ON");
						}
 if (str == mb_str3)
 break;

/* 延时10个OS Tick */
            rt_thread_delay(10);
        }
    }
    /* 执行邮箱对象脱离 */
    rt_mb_detach(&mb);
}
ALIGN(RT_ALIGN_SIZE)
static char thread4_stack[1024];
static struct rt_thread thread4;
/* 线程4入口 */
static void thread4_entry(void *parameter)
{
    rt_uint8_t count;
    
    count = 0;
	GPIO_InitTypeDef GPIO_InitStruct;
	/* Enable the BUTTON Clock */
  __HAL_RCC_GPIOB_CLK_ENABLE();

/* Configure Button pin as input */
    GPIO_InitStruct.Pin = GPIO_PIN_2 | GPIO_PIN_3;
    GPIO_InitStruct.Mode = GPIO_MODE_INPUT;
    GPIO_InitStruct.Pull = GPIO_PULLDOWN;
    GPIO_InitStruct.Speed = GPIO_SPEED_FREQ_HIGH;
    HAL_GPIO_Init(GPIOB, &GPIO_InitStruct);
  
	
    while(1)
    {
			
          if(1==HAL_GPIO_ReadPin(GPIOB,GPIO_PIN_2))
					{
            /* 发送mb_str1地址到邮箱中 */
            rt_mb_send(&mb, (rt_uint32_t)&mb_str1[0]);
          }
					if(1== HAL_GPIO_ReadPin(GPIOB,GPIO_PIN_3))
					{
						            /* 发送mb_str2地址到邮箱中 */
            rt_mb_send(&mb, (rt_uint32_t)&mb_str2[0]);
					}
        
       /* 延时20个OS Tick */
        rt_thread_delay(20);
    }
}
int mailbox_sample_init()
{
    rt_err_t result;

/* 初始化一个mailbox */
 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;
 }

/*rt_thread_init(&thread1,
                   "thread1",
                   thread1_entry,
                   RT_NULL,
                   &thread1_stack[0],
                   sizeof(thread1_stack), 10, 5);
    rt_thread_startup(&thread1);*/
		 rt_thread_init(&thread3,
                   "thread3",
                   thread3_entry,
                   RT_NULL,
                   &thread3_stack[0],
                   sizeof(thread3_stack), 10, 5);
    rt_thread_startup(&thread3);

/* rt_thread_init(&thread2,
                   "thread2",
                   thread2_entry,
                   RT_NULL,
                   &thread2_stack[0],
                   sizeof(thread2_stack), 10, 5);
    rt_thread_startup(&thread2);*/
		 rt_thread_init(&thread4,
                   "thread4",
                   thread4_entry,
                   RT_NULL,
                   &thread4_stack[0],
                   sizeof(thread4_stack), 10, 5);
    rt_thread_startup(&thread4);
    return 0;
}
/* 如果设置了RT_SAMPLES_AUTORUN，则加入到初始化线程中自动运行 */
#ifdef RT_SAMPLES_AUTORUN
    INIT_APP_EXPORT(mailbox_sample_init);
#endif
/* 导出到 msh 命令列表中 */
MSH_CMD_EXPORT(mailbox_sample_init, mailbox sample);
```