zoukankan      html  css  js  c++  java

  • 【FreeRTOS学习04】小白都能懂的 Queue Management 消息队列使用详解

    消息队列作为任务间同步扮演着必不可少的角色；

    相关文章

    【FreeRTOS实战汇总】小白博主的RTOS学习实战快速进阶之路（持续更新）

    文章目录

    1 前言

    任务之间的同步（同步就是任务之间做数据交互，或为两个任务之间的通讯），任务和中断之间的同步都可以依靠消息队列，从而实现异步处理，FreeRTOS的队列采用FIFO（先进先出）缓冲区，具体如下图所示；


    在这里插入图片描述

    2 xQUEUE

    FreeRTOS消息队列的实现主要是queue.c，需要包含头文件queue.h，下面先看一下queue.c中的数据类型xQUEUE，源码如下所示；

    typedef struct QueueDefinition
{
	int8_t *pcHead;					/*< Points to the beginning of the queue storage area. */
	int8_t *pcTail;					/*< Points to the byte at the end of the queue storage area.  Once more byte is allocated than necessary to store the queue items, this is used as a marker. */
	int8_t *pcWriteTo;				/*< Points to the free next place in the storage area. */

	union							/* Use of a union is an exception to the coding standard to ensure two mutually exclusive structure members don't appear simultaneously (wasting RAM). */
	{
		int8_t *pcReadFrom;			/*< Points to the last place that a queued item was read from when the structure is used as a queue. */
		UBaseType_t uxRecursiveCallCount;/*< Maintains a count of the number of times a recursive mutex has been recursively 'taken' when the structure is used as a mutex. */
	} u;

	List_t xTasksWaitingToSend;		/*< List of tasks that are blocked waiting to post onto this queue.  Stored in priority order. */
	List_t xTasksWaitingToReceive;	/*< List of tasks that are blocked waiting to read from this queue.  Stored in priority order. */

	volatile UBaseType_t uxMessagesWaiting;/*< The number of items currently in the queue. */
	UBaseType_t uxLength;			/*< The length of the queue defined as the number of items it will hold, not the number of bytes. */
	UBaseType_t uxItemSize;			/*< The size of each items that the queue will hold. */

	volatile int8_t cRxLock;		/*< Stores the number of items received from the queue (removed from the queue) while the queue was locked.  Set to queueUNLOCKED when the queue is not locked. */
	volatile int8_t cTxLock;		/*< Stores the number of items transmitted to the queue (added to the queue) while the queue was locked.  Set to queueUNLOCKED when the queue is not locked. */

	#if( ( configSUPPORT_STATIC_ALLOCATION == 1 ) && ( configSUPPORT_DYNAMIC_ALLOCATION == 1 ) )
		uint8_t ucStaticallyAllocated;	/*< Set to pdTRUE if the memory used by the queue was statically allocated to ensure no attempt is made to free the memory. */
	#endif

	#if ( configUSE_QUEUE_SETS == 1 )
		struct QueueDefinition *pxQueueSetContainer;
	#endif

	#if ( configUSE_TRACE_FACILITY == 1 )
		UBaseType_t uxQueueNumber;
		uint8_t ucQueueType;
	#endif

} xQUEUE;

    本文暂时不需要深入源码，在queue.h的接口已经封装得相当好，无需对细节太过于关注，下面会是对常用接口的使用的总结，如果英文好，直接看源码中的函数注释也是很好的选择。

    3 相关概念

    3.1 数据结构

    队列可以保存有限个具有确定长度的数据单元。队列可以保存的最大单元数目被称为队列的“深度”。在队列创建时需要设定其深度和每个单元的大小。通常情况下，队列被作为 FIFO(先进先出)使用，即数据由队列尾写入，从队列首读出。当然，由队列首写入也是可能的。往队列写入数据是通过字节拷贝把数据复制存储到队列中；从队列读出数据使得把
    队列中的数据拷贝删除。1 如下图所示；


    laizi
    注意
    上面提到的    数据单元    可以是一个char或int类型的数，但是相对比较合理的设计是，封装成一个合理的类，或者称之为结构体，可以明确当前数据单元的数据类型，数据来源（来自哪个任务）等等，因为一个队列可以被多个任务进行读取和发送函数，这样就避免了传输数据出现混淆的情况。通常设计是一个队列被多个任务写入数据，然后有一个任务读取，暂时称之为多写一读，反之，多读一写则较少遇到。

    3.2 收发数据堵塞

    当某个任务试图读或者写一个队列时，其可以指定一个阻塞超时时间，

    • 读取：
      任务读取数据时，在设置堵塞超时时间内，如果队列为空，该任务将保持阻塞状态以等待队列数据有效。当其它任务或中断服务例程
      往其等待的队列中写入了数据，该任务将自动由阻塞态转移为就绪态。

    • 写入：如果队列被多个任务写入，那么将导致多个任务堵塞以等待队列有效，当队列有效的时候，这些任务中的优先级最高的任务优先进入就绪态。

    4 常用函数

    FreeRTOS的消息队列常用接口都封装在queue.h中，通过宏定义统一将接口函数的命名风格整理得十分统一；具体如下图所示；


    在这里插入图片描述

    这里有两种需要注意；

    • 任务与任务之间同步：例如图中①处的API适用于任务间同步；
      • xQueueSendToFront
      • xQueueSendToFront
      • xQueueSend
      • xQueueOverwrite
    • 任务与中断之间同步：图中②处的API适用于任务于中断间同步，xxxISR()后缀的函数都是FreeRTOS中保证了线程安全的；
      • xQueueSendToFrontFromISR
      • xQueueSendToBackFromISR
      • xQueueOverwriteFromISR
      • xQueueSendFromISR

    4.1 创建队列

    • QueueHandle_t
      QueueHandle_t是一个void类型的指针变量，定义在queue.h中，具体如下；
    /**
 * Type by which queues are referenced.  For example, a call to xQueueCreate()
 * returns an QueueHandle_t variable that can then be used as a parameter to
 * xQueueSend(), xQueueReceive(), etc.
 */
