15.队列集

1.简介

在使用队列进行任务之间的“沟通交流”时，一个队列只允许任务间传递的消息为同一种数据类型，如果需要在任务间传递不同数据类型的消息时，那么就可以使用队列集。FreeRTOS提供的队列集功能可以对多个队列进行“监听”，只要被监听的队列中有一个队列有有效的消息，那么队列集的读取任务都可以读取到消息，如果读取任务因读取队列集而被阻塞，那么队列集将解除读取任务的阻塞。使用队列集的好处在于，队列集可以是的任务可以读取多个队列中的消息，而无需遍历所有待读取的队列，以确定具体读取哪一个队列。

使用队列集功能，需要在 FreeRTOSConfig.h 文件中将配置项 configUSE_QUEUE_SETS 配
置为 1，来启用队列集功能。
在这里插入图片描述

2.相关API函数

在这里插入图片描述

1. 函数 xQueueCreateSet()

此函数用于创建队列集，该函数在 queue.c 文件中有定义，函数的原型如下所示：

QueueSetHandle_t xQueueCreateSet(const UBaseType_t uxEventQueueLength);

在这里插入图片描述

QueueSetHandle_t xQueueCreateSet(const UBaseType_t uxEventQueueLength)
{QueueSetHandle_t pxQueue;/* 创建一个队列作为队列集* 队列长度为队列集可容纳的队列数量* 队列项目的大小为队列控制块的大小* 队列的类型为队列集*/pxQueue = xQueueGenericCreate( uxEventQueueLength,( UBaseType_t ) sizeof( Queue_t * ),queueQUEUE_TYPE_SET );return pxQueue;
}

2. 函数 xQueueAddToSet()

此函数用于往队列集中添加队列，要注意的时，队列在被添加到队列集之前，队列中不能
有有效的消息，该函数在 queue.c 文件中有定义，函数的原型如下所示：

BaseType_t xQueueAddToSet( QueueSetMemberHandle_t xQueueOrSemaphore,QueueSetHandle_t xQueueSet);

在这里插入图片描述
函数 xQueueAddToSet()的具体代码如下所示：

