17.6.7 使用注意事项

  1. 用 xQueueSend()、 xQueueSendFromISR()、 xQueueReceive()等这些函数之前应先创建需消息队列,并根据队列句柄进行操作。
  2. 队列读取采用的是先进先出(FIFO)模式,会先读取先存储在队列中的数据。当然也 FreeRTOS 也支持后进先出(LIFO)模式,那么读取的时候就会读取到后进队列的数据。
  3. 在获取队列中的消息时候,我们必须要定义一个存储读取数据的地方,并且该数据区域大小不小于消息大小,否则,很可能引发地址非法的错误。
  4. 无论是发送或者是接收消息都是以拷贝的方式进行, 如果消息过于庞大,可以将消息的地址作为消息进行发送、接收。
  5. 队列是具有自己独立权限的内核对象,并不属于任何任务。所有任务都可以向同一队列写入和读出。一个队列由多任务或中断写入是经常的事,但由多个任务读出倒是用的比较少。

17.6.8 队列实验

在 FreeRTOS 中创建了两个任务,一个是发送消息任务,一个是获取消息任务,两个任务独立运行,发送消息任务是通过检测按键的按下情况来发送消息,假如发送消息不成功,就把返回的错误情代码在串口打印出来,另一个任务是获取消息任务,在消息队列没有消息之前一直等待消息,一旦获取到消息就把消息打印在串口调试助手里。

  1. /* FreeRTOS头文件 */
  2. #include "FreeRTOS.h"
  3. #include "task.h"
  4. #include "queue.h"
  5. /* 开发板硬件bsp头文件 */
  6. #include "bsp_led.h"
  7. #include "bsp_usart.h"
  8. #include "bsp_key.h"
  9. /**************************** 任务句柄 ********************************/
  10. /*
  11. * 任务句柄是一个指针,用于指向一个任务,当任务创建好之后,它就具有了一个任务句柄
  12. * 以后我们要想操作这个任务都需要通过这个任务句柄,如果是自身的任务操作自己,那么
  13. * 这个句柄可以为NULL。
  14. */
  15. static TaskHandle_t AppTaskCreate_Handle = NULL;/* 创建任务句柄 */
  16. static TaskHandle_t Receive_Task_Handle = NULL;/* LED任务句柄 */
  17. static TaskHandle_t Send_Task_Handle = NULL;/* KEY任务句柄 */
  18. /********************************** 内核对象句柄 *********************************/
  19. /*
  20. * 信号量,消息队列,事件标志组,软件定时器这些都属于内核的对象,要想使用这些内核
  21. * 对象,必须先创建,创建成功之后会返回一个相应的句柄。实际上就是一个指针,后续我
  22. * 们就可以通过这个句柄操作这些内核对象。
  23. *
  24. * 内核对象说白了就是一种全局的数据结构,通过这些数据结构我们可以实现任务间的通信,
  25. * 任务间的事件同步等各种功能。至于这些功能的实现我们是通过调用这些内核对象的函数
  26. * 来完成的
  27. *
  28. */
  29. QueueHandle_t Test_Queue =NULL;
  30. /******************************* 全局变量声明 ************************************/
  31. /*
  32. * 当我们在写应用程序的时候,可能需要用到一些全局变量。
  33. */
  34. /******************************* 宏定义 ************************************/
  35. /*
  36. * 当我们在写应用程序的时候,可能需要用到一些宏定义。
  37. */
  38. #define QUEUE_LEN 4 /* 队列的长度,最大可包含多少个消息 */
  39. #define QUEUE_SIZE 4 /* 队列中每个消息大小(字节) */
  40. /*
  41. *************************************************************************
  42. * 函数声明
  43. *************************************************************************
  44. */
  45. static void AppTaskCreate(void);/* 用于创建任务 */
  46. static void Receive_Task(void* pvParameters);/* Receive_Task任务实现 */
  47. static void Send_Task(void* pvParameters);/* Send_Task任务实现 */
  48. static void BSP_Init(void);/* 用于初始化板载相关资源 */
  49. /*****************************************************************
  50. * @brief 主函数
  51. * @param 无
  52. * @retval 无
  53. * @note 第一步:开发板硬件初始化
  54. 第二步:创建APP应用任务
  55. 第三步:启动FreeRTOS,开始多任务调度
  56. ****************************************************************/
  57. int main(void)
  58. {
  59. BaseType_t xReturn = pdPASS;/* 定义一个创建信息返回值,默认为pdPASS */
  60. /* 开发板硬件初始化 */
  61. BSP_Init();
  62. printf("这是一个[野火]-STM32全系列开发板-FreeRTOS消息队列实验!\n");
  63. printf("按下KEY1或者KEY2发送队列消息\n");
  64. printf("Receive任务接收到消息在串口回显\n\n");
  65. /* 创建AppTaskCreate任务 */
  66. xReturn = xTaskCreate((TaskFunction_t )AppTaskCreate, /* 任务入口函数 */
  67. (const char* )"AppTaskCreate",/* 任务名字 */
  68. (uint16_t )512, /* 任务栈大小 */
  69. (void* )NULL,/* 任务入口函数参数 */
  70. (UBaseType_t )1, /* 任务的优先级 */
  71. (TaskHandle_t* )&AppTaskCreate_Handle);/* 任务控制块指针 */
  72. /* 启动任务调度 */
  73. if(pdPASS == xReturn)
  74. vTaskStartScheduler(); /* 启动任务,开启调度 */
  75. else
  76. return -1;
  77. while(1); /* 正常不会执行到这里 */
  78. }
  79. /***********************************************************************
  80. * @ 函数名 : AppTaskCreate
  81. * @ 功能说明: 为了方便管理,所有的任务创建函数都放在这个函数里面
  82. * @ 参数 : 无
  83. * @ 返回值 : 无
  84. **********************************************************************/
  85. static void AppTaskCreate(void)
  86. {
  87. BaseType_t xReturn = pdPASS;/* 定义一个创建信息返回值,默认为pdPASS */
  88. taskENTER_CRITICAL(); //进入临界区
  89. /* 创建Test_Queue */
  90. Test_Queue = xQueueCreate((UBaseType_t ) QUEUE_LEN,/* 消息队列的长度 */
  91. (UBaseType_t ) QUEUE_SIZE);/* 消息的大小 */
  92. if(NULL != Test_Queue)
  93. printf("创建Test_Queue消息队列成功!\r\n");
  94. /* 创建Receive_Task任务 */
  95. xReturn = xTaskCreate((TaskFunction_t )Receive_Task, /* 任务入口函数 */
  96. (const char* )"Receive_Task",/* 任务名字 */
  97. (uint16_t )512, /* 任务栈大小 */
  98. (void* )NULL, /* 任务入口函数参数 */
  99. (UBaseType_t )2, /* 任务的优先级 */
  100. (TaskHandle_t* )&Receive_Task_Handle);/* 任务控制块指针 */
  101. if(pdPASS == xReturn)
  102. printf("创建Receive_Task任务成功!\r\n");
  103. /* 创建Send_Task任务 */
  104. xReturn = xTaskCreate((TaskFunction_t )Send_Task, /* 任务入口函数 */
  105. (const char* )"Send_Task",/* 任务名字 */
  106. (uint16_t )512, /* 任务栈大小 */
  107. (void* )NULL,/* 任务入口函数参数 */
  108. (UBaseType_t )3, /* 任务的优先级 */
  109. (TaskHandle_t* )&Send_Task_Handle);/* 任务控制块指针 */
  110. if(pdPASS == xReturn)
  111. printf("创建Send_Task任务成功!\n\n");
  112. vTaskDelete(AppTaskCreate_Handle); //删除AppTaskCreate任务
  113. taskEXIT_CRITICAL(); //退出临界区
  114. }
  115. /**********************************************************************
  116. * @ 函数名 : Receive_Task
  117. * @ 功能说明: Receive_Task任务主体
  118. * @ 参数 :
  119. * @ 返回值 : 无
  120. ********************************************************************/
  121. static void Receive_Task(void* parameter)
  122. {
  123. BaseType_t xReturn = pdTRUE;/* 定义一个创建信息返回值,默认为pdTRUE */
  124. uint32_t r_queue; /* 定义一个接收消息的变量 */
  125. while (1)
  126. {
  127. xReturn = xQueueReceive( Test_Queue, /* 消息队列的句柄 */
  128. &r_queue, /* 发送的消息内容 */
  129. portMAX_DELAY); /* 等待时间 一直等 */
  130. if(pdTRUE == xReturn)
  131. printf("本次接收到的数据是%d\n\n",r_queue);
  132. else
  133. printf("数据接收出错,错误代码0x%lx\n",xReturn);
  134. }
  135. }
  136. /**********************************************************************
  137. * @ 函数名 : Send_Task
  138. * @ 功能说明: Send_Task任务主体
  139. * @ 参数 :
  140. * @ 返回值 : 无
  141. ********************************************************************/
  142. static void Send_Task(void* parameter)
  143. {
  144. BaseType_t xReturn = pdPASS;/* 定义一个创建信息返回值,默认为pdPASS */
  145. uint32_t send_data1 = 1;
  146. uint32_t send_data2 = 2;
  147. while (1)
  148. {
  149. if( Key_Scan(KEY1_GPIO_PORT,KEY1_GPIO_PIN) == KEY_ON )
  150. {/* K1 被按下 */
  151. printf("发送消息send_data1!\n");
  152. xReturn = xQueueSend( Test_Queue, /* 消息队列的句柄 */
  153. &send_data1,/* 发送的消息内容 */
  154. 0 ); /* 等待时间 0 */
  155. if(pdPASS == xReturn)
  156. printf("消息send_data1发送成功!\n\n");
  157. }
  158. if( Key_Scan(KEY2_GPIO_PORT,KEY2_GPIO_PIN) == KEY_ON )
  159. {/* K2 被按下 */
  160. printf("发送消息send_data2!\n");
  161. xReturn = xQueueSend( Test_Queue, /* 消息队列的句柄 */
  162. &send_data2,/* 发送的消息内容 */
  163. 0 ); /* 等待时间 0 */
  164. if(pdPASS == xReturn)
  165. printf("消息send_data2发送成功!\n\n");
  166. }
  167. vTaskDelay(20);/* 延时20个tick */
  168. }
  169. }
  170. /***********************************************************************
  171. * @ 函数名 : BSP_Init
  172. * @ 功能说明: 板级外设初始化,所有板子上的初始化均可放在这个函数里面
  173. * @ 参数 :
  174. * @ 返回值 : 无
  175. *********************************************************************/
  176. static void BSP_Init(void)
  177. {
  178. /*
  179. * STM32中断优先级分组为4,即4bit都用来表示抢占优先级,范围为:0~15
  180. * 优先级分组只需要分组一次即可,以后如果有其他的任务需要用到中断,
  181. * 都统一用这个优先级分组,千万不要再分组,切忌。
  182. */
  183. NVIC_PriorityGroupConfig( NVIC_PriorityGroup_4 );
  184. /* LED 初始化 */
  185. LED_GPIO_Config();
  186. /* 串口初始化 */
  187. USART_Config();
  188. /* 按键初始化 */
  189. Key_GPIO_Config();
  190. }
  191. /********************************END OF FILE****************************/

17.6.9 实验现象