FreeRTOS队列之向队列发送消息

2024-05-28 05:04

本文主要是介绍FreeRTOS队列之向队列发送消息,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

本篇文章记录我学习FreeRTOS队列相关的知识,主要是关于向队列发送消息的部分。

一、函数原型

创建好队列以后就可以向队列发送消息了,FreeRTOS提供了8个向队列发送消息的API函数。

1、函数xQueueSend()、xQueueSendToBack()和xQueueSendToFront()

这三个函数都是用于向队列中发送消息的,这三个函数本质都是宏,其中函数xQueueSend()和xQueueSendToBack()是一样的,都是后向入队,即将新的消息插入到队列的后面。函数xQueueSendToToFront()是前向入队,即将新消息插入到队列的前面。然而!这三个函数最后都是调用的同一个函数: xQueueGenericSend()。这三个函数只能用于任务函数中,不能用于中断服务函数,中断服务函数有专用的函数,它们以“FromISR”结尾,这三个函数的原型如下:

参数:

 返回值:

 2、函数xQueueOverwrite()

此函数也是用于向队列发送数据的,当队列满了以后会覆写掉旧的数据,不管这个旧数据有没有被其他任务或中断取走。这个函数常用于向那些长度为1的队列发送消息,此函数也是一个宏,最终调用的也是函数xQueueGenericSend(),函数原型如下:

3、函数xQueueGenericSend()

此函数才是真正干活的,上面讲的所有的任务级入队函数最终都是调用的此函数,此函数也是我们后面重点要讲解的,先来看一下函数原型:

4、函数xQueueSendFromISR()、
xQueueSendToBackFromISR()、
xQueueSendToFrontFromISR()

这三个函数也是向队列中发送消息的,这三个函数用于中断服务函数中。这三个函数本质也是宏,其中函数xQueueSendFromISR ()和xQueueSendToBackFromISR ()是一样的,都是后向入队,即将新的消息插入到队列的后面。函数xQueueSendToFrontFromISR()是前向入队,即将新消息插入到队列的前面。这三个函数同样调用同一个函数xQueueGenericSendFromISR()。这三个函数的原型如下:

我们注意观察,可以看出这些函数都没有设置阻塞时间值。原因很简单,这些函数都是在中断服务函数中调用的,并不是在任务中,所以也就没有阻塞这一说了!

 5、函数xQueueOverwriteFromISR()

此函数是xQueueOverwrite()的中断级版本,用在中断服务函数中,在队列满的时候自动覆写掉旧的数据,此函数也是一个宏,实际调用的也是函数xQueueGenericSendFromISR(),此函数原型如下:

此函数的参数和返回值同上面三个函数相同。

6、函数xQueueGenericSendFromISR()

上面说了4个中断级入队函数最终都是调用的函数xQueueGenericSendFromISR(),这是真正干活的主啊,也是我们下面会详细讲解的函数,先来看一下这个函数的原型,如下:

二、任务级通用入队函数

不管是后向入队、前向入队还是覆写入队,最终调用的都是通用入队函数xQueueGenericSend(),这个函数在文件queue.c文件中由定义,缩减后的函数代码如下:

(1)、要向队列发送数据,肯定要先检查一下队列是不是满的,如果是满的话肯定不能发送的。当队列未满或者是覆写入队的话就可以将消息入队了。


(2)、调用函数prvCopyDataToQueue()将消息拷贝到队列中。前面说了入队分为后向入队、前向入队和覆写入队,他们的具体实现就是在函数 prvCopyDataToQueue()中完成的。如果选择后向入队queueSEND_TO_BACK 的话就将消息拷贝到队列结构体成员 pcWriteTo 所指向的队列项,拷贝成功以后pcWriteTo增加 uxItemSize个字节,指向下一个队列项目。当选择前向入队queueSEND_TO_FRONT或者queueOVERWRITE的话就将消息拷贝到u.pcReadFrom所指向的队列项目,同样的需要调整u.pcReadFrom的位置。当向队列写入一个消息以后队列中统计当前消息数量的成员uxMessagesWaiting就会加一,但是选择覆写入队queueOVERWRITE的话还会将uxMessagesWaiting 减一,这样一减一加相当于队列当前消息数量没有变。

