STM32与Freertos入门（六）队列

news2025/10/31 15:36:54

1、队列介绍

队列是FreeRTOS提供的一种重要的通信机制，用于在任务之间传递数据。

FreeRTOS队列是一种先进先出（FIFO）的数据结构，用于在任务之间传递消息或数据项。它允许一个任务将数据项发送到队列，而另一个任务则可以从队列中接收这些数据项。

以下是FreeRTOS队列的一些重要特点和用法：

  1. 队列创建：可以使用FreeRTOS提供的API函数创建队列。在创建队列时，需要指定队列的最大长度和每个数据项的大小。

  2. 发送数据：任务可以使用xQueueSend()函数将数据项发送到队列中。如果队列已满，发送操作将被阻塞，直到有空间可用。

  3. 接收数据：任务可以使用xQueueReceive()函数从队列中接收数据项。如果队列为空，接收操作将被阻塞，直到有数据可用。

  4. 队列优先级：FreeRTOS队列还支持优先级功能。可以为队列设置优先级，使得在同时有多个任务等待发送或接收数据时，根据优先级决定哪个任务先进行操作。

  5. 队列长度：通过查询队列的长度，可以了解当前队列中待处理的数据项数量。这对于任务调度和资源管理非常有用。

使用FreeRTOS队列时，需要注意以下几点：

  • 需要合理设置队列的长度，确保不会超过任务处理能力。
  • 当队列满或空时，任务可能会被阻塞，因此要小心处理该种情况以避免死锁。
  • 在多任务环境下，要注意同步和竞争条件，以确保数据的正确性和一致性。

总的来说，FreeRTOS队列提供了一种方便和高效的任务间通信机制，可以在嵌入式系统中实现数据传递和同步。它是FreeRTOS强大功能的一部分，帮助开发人员编写可靠的实时应用程序。

2、队列测试

2.1 任务创建

2.2 队列建立

3、队列API

 3.1 创建队列

QueueHandle_t xQueueCreate( UBaseType_t uxQueueLength, UBaseType_t uxItemSize );
  • 参数：
    • uxQueueLength：队列可同时容纳的最大项目数 。
    • uxItemSize：存储队列中的每个数据项所需的大小（以字节为单位）。
  • 返回值： 
    • 如果队列创建成功，则返回所创建队列的句柄 。 如果创建队列所需的内存无法分配，则返回 NULL。

 3.2 写队列

BaseType_t xQueueSend(
              QueueHandle_t xQueue,
              const void * pvItemToQueue,
              TickType_t xTicksToWait
            );
  • 参数：
    • xQueue：队列的句柄，数据项将发送到此队列。
    • pvItemToQueue：待写入数据
    • xTicksToWait：阻塞超时时间
  • 返回值：
    • 如果成功写入数据，返回 pdTRUE，否则返回 errQUEUE_FULL。

  3.3读队列

BaseType_t xQueueReceive(
               QueueHandle_t xQueue,
               void *pvBuffer,
               TickType_t xTicksToWait
             );
  • 参数：
    • xQueue：待读取的队列
    • pvItemToQueue：数据读取缓冲区
    • xTicksToWait：阻塞超时时间
  • 返回值：
    • 成功返回 pdTRUE，否则返回 pdFALSE。

4、KEIL 5代码设计

4.1 写队列函数

void StartTask_send(void const * argument)
{
  /* USER CODE BEGIN StartTask_send */
	uint16_t buf = 100;
	BaseType_t status;
  /* Infinite loop */
  for(;;)
  {
		if(key==0){ 
			osDelay(20);
			if(key==0){
				printf("key按下\r\n");
				status=xQueueSend(myQueueHandle,&buf,0);
				if(status == pdTRUE){
					printf("写入队列成功，写入值%d\r\n",buf);
				}
				else{
					printf("写入失败\r\n");
				}
			}	
			while(key==0);
		}
		osDelay(10);
  }
  /* USER CODE END StartTask_send */
}

4.2 读队列函数

