【STM32】FreeRTOS消息队列和信号量学习

一、消息队列（queue）

队列是一种用于实现任务与任务之间，任务与中断之间消息交流的机制。

注意：1.数据的操作是FIFO模式。

2.队列需要明确数据的大小和队列的长度。

3.写和读都会出现堵塞。

实验：创建一个消息队列，两个发送任务，一个接收任务。

其中任务一任务三的等待时间为0，任务二的等待时间为portMAX_DELAY（死等）。

实现：在前一个项目的基础上进行更改【STM32】利用CubeMX对FreeRTOS用按键控制任务

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 */

  /* Create the semaphores(s) */

  /* 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 myQueue01 */
  osMessageQDef(myQueue01, 2, uint32_t);
  myQueue01Handle = osMessageCreate(osMessageQ(myQueue01), NULL);

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

  /* Create the thread(s) */
  /* definition and creation of Task1 */
  osThreadDef(Task1, StartDefaultTask, osPriorityNormal, 0, 128);
  Task1Handle = osThreadCreate(osThread(Task1), NULL);

  /* definition and creation of Task2 */
  osThreadDef(Task2, StartTask02, osPriorityIdle, 0, 128);
  Task2Handle = osThreadCreate(osThread(Task2), NULL);

  /* definition and creation of Task3 */
  osThreadDef(Task3, StartTask03, osPriorityIdle, 0, 128);
  Task3Handle = osThreadCreate(osThread(Task3), NULL);

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

}

/* USER CODE BEGIN Header_StartDefaultTask */
/**
  * @brief  Function implementing the Task1 thread.
  * @param  argument: Not used
  * @retval None
  */
/* USER CODE END Header_StartDefaultTask */
void StartDefaultTask(void const * argument)
{
  /* USER CODE BEGIN StartDefaultTask */
  /* Infinite loop */
	BaseType_t xStatus;
	uint32_t Buf=10086;
  for(;;)
  {
		if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_3)==0)
		{
			osDelay(20);
			if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_3)==0)
			{
				xStatus=xQueueSendToBack(myQueue01Handle,&Buf,0);
				if(xStatus!=pdTRUE)
				{
					printf("NO1\r\n");osDelay(500);
				}
				else
				{
					printf("YES1%u\r\n",Buf);osDelay(500);
				}
			}
		}
    
  }
  /* USER CODE END StartDefaultTask */
}

/* USER CODE BEGIN Header_StartTask02 */
/**
* @brief Function implementing the Task2 thread.
* @param argument: Not used
* @retval None
*/
/* USER CODE END Header_StartTask02 */
void StartTask02(void const * argument)
{
  /* USER CODE BEGIN StartTask02 */
  /* Infinite loop */
	BaseType_t xStatus;
	uint32_t Buf=66666;
  for(;;)
  {		
    if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_4)==0)
		{
			osDelay(20);
			if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_4)==0)
			{
				xStatus=xQueueSendToBack(myQueue01Handle,&Buf,portMAX_DELAY);
				if(xStatus!=pdTRUE)
				{
					printf("NO2\r\n");osDelay(500);
				}
				else
				{
					printf("YES2%u\r\n",Buf);osDelay(500);
				}
			}
		}
  }
  /* USER CODE END StartTask02 */
}

/* USER CODE BEGIN Header_StartTask03 */
/**
* @brief Function implementing the Task3 thread.
* @param argument: Not used
* @retval None
*/
/* USER CODE END Header_StartTask03 */
void StartTask03(void const * argument)
{
  /* USER CODE BEGIN StartTask03 */
  /* Infinite loop */
	//BaseType_t xStatus;
	uint32_t Buf=0;
  for(;;)
  {
    if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_2)==0)
		{
			osDelay(20);
			if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_2)==0)
			{
				printf("当前%u\r\n",Buf);
				//xStatus=xQueueReceive(myQueue01Handle,&Buf,portMAX_DELAY);
				if(xQueueReceive(myQueue01Handle,&Buf,portMAX_DELAY)!=pdTRUE)
				{
					printf("NO3\r\n");
				}
				else
				{
					printf("YES3%u\r\n",Buf);
				}
			}
		}
  }
  /* USER CODE END StartTask03 */
}