(3)、检查是否有任务由于请求队列消息而阻塞,阻塞的任务会挂在队列的xTasksWaitingToReceive列表上。
(4)、有任务由于请求消息而阻塞,因为在(2)中已将向队列中发送了一条消息了,所以调用函数xTaskRemoveFromEventList()将阻塞的任务从列表xTasksWaitingToReceive上移除,并且把这个任务添加到就绪列表中,如果调度器上锁的话这些任务就会挂到列表xPendingReadyList 上。如果取消阻塞的任务优先级比当前正在运行的任务优先级高还要标记需要进行任务切换。当函数xTaskRemoveFromEventList()返回值为pdTRUE的话就需要进行任务切换。


(5)、进行任务切换。
(6)、返回pdPASS,标记入队成功。


(7)、(2)到(6)都是非常理想的效果,即消息队列未满,入队没有任何障碍。但是队列满了以后呢?首先判断设置的阻塞时间是否为0,如果为О的话就说明没有阻塞时间。
(8)、由(7)得知阻塞时间为0,那就直接返回errQUEUE_FULL,标记队列已满就可以了。(9)、如果阻塞时间不为0并且时间结构体还没有初始化的话就初始化一次超时结构体变量,调用函数 vTaskSetTimeOutState()完成超时结构体变量xTimeOut 的初始化。其实就是记录当前的系统时钟节拍计数器的值 xTickCount和溢出次数xNumOfOverflows。


(10)、任务调度器上锁,代码执行到这里说明当前的状况是队列已满了,而且设置了不为0的阻塞时间。那么接下来就要对任务采取相应的措施了,比如将任务加入到队列的xTasksWaitingToSend列表中。
(11)、调用函数 prvLockQueue()给队列上锁,其实就是将队列中的成员变量cRxLock 和cTxLock 设置为queueLOCKED_UNMODIFIED。
(12)、调用函数xTaskCheckForTimeOut()更新超时结构体变量xTimeOut,并且检查阻塞时
间是否到了。
(13)、阻塞时间还没到,那就检查队列是否还是满的。
(14)、经过(12)和(13)得出阻塞时间没到,而且队列依旧是满的,那就调用函数vTaskPlaceOnEventList()将任务添加到队列的xTasksWaitingToSend 列表中和延时列表中,并且将任务从就绪列表中移除。注意!如果阻塞时间是 portMAX_DELAY并且宏INCLUDE_vTaskSuspend 为 1的话,函数 vTaskPlaceOnEventList()会将任务添加到列表xSuspendedTaskList 上。
(15)、操作完成,调用函数prvUnlockQueue()解锁队列。(16)、调用函数xTaskResumeAll)恢复任务调度器
(17)、阻塞时间还没到,但是队列现在有空闲的队列项,那么就在重试一次。
(18)、相比于第(12)步,阻塞时间到了!那么任务就不用添加到那些列表中了,那就解锁队列,恢复任务调度器。
(19)、返回errQUEUE_FULL,表示队列满了。

三、中断级通用入队函数

(1)、队列未满或者采用的覆写的入队方式,这是最理想的壮态。

(2)、读取队列的成员变量xTxLock,用于判断队列是否上锁。

(3)、将数据拷贝到队列中。
(4)、队列上锁了,比如任务级入队函数在操作队列中的列表的时候就会对队列上锁。
(5)、判断队列列表xTasksWaitingToReceive是否为空,如果不为空的话说明有任务在请求消息的时候被阻塞了。
(6)、将相应的任务从列表xTasksWaitingToReceive 上移除。跟任务级入队函数处理过程一样。
(7)、如果刚刚从列表xTasksWaitingToReceive 中移陈的仕分仇九纵比三里#元L冬i将那么标记pxHigherPriorityTaskWoken为pdTRUE,表示要进行任务切换。如果要进行任务切换
的话就需要在退出此函数以后,退出中断服务函数之前进行一次任务切换。
(8)、如果队列上锁的话那就将队列成员变量cTxLock 加一,农水进付」一次八队探IF,L队列解锁(prvUnlockQueue())的时候会对其做相应的处理。
(9)、返回pdPASS,表示入队完成。
(10)、如果队列满的话就直接返回errQUEUE_FULL,表示队列满。