void StartTask_receive(void const * argument)
{
  /* USER CODE BEGIN StartTask_receive */
	uint16_t buf;
	BaseType_t status;
  /* Infinite loop */
  for(;;)
  {
    if(key2==0){ 
			osDelay(20);
			if(key2==0){
				printf("key2按下\r\n");
				status=xQueueReceive(myQueueHandle,&buf,0);
				if(status == pdTRUE){
					printf("读取队列成功，读出值%d\r\n",buf);
				}
				else{
					printf("读取失败\r\n");
				}
			}	
			while(key2==0);
		}
		osDelay(10);
  }
  /* USER CODE END StartTask_receive */
}

freertos.c代码如下：

/* USER CODE BEGIN Header */
/**
  ******************************************************************************
  * File Name          : freertos.c
  * Description        : Code for freertos applications
  ******************************************************************************
  * @attention
  *
  * Copyright (c) 2023 STMicroelectronics.
  * All rights reserved.
  *
  * This software is licensed under terms that can be found in the LICENSE file
  * in the root directory of this software component.
  * If no LICENSE file comes with this software, it is provided AS-IS.
  *
  ******************************************************************************
  */
/* USER CODE END Header */

/* Includes ------------------------------------------------------------------*/
#include "FreeRTOS.h"
#include "task.h"
#include "main.h"
#include "cmsis_os.h"

/* Private includes ----------------------------------------------------------*/
/* USER CODE BEGIN Includes */

/* USER CODE END Includes */

/* Private typedef -----------------------------------------------------------*/
/* USER CODE BEGIN PTD */

/* USER CODE END PTD */

/* Private define ------------------------------------------------------------*/
/* USER CODE BEGIN PD */

/* USER CODE END PD */

/* Private macro -------------------------------------------------------------*/
/* USER CODE BEGIN PM */

/* USER CODE END PM */

/* Private variables ---------------------------------------------------------*/
/* USER CODE BEGIN Variables */

/* USER CODE END Variables */
osThreadId Task_sendHandle;
osThreadId Task_receiveHandle;
osMessageQId myQueueHandle;

/* Private function prototypes -----------------------------------------------*/
/* USER CODE BEGIN FunctionPrototypes */

/* USER CODE END FunctionPrototypes */

void StartTask_send(void const * argument);
void StartTask_receive(void const * argument);

void MX_FREERTOS_Init(void); /* (MISRA C 2004 rule 8.1) */

/* GetIdleTaskMemory prototype (linked to static allocation support) */
void vApplicationGetIdleTaskMemory( StaticTask_t **ppxIdleTaskTCBBuffer, StackType_t **ppxIdleTaskStackBuffer, uint32_t *pulIdleTaskStackSize );

/* USER CODE BEGIN GET_IDLE_TASK_MEMORY */
static StaticTask_t xIdleTaskTCBBuffer;
static StackType_t xIdleStack[configMINIMAL_STACK_SIZE];

void vApplicationGetIdleTaskMemory( StaticTask_t **ppxIdleTaskTCBBuffer, StackType_t **ppxIdleTaskStackBuffer, uint32_t *pulIdleTaskStackSize )
{
  *ppxIdleTaskTCBBuffer = &xIdleTaskTCBBuffer;
  *ppxIdleTaskStackBuffer = &xIdleStack[0];
  *pulIdleTaskStackSize = configMINIMAL_STACK_SIZE;
  /* place for user code */
}
/* USER CODE END GET_IDLE_TASK_MEMORY */

/**
  * @brief  FreeRTOS initialization
  * @param  None
  * @retval None
  */
