Kernel

第15天：内存池[15天rt-thread入门学习]

发布于 2018-06-04 22:04:53 浏览：2136 订阅该版

* 本帖最后由 wolfgang2018 于 2018-6-4 22:18 编辑 *

15、将本节实例中内存池改为动态申请的方式
我所选择的系统嘀嗒与课程选用的系统嘀嗒有些不一样，实验出来的结果有些不一样:

![01.jpg](/uploads/201806/04/215223ol9l68e68lptzl9l.jpg)
线程1优先级高，第一阶段是在获取内存池中的内存；

![02.jpg](/uploads/201806/04/215228wjr6mfalf0m8yyj0.jpg)
在0~47个内存池申请满后，再使用“rt_mp_alloc”申请时，进入阻塞状态，线程2开始运行；

![03.jpg](/uploads/201806/04/215243xoi6szi22rmbeddd.jpg)
说明如图

![04.jpg](/uploads/201806/04/215251ryei7dhif7hdy2ve.jpg)
后边依次类推，线程1的2、3次运行都随线程2的释放空间后才能得以运行

![05.jpg](/uploads/201806/04/215257knrs3p61dii3szgs.jpg)
后边依次类推，线程1的4、5次运行都随线程2的释放空间后才能得以运行

![06.jpg](/uploads/201806/04/215301nqmqbbbcnn6b6m6q.jpg)
后边依次类推，线程1的6、7次运行都随线程2的释放空间后才能得以运行

![07.jpg](/uploads/201806/04/215306lqn4qq5gizfz25bn.jpg)
后边依次类推，线程1的8、9次运行都随线程2的释放空间后才能得以运行。
在线程2第1次释放到46、47后，所有48块内存都释放完后，线程2完成第一轮释放。

![08.jpg](/uploads/201806/04/215311bbvdgavyavkafqcg.jpg)
线程1后在获取完第10次（10次0~47循环判断是否为空指针）内存后，退出循环，剩下的只有线程2在运行。

![10.jpg](/uploads/201806/04/215331ezmfaomn5g5iiibc.jpg)
![11.jpg](/uploads/201806/04/215332yu44r3uu44ujp3zq.jpg)
线程2完成10次释放后，结束了线程的运行。

相关程序代码：
```

//定义48块内存每块内存大小80
#define UPTRLENGTH 48
#define USIZE 80
//内存池内内存块定义为数组
static rt_uint8_t *uptr[UPTRLENGTH];
//内存池地址定义
static struct rt_mempool *user_mp=RT_NULL;
//用户线程定义
static rt_thread_t utid1 = RT_NULL;
static rt_thread_t utid2 = RT_NULL;

//线程1的程序结构，增加了几处内容提示；
/***************************************/
static void user_thread1_entry(void *parameter){
 rt_uint8_t i, count = 0;
 rt_uint8_t *block;
 while(1) {
 /* 申请内存块 */
	rt_kprintf("=============Thread1 Start: %d ",count);
	for (i = 0; i < UPTRLENGTH; i++){
 if (ptr* == RT_NULL){
 ptr* = rt_mp_alloc(user_mp, RT_WAITING_FOREVER);
 rt_kprintf("Thread1: allocate No.%d ", i);
 }
 }
	 rt_kprintf("============Thread1: ALL Pool Used!!! %d ", i);
 
 /* 继续申请一个内存块，因为已经没有内存块，线程应该被挂起 */
 block = rt_mp_alloc(user_mp, RT_WAITING_FOREVER);
 rt_kprintf("Thread1: Allocate One block mem! ");
	
 /* 释放这个内存块 */
 rt_mp_free(block);
 block = RT_NULL;
 rt_kprintf("Thread1: Free One block mem! ");
 
 /* 休眠10个OS Tick */
 rt_thread_delay(10);

/* 循环10次后，退出线程1 */
 if (count++ >= 10) {
 break;
	 }
 }
 rt_kprintf("Thread1: End of Thread1! %d ",count);
}

//线程2的程序结构，增加了几处提示：
static void user_thread2_entry(void *parameter){
 rt_uint8_t i, count = 0;
 while (1){
 rt_kprintf("===============Thread2 Start: %d ",count);
 rt_kprintf("Thread2: Begin Try to Release Block! ");
 for (i = 0 ; i < UPTRLENGTH; i ++) {
 /* 释放所有分配成功的内存块 */
 if (ptr* != RT_NULL){
 rt_kprintf("Thread2 Release Block %d ", i);
 rt_mp_free(ptr*);
 ptr* = RT_NULL;
 }
 }
 rt_kprintf("==============Thread2: Free ALL Block! %d ",i);
	
 /* 休眠10个OS Tick */
 rt_thread_delay(10);

/* 循环10次后，退出线程2 */
 if (count++ >= 10) {
 break;
 }
 }
 rt_kprintf("Thread2: End of Thread2!!! %d ",count);
}

//作业内存池主函数
int user_mempool_sample_init(){
 rt_uint8_t i;
 for (i=0;i<UPTRLENGTH;i++){
 *uptr*=RT_NULL;
 }
 /* 初始化内存池对象 */
 user_mp=rt_mp_create("ump1", UPTRLENGTH, USIZE);

/* 创建线程1 */
  utid1 = rt_thread_create("ut1", user_thread1_entry, RT_NULL,THREAD_STACK_SIZE,THREAD_PRIORITY-1,THREAD_TIMESLICE);
  if (utid1 != RT_NULL) {
      rt_thread_startup(utid1);
  };
  /* 创建线程2 */
  utid2 = rt_thread_create("ut2",user_thread2_entry, RT_NULL,THREAD_STACK_SIZE,THREAD_PRIORITY,THREAD_TIMESLICE);
  if (utid2 != RT_NULL) {
      rt_thread_startup(utid2);	
  }
  return 0;
}

//注册函数为命令行模式
/* 如果设置了RT_SAMPLES_AUTORUN，则加入到初始化线程中自动运行 */
#if defined (RT_SAMPLES_AUTORUN) && defined(RT_USING_COMPONENTS_INIT)
    INIT_APP_EXPORT(mempool_sample_init);
    INIT_APP_EXPORT(user_mempool_sample_init);
#endif
/* 导出到 msh 命令列表中 */
MSH_CMD_EXPORT(mempool_sample_init, mempool sample);
MSH_CMD_EXPORT(user_mempool_sample_init, mempool sample);

```
[https://www.rt-thread.org/qa/thread-7210-1-1.html](第01天：初识RT-Thread [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7211-1-1.html](第02天：系统启动代码和用户入口 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7261-1-1.html](第03天：线程的创建与删除 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7262-1-1.html](第04天：空闲任务及其钩子函数 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7263-1-1.html](第05天：中断和临界区保护 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7264-1-1.html](第06天：堆的初始化和使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7265-1-1.html](第07天：信号量的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7266-1-1.html](第08天：互斥量的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7267-1-1.html](第09天：邮箱的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7268-1-1.html](第10天：消息队列的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7271-1-1.html](第11天：事件的使用 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7272-1-1.html](第12天：生产者-消费者问题 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7273-1-1.html](第13天：生产者-消费者问题 [15天rt-thread入门学习])
[https://www.rt-thread.org/qa/thread-7274-1-1.html](第14天：软件定时器 [15天rt-thread入门学习])