typedef void * QueueHandle_t;

    基本上每个队列函数都会使用这个变量，这里我们统一称为队列的句柄；

    • xQueueCreate
      这个函数可以创建一个队列，创建成功则会返回一个队列句柄，如果创建失败则返回NULL，其函数原型是xQueueGenericCreate，具体如下所示；
    #define xQueueCreate( uxQueueLength, uxItemSize ) 
xQueueGenericCreate( ( uxQueueLength ), ( uxItemSize ), ( queueQUEUE_TYPE_BASE ) )

    xQueueCreate如下所示；

     QueueHandle_t xQueueCreate(
							  UBaseType_t uxQueueLength,
							  UBaseType_t uxItemSize
						  );
    参数 描述
    uxQueueLength 队列能够存储的最大单元数目，即队列深度
    uxItemSize 队列中数据单元的长度，以字节为单位
    retval NULL：创建失败；否则为创建成功

    4.2 发送数据

    下面都是从任务发送数据到队列，

     BaseType_t xQueueSendToBack(
								   QueueHandle_t	xQueue,
								   const void		*pvItemToQueue,
								   TickType_t		xTicksToWait
							   );

     BaseType_t xQueueSendToFront(
							  QueueHandle_t xQueue,
							  const void * pvItemToQueue,
							  TickType_t xTicksToWait
						 );
    • xQueueSend
      与xQueueSendToBack入队顺序相同，函数声明如下所示；
     BaseType_t xQueueSend(
							  QueueHandle_t xQueue,
							  const void * pvItemToQueue,
							  TickType_t xTicksToWait
						 );

    具体的参数描述如下：

    参数 描述
    xQueue 创建队列时返回的句柄
    pvItemToQueue 需要从任务发送到队列的数据
    xTicksToWait 阻塞超时时间。如果在发送时队列已满，这个时间即是任务处于阻塞态等待队列空间有效的最长等待时间。
    retval pdPass：发送数据成功
    errQUEUE_FULL：无法写入数据

    关于xTicksToWait

    • xTicksToWait设为0 ，且队列已满，则xQueueSendToFront()与xQueueSendToBack()均会立即返回。阻塞时间是以系统心跳周期为单位的，所以绝对时间取决于系统心跳频率。常量 portTICK_RATE_MS 可以用来把心跳时间单位转换为毫秒时间单位。
    • xTicksToWait 设置为 portMAX_DELAY ， 并且在FreeRTOSConig.h 中设定 INCLUDE_vTaskSuspend 为 1，那么阻塞等待将没有超时限制。

    4.3 接收数据

    • xQueueReceive
      xQueueReceive()用于从队列中接收(读取）数据单元。接收到的单元同时会从队列
      中删除      。函数声明如下；
     BaseType_t xQueueReceive(
								 QueueHandle_t xQueue,
								 void *pvBuffer,
								 TickType_t xTicksToWait
							);
    • xQueuePeek
      xQueuePeek()也是从从队列中接收数据单元，不同的是并不从队列中删出接收到的单元。 xQueuePeek()从队列首接收到数据后，不会修改队列中的数据，也不会改变数据在队列中的存储序顺。函数声明如下；
     BaseType_t xQueuePeek(
							 QueueHandle_t xQueue,
							 void * const pvBuffer,
							 TickType_t xTicksToWait
						 );

    具体的参数描述如下：

    参数 描述
    xQueue 队列的句柄
    pvBuffer 接收缓存指针。其指向一段内存区域，用于接收从队列中拷贝来的数据
    xTicksToWait 阻塞超时时间
    retavl pdPASS：接收成功
    errQUEUE_FULL：接收失败
    • uxQueueSpacesAvailable
      uxQueueSpacesAvailable()用于查询队列中可用的空闲空间数量；函数声明如下；
    UBaseType_t uxQueueSpacesAvailable( const QueueHandle_t xQueue );
    参数 描述
    xQueue 队列的句柄
    retval 当前队列中空余的数据单元个数，0表示队列已满
    • uxQueueMessagesWaiting
      uxQueueMessagesWaiting()用于查询队列中当前有效数据单元个数；函数声明如下；
    UBaseType_t uxQueueMessagesWaiting( const QueueHandle_t xQueue );
    参数 描述
    xQueue 队列的句柄
    retval 当前队列中空余的数据单元个数，0表示队列为空

    4.4 删除队列

    • vQueueDelete
      用来删除一个队列，直接传入已创建的队列句柄即可，函数声明如下；
    void vQueueDelete( QueueHandle_t xQueue );

    5 举例

    多个任务写入一个任务读取的时候应该怎么做呢？如下图所示2；
    在这里插入图片描述
    这里有三个任务，所以为了搞清楚数据来自哪个任务，因此将数据单元封装起来，使用
    iMeaning表示数据单元的源头，当然这里还是比较简单的应用。

    6 总结

    本文介绍了FreeRTOS的消息队列比价常用的方法，当然是相对简单的，侧重在了解概念上，需要实际的应用从而加深理解，更加详细已经灵活的应用可以参考FreeRTOS作者撰写的Mastering_the_FreeRTOS_Real_Time_Kernel-A_Hands-On_Tutorial_Guide。

    1. Mastering_the_FreeRTOS_Real_Time_Kernel-A_Hands-On_Tutorial_Guide.pdf ↩︎

    2. FREERTOS 实时内核实用指南,Zou Changjun ↩︎
  • 相关阅读:
    创建字典的方法
    python中，a=10.0 b=10.0 a is b 为什么输出是false
    Python 拷贝对象（深拷贝deepcopy与浅拷贝copy）
    二十三种设计模式及其python实现
    python字符串替换的2种方法
    数据库索引的实现原理？
    异步IO数据库队列缓存RabbitMQ队列
    Python 如何用列表实现栈和队列？
    Python数据结构与算法？
    django -----原生SQL语句查询与前端数据传递？
  • 原文地址：https://www.cnblogs.com/unclemac/p/12783313.html
Copyright © 2011-2022 走看看