void MX_FREERTOS_Init(void) {
  /* USER CODE BEGIN Init */

  /* USER CODE END Init */

  /* USER CODE BEGIN RTOS_MUTEX */
  /* add mutexes, ... */
  /* USER CODE END RTOS_MUTEX */

  /* USER CODE BEGIN RTOS_SEMAPHORES */
  /* add semaphores, ... */
  /* USER CODE END RTOS_SEMAPHORES */

  /* USER CODE BEGIN RTOS_TIMERS */
  /* start timers, add new ones, ... */
  /* USER CODE END RTOS_TIMERS */

  /* Create the queue(s) */
  /* definition and creation of myQueue */
  osMessageQDef(myQueue, 16, uint16_t);
  myQueueHandle = osMessageCreate(osMessageQ(myQueue), NULL);

  /* USER CODE BEGIN RTOS_QUEUES */
  /* add queues, ... */
  /* USER CODE END RTOS_QUEUES */

  /* Create the thread(s) */
  /* definition and creation of Task_send */
  osThreadDef(Task_send, StartTask_send, osPriorityNormal, 0, 128);
  Task_sendHandle = osThreadCreate(osThread(Task_send), NULL);

  /* definition and creation of Task_receive */
  osThreadDef(Task_receive, StartTask_receive, osPriorityBelowNormal, 0, 128);
  Task_receiveHandle = osThreadCreate(osThread(Task_receive), NULL);

  /* USER CODE BEGIN RTOS_THREADS */
  /* add threads, ... */
  /* USER CODE END RTOS_THREADS */

}

/* USER CODE BEGIN Header_StartTask_send */
/**
  * @brief  Function implementing the Task_send thread.
  * @param  argument: Not used
  * @retval None
  */
/* USER CODE END Header_StartTask_send */
void StartTask_send(void const * argument)
{
  /* USER CODE BEGIN StartTask_send */
	uint16_t buf = 100;
	BaseType_t status;
  /* Infinite loop */
  for(;;)
  {
		if(key==0){ 
			osDelay(20);
			if(key==0){
				printf("key按下\r\n");
				status=xQueueSend(myQueueHandle,&buf,0);
				if(status == pdTRUE){
					printf("写入队列成功，写入值%d\r\n",buf);
				}
				else{
					printf("写入失败\r\n");
				}
			}	
			while(key==0);
		}
		osDelay(10);
  }
  /* USER CODE END StartTask_send */
}

/* USER CODE BEGIN Header_StartTask_receive */
/**
* @brief Function implementing the Task_receive thread.
* @param argument: Not used
* @retval None
*/
/* USER CODE END Header_StartTask_receive */
void StartTask_receive(void const * argument)
{
  /* USER CODE BEGIN StartTask_receive */
	uint16_t buf;
	BaseType_t status;
  /* Infinite loop */
  for(;;)
  {
    if(key2==0){ 
			osDelay(20);
			if(key2==0){
				printf("key2按下\r\n");
				status=xQueueReceive(myQueueHandle,&buf,0);
				if(status == pdTRUE){
					printf("读取队列成功，读出值%d\r\n",buf);
				}
				else{
					printf("读取失败\r\n");
				}
			}	
			while(key2==0);
		}
		osDelay(10);
  }
  /* USER CODE END StartTask_receive */
}
/* Private application code --------------------------------------------------*/
/* USER CODE BEGIN Application */

/* USER CODE END Application */

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Linux部署MySQL5.7和8.0版本 | CentOS和Ubuntu系统详细步骤安装

Linux部署MySQL5.7和8.0版本 | CentOS和Ubuntu系统详细步骤安装

一、MySQL数据库管理系统安装部署【简单】 简介 MySQL数据库管理系统（后续简称MySQL），是一款知名的数据库系统，其特点是：轻量、简单、功能丰富。 MySQL数据库可谓是软件行业的明星产品，无论是后端开发、…
阅读更多...
Reinfocement Learning 学习笔记PartⅡ

Reinfocement Learning 学习笔记PartⅡ

文章目录 Reinfocement Learning六、随机近似与随机梯度下降（Stochastic Approximation & Stochastic Gradient Descent）6.1 Robbins-Monro Algorithm6.2 随机梯度下降 七、时序差分方法（Temporal-Difference Learning）7.1 TD…
阅读更多...
[算法总结] 十大排序算法