现象：队列满了以后，任务一无法发送，任务二会死等，队列空闲以后完成发送。

二、信号量

消息队列用于传输多个数据，占用时间也相对较长，但有时只需要传输状态，因此引入信号量。信号量也是队列的一种。信号量有两种，如果它的量只有0（被拿走的状态）和1（被填入的状态）两种状态，就称为二进制的信号量；当量的状态大于两种，就称为计数型信号量。

1.二值信号量

实验：任务一：按键采集数据；任务二：拿走以后串口发送信息

实现：

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 */

  /* Create the semaphores(s) */
  /* definition and creation of myBinarySem01 */
  osSemaphoreDef(myBinarySem01);
  myBinarySem01Handle = osSemaphoreCreate(osSemaphore(myBinarySem01), 1);

  /* 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 myQueue01 */
  osMessageQDef(myQueue01, 2, uint32_t);
  myQueue01Handle = osMessageCreate(osMessageQ(myQueue01), NULL);

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

  /* Create the thread(s) */
  /* definition and creation of Task1 */
  osThreadDef(Task1, StartDefaultTask, osPriorityNormal, 0, 128);
  Task1Handle = osThreadCreate(osThread(Task1), NULL);

  /* definition and creation of Task2 */
  osThreadDef(Task2, StartTask02, osPriorityNormal, 0, 128);
  Task2Handle = osThreadCreate(osThread(Task2), NULL);

  /* definition and creation of Task3 */
  osThreadDef(Task3, StartTask03, osPriorityNormal, 0, 128);
  Task3Handle = osThreadCreate(osThread(Task3), NULL);

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

}

/* USER CODE BEGIN Header_StartDefaultTask */
/**
  * @brief  Function implementing the Task1 thread.
  * @param  argument: Not used
  * @retval None
  */
/* USER CODE END Header_StartDefaultTask */
void StartDefaultTask(void const * argument)
{
  /* USER CODE BEGIN StartDefaultTask */
  /* Infinite loop */
	BaseType_t xStatus;
	uint32_t Buf=10086;
  for(;;)
	{
//  {
		if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_3)==0)
		{
			osDelay(20);
			if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_3)==0)
			{
//				xStatus=xQueueSendToBack(myQueue01Handle,&Buf,0);
				if(xSemaphoreGive(myBinarySem01Handle)==pdTRUE)
				{
					printf("NO1\r\n");
				}
				else
				{
					printf("YES1%u\r\n",Buf);
				}
			}
		}
    
  }
  /* USER CODE END StartDefaultTask */
}

/* USER CODE BEGIN Header_StartTask03 */
/**
* @brief Function implementing the Task3 thread.
* @param argument: Not used
* @retval None
*/
/* USER CODE END Header_StartTask03 */
void StartTask03(void const * argument)
{
  /* USER CODE BEGIN StartTask03 */
  /* Infinite loop */	
	uint32_t Buf=0;
  for(;;)
  {
    if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_2)==0)
		{
			osDelay(20);
			if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_2)==0)
			{				
				if(xSemaphoreTake(myBinarySem01Handle,0)==pdTRUE)
				{
					printf("YES3\r\n");
				}
				else
				{
					printf("NO3%u\r\n",Buf);
				}
			}
		}
  }
  /* USER CODE END StartTask03 */
}

 现象：当按键释放了信号量，串口才能成功发送信息。

2.记数型信号量

实验：任务一 ：按键一记录人进来；按键二记录人出去；（最多有10个人）

任务二：串口每隔3S打印人数。