BaseType_t xQueueAddToSet( QueueSetMemberHandle_t xQueueOrSemaphore,
QueueSetHandle_t xQueueSet)
{BaseType_t xReturn;/* 进入临界区 */taskENTER_CRITICAL();{if( ( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer != NULL ){xReturn = pdFAIL;}/* 队列中要求没有有效消息 */else if( ( ( Queue_t * ) xQueueOrSemaphore )->uxMessagesWaiting !=( UBaseType_t ) 0 ){xReturn = pdFAIL;}else{/* 将队列所在队列集设为队列集 */( ( Queue_t * ) xQueueOrSemaphore )->pxQueueSetContainer =xQueueSet;xReturn = pdPASS;}}/* 退出临界区 */taskEXIT_CRITICAL();return xReturn;
}

3. 函数 xQueueRemoveFromSet()

此函数用于从队列集中移除队列，要注意的时，队列在从队列集移除之前，必须没有有效
的消息，该函数在 queue.c 文件中有定义，函数的原型如下所示：

BaseType_t xQueueRemoveFromSet(QueueSetMemberHandle_t xQueueOrSemaphore,QueueSetHandle_t xQueueSet);

在这里插入图片描述
在这里插入图片描述
函数 xQueueRemoveFromSet()的具体代码如下所示：

BaseType_t xQueueRemoveFromSet(QueueSetMemberHandle_t xQueueOrSemaphore,QueueSetHandle_t xQueueSet)
{BaseType_t xReturn;Queue_t * const pxQueueOrSemaphore = ( Queue_t * ) xQueueOrSemaphore;/* 队列需在队列集中，才能移除 */if( pxQueueOrSemaphore->pxQueueSetContainer != xQueueSet ){xReturn = pdFAIL;}/* 队列中没有有效消息时，才能移除 */else if( pxQueueOrSemaphore->uxMessagesWaiting != ( UBaseType_t ) 0 ){xReturn = pdFAIL;}else{/* 进入临界区 */taskENTER_CRITICAL();{/* 将队列所在队列集设为空 */pxQueueOrSemaphore->pxQueueSetContainer = NULL;}/* 退出临界区 */taskEXIT_CRITICAL();xReturn = pdPASS;}return xReturn;
}

4. 函数 xQueueSelectFromSet()

此函数用于在任务中获取队列集中有有效消息的队列，该函数在 queue.c 文件中有定义，函
数的原型如下所示：

QueueSetMemberHandle_t xQueueSelectFromSet(QueueSetHandle_t xQueueSet,TickType_t const xTicksToWait);

在这里插入图片描述
在这里插入图片描述
函数 xQueueSelectFromSet()的具体代码如下所示：

QueueSetMemberHandle_t xQueueSelectFromSet(QueueSetHandle_t xQueueSet,TickType_t const xTicksToWait)
{QueueSetMemberHandle_t xReturn = NULL;/* 读取队列集的消息* 读取到的消息，* 即为队列集中有空闲消息的队列*/( void ) xQueueReceive( ( QueueHandle_t ) xQueueSet,&xReturn,xTicksToWait);return xReturn;
}

5. 函数 xQueueSelectFromSetFromISR()

此函数用于在中断中获取队列集中有有效消息的队列，该函数在 queue.c 文件中有定义，函
数的原型如下所示：

QueueSetMemberHandle_t xQueueSelectFromSetFromISR(QueueSetHandle_t xQueueSet );

在这里插入图片描述

QueueSetMemberHandle_t xQueueSelectFromSetFromISR(QueueSetHandle_t xQueueSet )
{QueueSetMemberHandle_t xReturn = NULL;/* 在中断中读取队列集的消息* 读取到的消息，* 即为队列集中有空闲消息的队列*/( void ) xQueueReceiveFromISR( ( QueueHandle_t ) xQueueSet,&xReturn,NULL);return xReturn;
}

3.相关实验

在这里插入图片描述

#include "freertos_demo.h"
#include "./SYSTEM/usart/usart.h"
#include "./BSP/LED/led.h"
#include "./BSP/LCD/lcd.h"
#include "./BSP/KEY/key.h"
#include "./SYSTEM/delay/delay.h"
#include "./MALLOC/malloc.h"
/*FreeRTOS*********************************************************************************************/
#include "FreeRTOS.h"
#include "task.h"
#include "queue.h"
#include "semphr.h"
/******************************************************************************************************/
/*FreeRTOS配置*//* START_TASK 任务 配置* 包括: 任务句柄 任务优先级 堆栈大小 创建任务*/
#define START_TASK_PRIO         1
#define START_TASK_STACK_SIZE   128
TaskHandle_t    start_task_handler;
void start_task( void * pvParameters );/* TASK1 任务 配置* 包括: 任务句柄 任务优先级 堆栈大小 创建任务*/
#define TASK1_PRIO         2
#define TASK1_STACK_SIZE   128
TaskHandle_t    task1_handler;
void task1( void * pvParameters );/* TASK2 任务 配置* 包括: 任务句柄 任务优先级 堆栈大小 创建任务*/
#define TASK2_PRIO         3
#define TASK2_STACK_SIZE   128
TaskHandle_t    task2_handler;
void task2( void * pvParameters );/******************************************************************************************************/
QueueSetHandle_t queueset_handle;
QueueHandle_t    queue_handle;
QueueHandle_t    semphr_handle;
/*** @brief       FreeRTOS例程入口函数* @param       无* @retval      无*/
void freertos_demo(void)
{    xTaskCreate((TaskFunction_t         )   start_task,(char *                 )   "start_task",(configSTACK_DEPTH_TYPE )   START_TASK_STACK_SIZE,(void *                 )   NULL,(UBaseType_t            )   START_TASK_PRIO,(TaskHandle_t *         )   &start_task_handler );vTaskStartScheduler();
}void start_task( void * pvParameters )
{taskENTER_CRITICAL();                               /* 进入临界区 */queueset_handle = xQueueCreateSet( 2 );             /* 创建队列集，可以存放2个队列 */if(queueset_handle != NULL){printf("队列集创建成功！！\r\n");}queue_handle = xQueueCreate( 1, sizeof(uint8_t) );  /* 创建队列 */ semphr_handle = xSemaphoreCreateBinary();           /* 创建二值信号量 */xQueueAddToSet( queue_handle,queueset_handle);xQueueAddToSet( semphr_handle,queueset_handle);xTaskCreate((TaskFunction_t         )   task1,(char *                 )   "task1",(configSTACK_DEPTH_TYPE )   TASK1_STACK_SIZE,(void *                 )   NULL,(UBaseType_t            )   TASK1_PRIO,(TaskHandle_t *         )   &task1_handler );xTaskCreate((TaskFunction_t         )   task2,(char *                 )   "task2",(configSTACK_DEPTH_TYPE )   TASK2_STACK_SIZE,(void *                 )   NULL,(UBaseType_t            )   TASK2_PRIO,(TaskHandle_t *         )   &task2_handler );vTaskDelete(NULL);taskEXIT_CRITICAL();                /* 退出临界区 */
}/* 任务一，实现队列发送以及信号量释放 */
void task1( void * pvParameters )
{uint8_t key = 0;BaseType_t err = 0;while(1) {key = key_scan(0);if(key == KEY0_PRES){err = xQueueSend( queue_handle, &key, portMAX_DELAY );if(err == pdPASS){printf("往队列queue_handle写入数据成功！！\r\n");}}else if(key == KEY1_PRES){err = xSemaphoreGive(semphr_handle);if(err == pdPASS){printf("释放信号量成功！！\r\n");}}vTaskDelay(10);}
}/* 任务二，获取队列集的消息 */
void task2( void * pvParameters )
{QueueSetMemberHandle_t member_handle;uint8_t key;while(1){member_handle = xQueueSelectFromSet( queueset_handle,portMAX_DELAY);if(member_handle == queue_handle){xQueueReceive( member_handle,&key,portMAX_DELAY);printf("获取到的队列数据为：%d\r\n",key);}else if(member_handle == semphr_handle){xSemaphoreTake( member_handle, portMAX_DELAY );printf("获取信号量成功！！\r\n");}}
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/301501.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Unity类银河恶魔城学习记录12-4 p126 Item Tooltip源代码

Unity类银河恶魔城学习记录12-4 p126 Item Tooltip源代码

Alex教程每一P的教程原代码加上我自己的理解初步理解写的注释，可供学习Alex教程的人参考 此代码仅为较上一P有所改变的代码 【Unity教程】从0编程制作类银河恶魔城游戏_哔哩哔哩_bilibili UI.cs using System.Collections; using System.Collections.Generic; usi…
阅读更多...
xilinx AXI CAN驱动开发

xilinx AXI CAN驱动开发

CAN收发方案有很多，常见的解决方案通过是采用CAN收发芯片，例如最常用的SJA1000,xilinx直接将CAN协议栈用纯逻辑实现，AXI CAN是其中一种； 通过这种方式硬件上只需外接一个PHY芯片即可 上图加了一个电平转换芯片 软件设计方面&…
阅读更多...
Scala大数据开发

Scala大数据开发

版权声明 本文原创作者：谷哥的小弟作者博客地址：http://blog.csdn.net/lfdfhl Scala简述 在此，简要介绍 Scala 的基本信息和情况。 Scala释义 Scala 源自于英语单词scalable，表示可伸缩的、可扩展的含义。 Scala作者 Scala编…
阅读更多...
【考研数学】张宇《1000题》刷不动，做不下来怎么办❓

【考研数学】张宇《1000题》刷不动，做不下来怎么办❓

学长肯定是用着效果不错才给你推荐的，但是习题册有很多，各自有不同的风格，1000题适不适合你的情况是你要考虑的点。 选书还是要结合自身的情况，如果当前用着不错的话，继续完全没有问题，核心就是要从自身的…
阅读更多...
IT外包服务：企业数据资产化加速利器

IT外包服务：企业数据资产化加速利器

随着数字化时代的兴起，数据成为企业最为重要的资源之一。数据驱动创新对于企业的竞争力和可持续发展至关重要。在这一进程中，IT外包服务发挥着关键作用，加速企业数据资产化进程，为企业提供了重要支持。 首先，IT外包服务…
阅读更多...
【学习心得】Python中的queue模块使用

【学习心得】Python中的queue模块使用

一、Queue模块的知识点思维导图 二、Queue模块常用函数介绍 queue模块是内置的，不需要安装直接导入就可以了。 （1）创建一个Queue对象 import queue# 创建一个队列实例 q queue.Queue(maxsize20) # 可选参数，默认为无限大&am…
阅读更多...
基于springboot实现教师人事档案管理系统项目【项目源码+论文说明】

基于springboot实现教师人事档案管理系统项目【项目源码+论文说明】

基于springboot实现IT技术交流和分享平台系统演示 摘要 我国科学技术的不断发展，计算机的应用日渐成熟，其强大的功能给人们留下深刻的印象，它已经应用到了人类社会的各个层次的领域，发挥着重要的不可替换的作用。信息管理作为计算…
阅读更多...
【chrome扩展】简 Tab (SimpTab)‘每日一句名言’样式

【chrome扩展】简 Tab (SimpTab)‘每日一句名言’样式

背景：最初参考“每日诗词”发现总是那几句，可以更换API接口完成“每日一句名言” 声明：本人不会ajax及ccs样式，非专业人士，借助CHATGPT代码生成完成。请友善交流。 每一句名言API: "https://api.xygeng.cn/open…
阅读更多...
libVLC 提取视频帧

libVLC 提取视频帧

在前面的文章中，我们使用libvlc_media_player_set_hwnd设置了视频的显示的窗口。 libvlc_media_player_set_hwnd(vlc_mediaPlayer, (void *)ui.widgetShow->winId()); 如果我们想要提取每一帧数据，将数据保存到本地，该如何操作呢&#x…
阅读更多...
OPC UA遇见chatGPT

OPC UA遇见chatGPT

最近opc 基金会将召开一个会议，主题是”OPC UA meets IT“。由此可见，工业自动化行业也开始研究和评估chatGPT带来的影响了。 本文谈谈本人对OPC UA 与chatGPT结合的初步实验和思考。 构建OPC UA 信息模型 chatGPT 的确非常强大了，使用自然…
阅读更多...
用户登录时md5加密源码解析

用户登录时md5加密源码解析

首先，在登录的时候，将页面提交的密码password加密处理，即password DigestUtils.md5DigestAsHex(password.getBytes()); 接着按ctrl鼠标左键，进入md5DigestAsHex函数中进行查看： 可以发现，md5DigestAsHex函…
阅读更多...
Mysql底层原理六：InnoDB 数据页结构

Mysql底层原理六：InnoDB 数据页结构

1.行格式 1.1 Compact行格式 1.1.1 示意图 1.1.2 准备一下 1）建表 mysql> CREATE TABLE record_format_demo (-> c1 VARCHAR(10),-> c2 VARCHAR(10) NOT NULL,-> c3 CHAR(10),-> c4 VARCHAR(10)-> ) CHARSETascii ROW_FORMATCOM…
阅读更多...
积木-蓝桥每日真题

积木-蓝桥每日真题

0积木 - 蓝桥云课 (lanqiao.cn) 题目描述 小明用积木搭了一个城堡。 为了方便，小明在搭的时候用的是一样大小的正方体积木，搭在了一个n行m列的方格图上，每个积木正好占据方格图的一个小方格。 当然，小明的城堡并不是平面的&#x…
阅读更多...
Discord注册教程：Discord刚注册就被封怎么办？附申诉教程！

Discord注册教程：Discord刚注册就被封怎么办？附申诉教程！

Discord如今在海外社交媒体平台中迅速崛起，许多社交媒体营销人员也纷纷利用其社群特性进行推广，Discord注册也就成为社媒营销人员必经之路。然而，很多人注册Discord账号时常常会想：“在国内使用Discord会封号吗？”事实…
阅读更多...
个推助力小米汽车APP实现智能用户触达，打造智能出行新体验

个推助力小米汽车APP实现智能用户触达，打造智能出行新体验

4月3日，小米SU7首批交付仪式在北京亦庄的小米汽车工厂总装车间举行，全国28城交付中心也同步开启首批交付。随着小米SU7系列汽车的正式发售和交付，小米汽车APP迎来了用户体量的爆发式增长。 小米汽车APP是小米汽车官方推出的手机应用&#xff…
阅读更多...
数据库面试题

数据库面试题

文章目录 事务未提交和提交事务的4大特征事务的隔离级别并发事务的问题MVVCundo log 和 redo log记录的隐藏字段readview（读视图） 事务未提交和提交 事务未提交时数据存在于数据库系统的缓存中，而在事务提交后，数据才会被写入到磁…
阅读更多...
多叉树题目：子树中标签相同的结点数

多叉树题目：子树中标签相同的结点数

文章目录 题目标题和出处难度题目描述要求示例数据范围 解法思路和算法代码复杂度分析 题目 标题和出处 标题：子树中标签相同的结点数 出处：1519. 子树中标签相同的结点数 难度 5 级 题目描述 要求 给你一个树（即一个连通的无向无环图…
阅读更多...
【Canvas技法】图解绘制圆弧的重要函数 arc(x,y,r,startAngle,endAngle,clockWise)

【Canvas技法】图解绘制圆弧的重要函数 arc(x,y,r,startAngle,endAngle,clockWise)

【一图释疑】 【绘制上图用代码】 <!DOCTYPE html> <html lang"utf-8"> <meta http-equiv"Content-Type" content"text/html; charsetutf-8"/> <head><title>Html5/Canvas中绘制圆弧的重要函数 arc(x,y,r,startA…
阅读更多...
虹科Pico汽车示波器 | 免拆诊断案例 | 2019款别克GL8豪华商务车前照灯水平调节故障

虹科Pico汽车示波器 | 免拆诊断案例 | 2019款别克GL8豪华商务车前照灯水平调节故障

一、故障现象 一辆2019款别克GL8豪华商务车&#xff0c;搭载LTG发动机&#xff0c;累计行驶里程约为10.7万km。车主反映&#xff0c;车辆行驶过程中组合仪表提示前照灯水平调节故障。 二、故障诊断 接车后试车&#xff0c;起动发动机&#xff0c;组合仪表上提示“前照灯水平…
阅读更多...
CSS常见样式

CSS常见样式

字体相关的样式 <style>div{/* 斜体 */font-style: italic;/* 加粗 100-900*/font-weight: 900;/* 字体大小 */font-size: 20px;/* 声明字体格式 */font-family: "微软雅黑";}</style> div内部文字垂直居中 只需要将行高设为其height的大小即可。 div{…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023