[算法总结] 十大排序算法

[算法总结] 十大排序算法 简介： 本文首发于我的个人博客：尾尾部落排序算法是最经典的算法知识。因为其实现代码短，应该广，在面试中经常会问到排序算法及其相关的问题。一般在面试中最常考的是快速排序和归并排序等基本的排序算法…
阅读更多...
想做游戏开发，我应该会点啥？

想做游戏开发，我应该会点啥？

在知乎上，经常能看到类似“如何入门游戏开发”这样的问题，这篇文章，我试着概括性的对游戏开发所需要的技能做一个总结，希望大家对游戏开发能有一个基本的认识~ 游戏开发基础要求高么？ 和其他程序猿一样，要…
阅读更多...
[MySQL]数据库概述

[MySQL]数据库概述

目录 1.什么是数据库 2.数据库分类 2.1关系型数据库 2.2非关系型数据库 1.什么是数据库 我们知道，存储数据可以使用文件来存储。那么为什么我们还要大费周章的去设计和使用数据库呢？ 因为文件保存数据有以下几个缺点： 1.文件的安全性不…
阅读更多...
Failed to install one or more provisioning profiles on the device

Failed to install one or more provisioning profiles on the device

把provision文件导入mac，双击安装provision的时候，提示：Failed to install one or more provisioning profiles on the device。 大体意思是： 未能在设备上安装一个或多个配置配置文件。请确保为此设备配置配置文件。如果没有&am…
阅读更多...
FGSM、PGD、BIM对抗攻击算法实现

FGSM、PGD、BIM对抗攻击算法实现

本篇文章是博主在AI、无人机、强化学习等领域学习时，用于个人学习、研究或者欣赏使用，并基于博主对人工智能等领域的一些理解而记录的学习摘录和笔记，若有不当和侵权之处，指出后将会立即改正，还望谅解。文章分类在AI学…
阅读更多...
代码随想录算法训练营 | day52 动态规划 300.最长递增子序列，674.最长连续递增子序列，718.最长重复子数组

代码随想录算法训练营 | day52 动态规划 300.最长递增子序列，674.最长连续递增子序列，718.最长重复子数组

刷题 300.最长递增子序列 题目链接 | 文章讲解 | 视频讲解 题目：给你一个整数数组 nums ，找到其中最长严格递增子序列的长度。 子序列是由数组派生而来的序列，删除（或不删除）数组中的元素而不改变其余元素的顺序。…
阅读更多...
vue脚手架安装及使用

vue脚手架安装及使用

准备工作 安装node安装cnpm cnpm是npm的“廉价平替” 提高安装速度 npm install -g cnpm --registryhttps://registry.npm.taobao.org 安装脚手架 安装Vue脚手架 cnpm install -g vue/cli 用vue脚手架创建vue项目 找好创建项目的位置 创建项目 vue create test (test为项…
阅读更多...
磁盘及文件系统（上）

磁盘及文件系统（上）

这次博客我们将重点理解Ext2文件系统。 首先我们要理解什么是文件系统。 在之前我们一直理解的文件都是一个被打开的文件，而os为了能够管理这样的文件创建了struct_file这样的结构体对象在内核中描述被打开的文件，这个结构体对象中包含了被打开文件的基…
阅读更多...
【PostgreSQL】从零开始:（一）初识PostgreSQL

【PostgreSQL】从零开始:（一）初识PostgreSQL

从零开始:（一）初识PostgreSQL PostgreSQL数据库介绍为什么使用 PostgreSQL？那么多最终用户,云厂商为什么要贡献核心代码？基于PostgreSQL底层开发的好处：为什么要学习PostgreSQL？截止本文发布之日&#xff0…
阅读更多...
鸿蒙系统（HarmonyOS）之方舟框架（ArkUI）介绍

鸿蒙系统（HarmonyOS）之方舟框架（ArkUI）介绍