实现：

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 */

  /* Create the semaphores(s) */
  /* definition and creation of myBinarySem01 */
  osSemaphoreDef(myBinarySem01);
  myBinarySem01Handle = osSemaphoreCreate(osSemaphore(myBinarySem01), 1);

  /* definition and creation of myCountingSem01 */
  osSemaphoreDef(myCountingSem01);
  myCountingSem01Handle = osSemaphoreCreate(osSemaphore(myCountingSem01), 10);

  /* 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 myQueue01 */
  osMessageQDef(myQueue01, 2, uint32_t);
  myQueue01Handle = osMessageCreate(osMessageQ(myQueue01), NULL);

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

  /* Create the thread(s) */
  /* definition and creation of Task1 */
  osThreadDef(Task1, StartDefaultTask, osPriorityNormal, 0, 128);
  Task1Handle = osThreadCreate(osThread(Task1), NULL);

  /* definition and creation of Task2 */
  osThreadDef(Task2, StartTask02, osPriorityNormal, 0, 128);
  Task2Handle = osThreadCreate(osThread(Task2), NULL);

  /* definition and creation of Task3 */
  osThreadDef(Task3, StartTask03, osPriorityNormal, 0, 128);
  Task3Handle = osThreadCreate(osThread(Task3), NULL);

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

}

/* USER CODE BEGIN Header_StartDefaultTask */
/**
  * @brief  Function implementing the Task1 thread.
  * @param  argument: Not used
  * @retval None
  */
/* USER CODE END Header_StartDefaultTask */
void StartDefaultTask(void const * argument)
{
  /* USER CODE BEGIN StartDefaultTask */
  /* Infinite loop */
  for(;;)
  {
		if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_3)==0)
		{
			osDelay(20);
			if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_3)==0)
			{
				
				if(xSemaphoreGive(myCountingSem01Handle)!=pdTRUE)
				{
					printf("NO1\r\n");
				}
				else
				{
					printf("YES1\r\n");
				}
			}
			
		}
		if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_4)==0)
		{
			osDelay(20);
			if(HAL_GPIO_ReadPin(GPIOE,GPIO_PIN_4)==0)
			{
				
				if(xSemaphoreTake(myCountingSem01Handle,0)!=pdTRUE)
				{
					printf("NO2\r\n");
				}
				else
				{
					printf("YES2\r\n");
				}
			}
			
		}
    
  }
  /* USER CODE END StartDefaultTask */
}

/* USER CODE BEGIN Header_StartTask02 */
/**
* @brief Function implementing the Task2 thread.
* @param argument: Not used
* @retval None
*/
/* USER CODE END Header_StartTask02 */
void StartTask02(void const * argument)
{
  /* USER CODE BEGIN StartTask02 */
  /* Infinite loop */
	
  for(;;)
  {
    
  }
  /* USER CODE END StartTask02 */
}

/* USER CODE BEGIN Header_StartTask03 */
/**
* @brief Function implementing the Task3 thread.
* @param argument: Not used
* @retval None
*/
/* USER CODE END Header_StartTask03 */
void StartTask03(void const * argument)
{
  /* USER CODE BEGIN StartTask03 */
  /* Infinite loop */

  for(;;)
  {
		printf("possess %d people\r\n",(uint16_t)uxSemaphoreGetCount(myCountingSem01Handle));
		osDelay(3000);
  }
  /* USER CODE END StartTask03 */
}

 因为用了函数

myCountingSem01Handle = osSemaphoreCreate(osSemaphore(myCountingSem01), 10);

默认当前计数值为满值。如果设置为0，使用下面的函数：

myCountingSem01Handle=xSemaphoreCreateCounting(10,0);

现象：通过按键一和二实现记录人数，并串口打印了当前人数。

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

阿里云弹性裸金属服务器详细介绍（原神龙）

阿里云弹性裸金属服务器详细介绍（原神龙）

阿里云弹性裸金属服务器（ECS Bare Metal Server）是一种可弹性伸缩的高性能计算服务，原神龙服务器，计算性能与传统物理机无差别，具有安全物理隔离的特点，裸金属服务器分钟级的交付周期。阿里云服务器网分享阿…
阅读更多...
python——案例18：判断该元素是否在列表中

python——案例18：判断该元素是否在列表中