这篇关于FreeRTOS队列之向队列发送消息的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1009609

相关文章

SpringKafka错误处理(重试机制与死信队列)

《SpringKafka错误处理(重试机制与死信队列)》SpringKafka提供了全面的错误处理机制,通过灵活的重试策略和死信队列处理,下面就来介绍一下,具有一定的参考价值,感兴趣的可以了解一下... 目录引言一、Spring Kafka错误处理基础二、配置重试机制三、死信队列实现四、特定异常的处理策略五

在Android平台上实现消息推送功能

《在Android平台上实现消息推送功能》随着移动互联网应用的飞速发展,消息推送已成为移动应用中不可或缺的功能,在Android平台上,实现消息推送涉及到服务端的消息发送、客户端的消息接收、通知渠道(... 目录一、项目概述二、相关知识介绍2.1 消息推送的基本原理2.2 Firebase Cloud Me

SpringKafka消息发布之KafkaTemplate与事务支持功能

《SpringKafka消息发布之KafkaTemplate与事务支持功能》通过本文介绍的基本用法、序列化选项、事务支持、错误处理和性能优化技术,开发者可以构建高效可靠的Kafka消息发布系统,事务支... 目录引言一、KafkaTemplate基础二、消息序列化三、事务支持机制四、错误处理与重试五、性能优

SpringIntegration消息路由之Router的条件路由与过滤功能

《SpringIntegration消息路由之Router的条件路由与过滤功能》本文详细介绍了Router的基础概念、条件路由实现、基于消息头的路由、动态路由与路由表、消息过滤与选择性路由以及错误处理... 目录引言一、Router基础概念二、条件路由实现三、基于消息头的路由四、动态路由与路由表五、消息过滤

如何使用C#串口通讯实现数据的发送和接收

《如何使用C#串口通讯实现数据的发送和接收》本文详细介绍了如何使用C#实现基于串口通讯的数据发送和接收,通过SerialPort类,我们可以轻松实现串口通讯,并结合事件机制实现数据的传递和处理,感兴趣... 目录1. 概述2. 关键技术点2.1 SerialPort类2.2 异步接收数据2.3 数据解析2.

Windows server服务器使用blat命令行发送邮件

《Windowsserver服务器使用blat命令行发送邮件》在linux平台的命令行下可以使用mail命令来发送邮件,windows平台没有内置的命令,但可以使用开源的blat,其官方主页为ht... 目录下载blatBAT命令行示例备注总结在linux平台的命令行下可以使用mail命令来发送邮件,Win

使用Java发送邮件到QQ邮箱的完整指南

《使用Java发送邮件到QQ邮箱的完整指南》在现代软件开发中,邮件发送功能是一个常见的需求,无论是用户注册验证、密码重置,还是系统通知,邮件都是一种重要的通信方式,本文将详细介绍如何使用Java编写程... 目录引言1. 准备工作1.1 获取QQ邮箱的SMTP授权码1.2 添加JavaMail依赖2. 实现

Qt实现发送HTTP请求的示例详解

《Qt实现发送HTTP请求的示例详解》这篇文章主要为大家详细介绍了如何通过Qt实现发送HTTP请求,文中的示例代码讲解详细,具有一定的借鉴价值,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1、添加network模块2、包含改头文件3、创建网络访问管理器4、创建接口5、创建网络请求对象6、创建一个回复对

Spring Boot整合消息队列RabbitMQ的实现示例

《SpringBoot整合消息队列RabbitMQ的实现示例》本文主要介绍了SpringBoot整合消息队列RabbitMQ的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的... 目录RabbitMQ 简介与安装1. RabbitMQ 简介2. RabbitMQ 安装Spring

springboot rocketmq配置生产者和消息者的步骤

《springbootrocketmq配置生产者和消息者的步骤》本文介绍了如何在SpringBoot中集成RocketMQ,包括添加依赖、配置application.yml、创建生产者和消费者,并展... 目录1. 添加依赖2. 配置application.yml3. 创建生产者4. 创建消费者5. 使用在