鸿蒙开发官网：HarmonyOS应用开发官网 - 华为HarmonyOS打造全场景新服务 方舟开发框架（简称：ArkUI），是一套构建HarmonyOS应用界面的UI开发框架，它提供了极简的UI语法与包括UI组件、动画机制、事件交互等在内…
阅读更多...
鸿蒙app获取文本控件按钮控件_修改控件名称_按钮触发事件_提示信息显示

鸿蒙app获取文本控件按钮控件_修改控件名称_按钮触发事件_提示信息显示

鸿蒙app获取文本控件按钮控件_修改控件名称_按钮触发事件_ 点击启动：提示信息显示 package com.example.myapplication.slice;import com.example.myapplication.ResourceTable; import ohos.aafwk.ability.AbilitySlice; import ohos.aafwk.content.Intent; impor…
阅读更多...
linux 文本信息查询grep；控制命令执行和管道操作符号

linux 文本信息查询grep；控制命令执行和管道操作符号

1、grep grep "keyword" /path/to/logfile获取查询结果最后一行 grep "runs/detect/train" test4.log | tail -n 12、linux控制命令执行和管道操作符号 &、|、; 和 &&、》、>、< ##例子&#xff1b;wandb disabled && yolo …
阅读更多...
synchronized关键字的使用和原理

synchronized关键字的使用和原理

synchronized关键字的使用和原理 synchronized&#xff1a;对象锁&#xff0c;保证了临界区内代码的原子性&#xff0c;采用互斥的方式让同一时刻至多只有一个线程能持有对象锁&#xff0c;其它线程获取这个对象锁时会阻塞&#xff0c;保证拥有锁的线程可以安全的执行临界区内…
阅读更多...
vue-实现高德地图-省级行政区地块显示+悬浮显示+标签显示

vue-实现高德地图-省级行政区地块显示+悬浮显示+标签显示

<template><div><div id"container" /><div click"showFn">显示</div><div click"removeFn">移除</div></div> </template><script> import AMapLoader from amap/amap-jsapi-load…
阅读更多...
SpringBoot - application.yml 多环境切换解决方案

SpringBoot - application.yml 多环境切换解决方案

问题描述 这个问题玩过 SpringCloud 的小伙伴估计会想到用 bootstrap.yml 来解决这个问题。但是如果说为了解决这个问题引入了一堆的 SpringCloud Jar&#xff0c;就感觉杀鸡用牛刀。 于是今天我们想只有 application.yml 自己就可以解决这个问题&#xff0c;如何搞定&#x…
阅读更多...
真正可行的vue3迁移到nuxt3方法（本人亲测，完全避坑）

真正可行的vue3迁移到nuxt3方法（本人亲测，完全避坑）

终于到了总结经验的时候了&#xff0c;这绝对是全网唯一、完全真正可行的干货。 在我看来&#xff0c;知识就是要拿来分享的&#xff0c;分享给他人也是在提高自己。我绝对不会搞什么订阅或者vip专栏来搞钱坑害各位&#xff0c; 因为我在csdn写文章最主要的目的是为了记录和总…
阅读更多...
Chrome限制第三方Cookie：未来无法再追踪你看过哪些敏感的“色色”内容了

Chrome限制第三方Cookie：未来无法再追踪你看过哪些敏感的“色色”内容了

当我们在浏览网络的时候&#xff0c;常听到「Cookie」这个词&#xff0c;但许多人可能不太清楚它到底是什么。最近&#xff0c;Google 宣布了一项重要更新&#xff0c;Google Chrome 将减少对第三方cookie 的支持&#xff0c;以提高用户隐私保护。 下面我会解释一下这个改变对…
阅读更多...
华为数通——路由冗余和备份

华为数通——路由冗余和备份

注&#xff1a;当一条路由的出接口down时&#xff0c;该路由会自动失效。 要求&#xff1a;数据优先走千兆链路。 R1 [ ]ip route-static 172.16.1.0 24 12.1.1.2 目的地址 掩码 下一条 [ ]ip route-static 172.16.1.0 24 21.1.1.2 preference 50 目的地址 …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023