案例18：判断该元素是否在列表中test_list[10,-8,25.6,88,0,4]print("查看88是否在列表里面：")for i in test_list:if(i88):print("存在") print("查看88是否在列表中：") if(88 in test_list):print("存在…
阅读更多...
微服务服务拆分和远程调用

微服务服务拆分和远程调用

一、服务架构比较 单体架构：简单方便，高度耦合，扩展性差，适合小型项目。例如：学生管理系统 分布式架构：松耦合，扩展性好，但架构复杂，难度大。适合大型互联网项目&#x…
阅读更多...
【Linux操作系统】深入理解系统调用中的read和write函数

【Linux操作系统】深入理解系统调用中的read和write函数

在操作系统中，系统调用是用户程序与操作系统之间进行交互的重要方式。其中，read和write函数是常用的系统调用函数，用于在用户程序和操作系统之间进行数据的读取和写入。本文将深入介绍read和write函数的工作原理、用法以及示例代码&#xff0…
阅读更多...
湘大 XTU OJ 1290 Alice and Bob 题解（非常详细）：字符串 分类讨论 简单模拟

湘大 XTU OJ 1290 Alice and Bob 题解（非常详细）：字符串 分类讨论 简单模拟

一、链接 1290 Alice and Bob 二、题目 题目描述 Alice和Bob玩剪刀-石头-布的游戏，请你写个程序判断一下比赛的结果。 输入 第一行是一个整数K，表示样例的个数。 以后每行两个单词，rock表示石头，paper表示布，scis…
阅读更多...
Redis 拒绝服务漏洞（CVE-2023-28856）修复处理

Redis 拒绝服务漏洞（CVE-2023-28856）修复处理

一、漏洞描述 Redis Labs Redis是美国Redis Labs公司的一套开源的使用ANSI C编写、支持网络、可基于内存亦可持久化的日志型、键值（Key-Value）存储数据库，并提供多种语言的API。 Redis 7.0.0 到 7.0.10版本、6.2.0 到 6.2.11版本、6.0.0 到 …
阅读更多...
Git：在本地电脑上如何使用git？

Git：在本地电脑上如何使用git？

git 版本： 2.40.1.windows.1 文章目录 一. 使用git之前你必须要理解的几个概念1.1 理解工作区、版本库、暂存区的概念1.2 提交Git版本库的步骤【分两步执行】 二. Git本地库实战2.1 初始化版本库2.2 新建 & 提交 & 状态2.3 查看日志2.4 回退 & 穿梭 &am…
阅读更多...
树莓派RP2040 用Arduino IDE安装和编译

树莓派RP2040 用Arduino IDE安装和编译

目录 1 Arduino IDE 1.1 IDE下载 1.2 安装 arduino mbed os rp2040 boards 2 编程-烧录固件 2.1 打开点灯示例程序 2.2 选择Raspberry Pi Pico开发板 2.3 编译程序 2.4 烧录程序 2.4.1 Raspberry Pi Pico开发板首次烧录提示失败 2.4.2 解决首次下载失败问题 2.4.2.1…
阅读更多...
FFmpeg 使用总结

FFmpeg 使用总结

FFmpeg 简介 FFmpeg的名称来自MPEG视频编码标准，前面的“FF”代表“Fast Forward”，FFmpeg是一套可以用来记录、转换数字音频、视频，并能将其转化为流的开源计算机程序。可以轻易地实现多种视频格式之间的相互转换。包括如下几个部分&#xf…
阅读更多...
C语言一些有趣的冷门知识

C语言一些有趣的冷门知识

文章目录 概要1.访问数组元素的方法运行结果 2.中括号的特殊用法运行结果 3.大括号的特殊用法运行结果 4.sizeof的用法运行结果 5.渐进运算符运行结果 小结 概要 本文章只是介绍一些有趣的C语言知识，纯属娱乐。这里所有的演示代码我是使用的编译器是Visual Studio …
阅读更多...
jenkins流水线

jenkins流水线

1.拉取代码 https://gitee.com/Wjc_project/yygh-parent.git2、项目编译 mvn clean package -Dmaven.test.skiptrue ls hospital-manage/target3、构建镜像 ls hospital-manage/target docker build -t hospital-manage:latest -f hospital-manage/Dockerfile ./hospital-ma…
阅读更多...
SRS视频媒体服务器-docker启动：更换默认端口时的错误

SRS视频媒体服务器-docker启动：更换默认端口时的错误

一、概述 在使用srs视频服务器时，一直都是使用默认的端口配置。但是，这些默认端口在某些时候可能已经被占用了，就需要更改端口了。 注意注意注意：使用docker启动srs，在更换端口一定要下面的内容。 二、使用docker启动…
阅读更多...
MFC第三十天 通过CToolBar类开发文字工具栏和工具箱、GDI+边框填充以及基本图形的绘制方法、图形绘制过程的反色线模型和实色模型

MFC第三十天 通过CToolBar类开发文字工具栏和工具箱、GDI+边框填充以及基本图形的绘制方法、图形绘制过程的反色线模型和实色模型

文章目录 CControlBar通过CToolBar类开发文字工具栏和工具箱CMainFrame.hCAppCMainFrm.cppCMainView.hCMainView.cppCEllipse.hCEllipse.cppCLine.hCLine.cppCRRect .hCRRect .cpp CControlBar class AFX_NOVTABLE CControlBar : public CWnd{DECLARE_DYNAMIC(CControlBar)pro…
阅读更多...
Jmeter请求接口返回值乱码解决

Jmeter请求接口返回值乱码解决

乱码示例 解决步骤： 1.打开Jmeter安装目录下的bin目录，找到jmeter.properties 2.使用记事本或其他编译工具打开jmeter.properties文件，然后全局搜索sampleresult.default.encoding 3.在文件中添加sampleresult.default.encodingutf-8,保存…
阅读更多...
LeetCode--HOT100题（28）

LeetCode--HOT100题（28）

目录 题目描述：2. 两数相加（中等）题目接口解题思路代码 PS: 题目描述：2. 两数相加（中等） 给你两个 非空 的链表，表示两个非负的整数。它们每位数字都是按照 逆序 的方式存储的，并且…
阅读更多...
c语言每日一练(6)

c语言每日一练(6)

前言：每日一练系列，每一期都包含5道选择题，2道编程题，博主会尽可能详细地进行讲解，令初学者也能听的清晰。每日一练系列会持续更新，暑假时三天之内必有一更，到了开学之后，将看学业情…
阅读更多...
42. range函数—生成器函数-更新

42. range函数—生成器函数-更新

【目录】 文章目录 1. range( )函数是什么？2. 知识回顾-列表的切片3. range( )函数的语法3.1 range( )函数语法3.2 参数说明3.3 列表切片和range函数的区别 4. 实操练习4.1 参数为一个正整数4.2 参数为04.3 参数为一个负整数4.4 有2个参数4.5 有3个参数4.6 步长为负…
阅读更多...
vscode extension 怎么区分dev prod

vscode extension 怎么区分dev prod

开发模式注入环境变量 使用vsode 提供的api
阅读更多...
利用Torchmetrics库快速进行Torch的评价指标计算（推荐）

利用Torchmetrics库快速进行Torch的评价指标计算（推荐）

目录 1、安装 2、基本流程介绍 3、MetricCollection 4、自定义指标 5、我们可以调用多个指标计算不同的任务 6、可以是标签，也可以是one_hot编码 7、常用分类指标计算 8、异常报错 1、安装 官网地址：Welcome to TorchMetrics — PyTorch-Metrics 1.0.1 documenta…
阅读更多...
掌握Python的X篇_34_Python朗读文字

掌握Python的X篇_34_Python朗读文字

各种广告中说python是人工智能的主宰，其实这更多是噱头的成分，但是python确实可以做很多的事情，本篇将会介绍利用pythonAI平台来合成声音。今天将会用到的是百度。 文章目录 1. baiToVoice2. 注册appid3. 合成代码 1. baiToVoice 使用百度A…
阅读更多...
最新文章

Copyright @ 2022~2023