【学习日记】【FreeRTOS】空闲任务与阻塞延时

写在前面

本文是基于野火 RTOS 教程对空闲任务和阻塞延时的详解。

一、什么是任务中的阻塞延时

  • 说到阻塞延时,笔者的第一反应就是在单片机的 while 循环中,使用一个 for 循环不断递减一个大数,通过 CPU 不断执行一条指令的耗时进行延时。这种延时会占用 CPU 资源执行指令,在延时的时候 CPU 不能执行其他的指令。
  • 但是注意,我们现在是想在 RTOS 中的任务实现阻塞延时,RTOS 可以有多个任务,所有所谓任务中的阻塞延时虽然也是阻塞其后的代码运行,但是只阻塞了他所在的那个任务中阻塞延时函数后面的代码。
  • 也就是说,RTOS 中,任务中的阻塞延时就是先阻塞一下这个任务,然后把 CPU 使用权交给其他代码,虽然也是阻塞下文的代码执行,但是只阻塞这个任务的下文,CPU 在这个过程中可以执行其他任务中的指令,大大提高 CPU 利用率,和笔者印象中的阻塞延时并不一样。

二、空闲任务有什么用

  • 空闲任务的优先级是所有任务中优先级最低的,当其他任务都在阻塞延时中,CPU 就会切换到空闲任务运行。
  • 一般来说在空闲任务里面运行一些系统内存的清理工作,或者在空闲任务中让单片机休眠或者进入低功耗模式。

三、空闲任务的实现

  1. 定义空闲任务的任务栈
  2. 定义空闲任务的 TCB
  3. 空闲任务的创建

注意,空闲任务的任务栈和 TCB 变量我们都在 main.c 中声明为全局变量,但是同时,我们想在开启任务调度器的时候自动创建一个空闲任务,而 RTOS 的开发人员不用显式地去创建空闲任务,所以我们把空闲任务的创建集成在 void vTaskStartScheduler( void ) 这个函数中。这样,我们在启动调度器的同时就会自动创建一个空闲任务。代码如下:

void vTaskStartScheduler( void )
{
/*======================================创建空闲任务start==============================================*/     TCB_t *pxIdleTaskTCBBuffer = NULL;               /* 用于指向空闲任务控制块 */StackType_t *pxIdleTaskStackBuffer = NULL;       /* 用于空闲任务栈起始地址 */uint32_t ulIdleTaskStackSize;/* 获取空闲任务的内存:任务栈和任务TCB */vApplicationGetIdleTaskMemory( &pxIdleTaskTCBBuffer, &pxIdleTaskStackBuffer, &ulIdleTaskStackSize );    xIdleTaskHandle = xTaskCreateStatic( (TaskFunction_t)prvIdleTask,              /* 任务入口 */(char *)"IDLE",                           /* 任务名称,字符串形式 */(uint32_t)ulIdleTaskStackSize ,           /* 任务栈大小,单位为字 */(void *) NULL,                            /* 任务形参 */(StackType_t *)pxIdleTaskStackBuffer,     /* 任务栈起始地址 */(TCB_t *)pxIdleTaskTCBBuffer );           /* 任务控制块 *//* 将任务添加到就绪列表 */                                 vListInsertEnd( &( pxReadyTasksLists[0] ), &( ((TCB_t *)pxIdleTaskTCBBuffer)->xStateListItem ) );
/*======================================创建空闲任务end================================================*//* 手动指定第一个运行的任务 */pxCurrentTCB = &Task1TCB;/* 初始化系统时基计数器 */xTickCount = ( TickType_t ) 0U;/* 启动调度器 */if( xPortStartScheduler() != pdFALSE ){/* 调度器启动成功,则不会返回,即不会来到这里 */}
}

上面这段代码调用了 xTaskCreateStatic() 这个函数进行空闲任务的创建,但是这个函数需要传入空闲任务的任务栈和 TCB 变量,而我们把这些变量定义在了 main.c 中,所以需要使用 vApplicationGetIdleTaskMemory() 这个函数来使 vTaskStartScheduler() 函数中的任务指针等等变量指向定义在 main.c 中的任务栈和 TCB,然后再把这些任务指针等传入 xTaskCreateStatic() 中。vApplicationGetIdleTaskMemory() 的具体代码如下:

void vApplicationGetIdleTaskMemory( TCB_t **ppxIdleTaskTCBBuffer, StackType_t **ppxIdleTaskStackBuffer, uint32_t *pulIdleTaskStackSize )
{*ppxIdleTaskTCBBuffer=&IdleTaskTCB;*ppxIdleTaskStackBuffer=IdleTaskStack; *pulIdleTaskStackSize=configMINIMAL_STACK_SIZE;
}

四、任务中的阻塞延时怎么实现

具体想法如下:

  1. 为 TCB 添加记录延时时间的参数
  2. 在任务中调用阻塞延时函数时,会给 TCB 记录延时时间的参数进行赋值,然后调用任务切换函数
  3. 调用任务切换函数会产生 PendSV 中断,在 PendSV中断服务函数中会调用上下文切换函数 vTaskSwitchContext()
  4. 在上下文切换函数中,我们更新当前执行任务的指针。现在我们的思想是,如果当前任务是空闲任务,那么查看其他任务的延时是否结束,如果没有结束就继续执行空闲任务;如果当前执行的不是空闲任务,那么检查一下其他任务是否在延时中,如果不在延时中,就不忘初心进行任务切换,如果在延时中,就判断现在这个任务是否要延时,如果要延时就切换到空闲任务,否则就不进行任何切换。
  5. 上面检查任务是否在延时状态都是通过检查 TCB 的延时参数是否为 0 来实现的,我们使用 SysTick 中断来对 TCB 的延时参数进行定时修改
  6. 在每次 SysTick 中断触发时,我们更新一下系统时基计数器(以后有用),然后扫描一下就绪列表中所有 TCB 的延时参数,不为 0 就减 1,最后尝试任务切换

1. 为 TCB 添加记录延时时间的参数

typedef struct tskTaskControlBlock
{volatile StackType_t    *pxTopOfStack;    /* 栈顶 */ListItem_t			    xStateListItem;   /* 任务节点 */StackType_t             *pxStack;         /* 任务栈起始地址 *//* 任务名称,字符串形式 */char                    pcTaskName[ configMAX_TASK_NAME_LEN ];  TickType_t xTicksToDelay; /* 用于延时 */
} tskTCB;
typedef tskTCB TCB_t;

2. 阻塞延时函数 vTaskDelay()

给 TCB 记录延时时间的参数进行赋值,然后调用任务切换函数。

void vTaskDelay( const TickType_t xTicksToDelay )
{TCB_t *pxTCB = NULL;/* 获取当前任务的TCB */pxTCB = pxCurrentTCB;/* 设置延时时间 */pxTCB->xTicksToDelay = xTicksToDelay;/* 任务切换 */taskYIELD();
}

3. 上下文切换函数 vTaskSwitchContext()

  • 如果当前任务是空闲任务
    • 查看其他任务的延时是否结束
      • 没有结束 -> 继续执行空闲任务
      • 结束 -> 跳转到其他任务
  • 如果当前执行的不是空闲任务
    • 检查一下其他任务是否在延时中
      • 不在延时中 -> 进行任务切换
      • 在延时中 -> 判断现在这个任务是否要延时
        • 要延时就切换到空闲任务
        • 否则就不进行任何切换
void vTaskSwitchContext( void )
{/* 如果当前线程是空闲线程,那么就去尝试执行线程1或者线程2,看看他们的延时时间是否结束,如果线程的延时时间均没有到期,那就返回继续执行空闲线程 */if( pxCurrentTCB == &IdleTaskTCB ){if(Task1TCB.xTicksToDelay == 0){            pxCurrentTCB =&Task1TCB;}else if(Task2TCB.xTicksToDelay == 0){pxCurrentTCB =&Task2TCB;}else{return;		/* 线程延时均没有到期则返回,继续执行空闲线程 */} }else{/*如果当前线程是线程1或者线程2的话,检查下另外一个线程,如果另外的线程不在延时中,就切换到该线程否则,判断下当前线程是否应该进入延时状态,如果是的话,就切换到空闲线程。否则就不进行任何切换 */if(pxCurrentTCB == &Task1TCB){if(Task2TCB.xTicksToDelay == 0){pxCurrentTCB =&Task2TCB;}else if(pxCurrentTCB->xTicksToDelay != 0){pxCurrentTCB = &IdleTaskTCB;}else {return;		/* 返回,不进行切换,因为两个线程都处于延时中 */}}else if(pxCurrentTCB == &Task2TCB){if(Task1TCB.xTicksToDelay == 0){pxCurrentTCB =&Task1TCB;}else if(pxCurrentTCB->xTicksToDelay != 0){pxCurrentTCB = &IdleTaskTCB;}else {return;		/* 返回,不进行切换,因为两个线程都处于延时中 */}}}
}

4. SysTick 中断对 TCB 的延时参数进行定时修改

/*
*************************************************************************
*                             SysTick中断服务函数
*************************************************************************
*/
void xPortSysTickHandler( void )
{/* 关中断 */vPortRaiseBASEPRI();/* 更新系统时基 */xTaskIncrementTick();/* 开中断 */vPortClearBASEPRIFromISR();
}

每次 SysTick 中断触发时,我们更新一下系统时基计数器(以后有用),然后扫描一下就绪列表中所有 TCB 的延时参数,不为 0 就减 1,最后尝试任务切换:

void xTaskIncrementTick( void )
{TCB_t *pxTCB = NULL;BaseType_t i = 0;/* 更新系统时基计数器xTickCount,xTickCount是一个在port.c中定义的全局变量 */const TickType_t xConstTickCount = xTickCount + 1;xTickCount = xConstTickCount;/* 扫描就绪列表中所有线程的xTicksToDelay,如果不为0,则减1 */for(i=0; i<configMAX_PRIORITIES; i++){pxTCB = ( TCB_t * ) listGET_OWNER_OF_HEAD_ENTRY( ( &pxReadyTasksLists[i] ) );if(pxTCB->xTicksToDelay > 0){pxTCB->xTicksToDelay --;}}/* 任务切换 */portYIELD();
}

关于上面这段代码,有一段写得很奇怪:

    /* 更新系统时基计数器xTickCount,xTickCount是一个在port.c中定义的全局变量 */const TickType_t xConstTickCount = xTickCount + 1;xTickCount = xConstTickCount;

笔者刚开始看到的时候想问:直接递增xTickCount不行吗,为什么要写成
const TickType_t xConstTickCount = xTickCount + 1;
xTickCount = xConstTickCount;
这样不是画蛇添足吗?使代码更复杂。

其实不然,在任务调度器中,xTickCount 变量用于记录系统的时基计数器。它的目的是跟踪系统运行的时间,并且根据需要递增。

直接递增 xTickCount 可能会导致并发问题。在多线程或多任务的情况下,如果有多个任务同时尝试递增 xTickCount,并且中间存在竞争条件,可能会导致计数不准确或不一致。

为了避免这种并发问题,代码中将递增操作分解为两个步骤:

首先,通过 const TickType_t xConstTickCount = xTickCount + 1; 将 xTickCount 的值复制到一个中间变量 xConstTickCount 中,并递增这个中间变量。

然后,将中间变量 xConstTickCount 的值赋回给 xTickCount,完成递增操作。

这样做的好处是,无论何时进行递增操作,代码都使用了一个稳定的中间值 xConstTickCount 来执行计算和更新。这确保了计数器 xTickCount 在整个递增过程中保持一致,并且不会受到其他任务的干扰。这样可以避免并发问题,提高代码的可靠性和正确性。

5. 最后是 SysTick 的相关初始化代码

在调度器启动函数 xPortStartScheduler() 函数中调用 vPortSetupTimerInterrupt():

/*
*************************************************************************
*                              调度器启动函数
*************************************************************************
*/BaseType_t xPortStartScheduler( void )
{/*PendSV是一个用于低优先级任务切换的软件中断。通过触发PendSV中断,可以请求处理器在合适的时间切换到更高优先级的任务。PendSV中断具有最低的中断优先级,因此可以在其他中断处理完成后立即执行。*//* 配置PendSV 和 SysTick 的中断优先级为最低 */portNVIC_SYSPRI2_REG |= portNVIC_PENDSV_PRI;portNVIC_SYSPRI2_REG |= portNVIC_SYSTICK_PRI;//初始化SysTick中断vPortSetupTimerInterrupt();/* 启动第一个任务,不再返回 */prvStartFirstTask();/* 不应该运行到这里 */return 0;
}

初始化 SysTick 的函数 vPortSetupTimerInterrupt():

/*
*************************************************************************
*                             初始化SysTick
*************************************************************************
*/
void vPortSetupTimerInterrupt( void )
{/* 设置重装载寄存器的值 */portNVIC_SYSTICK_LOAD_REG = ( configSYSTICK_CLOCK_HZ / configTICK_RATE_HZ ) - 1UL;/* 设置系统定时器的时钟等于内核时钟使能SysTick 定时器中断使能SysTick 定时器 */portNVIC_SYSTICK_CTRL_REG = ( portNVIC_SYSTICK_CLK_BIT | portNVIC_SYSTICK_INT_BIT |portNVIC_SYSTICK_ENABLE_BIT ); 
}

这里解释一下重装载寄存器的值怎么设置。计时器实际上是一个计数器,当接收到设定数量的脉冲后进行一次中断,而这个设定的数量就是重装载寄存器的值。

我们把计时器接入到 CPU 晶振后,由于晶振每隔一段固定时间发出一个脉冲信号,此时计时器就将重装载寄存器的值减 1,当重装载寄存器的值减到 0 后,就触发一次中断,由此完成了对晶振的高频率信号的分频。

注意,重装载寄存器的值是从 0 开始减的,所以设置时要减 1。

可以看到,我们使用 configSYSTICK_CLOCK_HZ / configTICK_RATE_HZ ) - 1UL 进行设置,configSYSTICK_CLOCK_HZ 实际上就是 CPU 的晶振频率,而 configTICK_RATE_HZ 就是我们设置 SysTick 的中断频率。

其中的宏定义为:

#define configCPU_CLOCK_HZ			( ( unsigned long ) 25000000 )	
#define configTICK_RATE_HZ			( ( TickType_t ) 100 )/* SysTick 配置寄存器 */
#define portNVIC_SYSTICK_CTRL_REG			( * ( ( volatile uint32_t * ) 0xe000e010 ) )
#define portNVIC_SYSTICK_LOAD_REG			( * ( ( volatile uint32_t * ) 0xe000e014 ) )#ifndef configSYSTICK_CLOCK_HZ#define configSYSTICK_CLOCK_HZ configCPU_CLOCK_HZ/* 确保SysTick的时钟与内核时钟一致 */#define portNVIC_SYSTICK_CLK_BIT	( 1UL << 2UL )
#else#define portNVIC_SYSTICK_CLK_BIT	( 0 )
#endif#define portNVIC_SYSTICK_INT_BIT			( 1UL << 1UL )
#define portNVIC_SYSTICK_ENABLE_BIT			( 1UL << 0UL )

后记

如果您觉得本文写得不错,可以点个赞激励一下作者!
如果您发现本文的问题,欢迎在评论区或者私信共同探讨!
共勉!

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

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

相关文章

python优雅地爬虫!

背景 我需要获得新闻&#xff0c;然后tts&#xff0c;在每天上班的路上可以听一下。具体的方案后期我也会做一次分享。先看我喜欢的万能的老路&#xff1a;获得html内容-> python的工具库解析&#xff0c;获得元素中的内容&#xff0c;完成。 好家伙&#xff0c;我知道我爬…

视频云存储/安防监控/视频汇聚EasyCVR平台新增设备经纬度选取

视频云存储/安防监控EasyCVR视频汇聚平台基于云边端智能协同&#xff0c;支持海量视频的轻量化接入与汇聚、转码与处理、全网智能分发、视频集中存储等。音视频流媒体视频平台EasyCVR拓展性强&#xff0c;视频能力丰富&#xff0c;具体可实现视频监控直播、视频轮播、视频录像、…

公网远程连接Redis数据库「内网穿透」

文章目录 1. Linux(centos8)安装redis数据库2. 配置redis数据库3. 内网穿透3.1 安装cpolar内网穿透3.2 创建隧道映射本地端口 4. 配置固定TCP端口地址4.1 保留一个固定tcp地址4.2 配置固定TCP地址4.3 使用固定的tcp地址连接 前言 洁洁的个人主页 我就问你有没有发挥&#xff0…

蓝牙资讯|苹果Apple Watch可手势操控Mac和Apple TV等设备

根据美国商标和专利局&#xff08;USPTO&#xff09;公示的清单&#xff0c;苹果公司近日获得了一项技术专利&#xff0c;概述了未来的 Apple Watch 手表&#xff0c;使用手势等操控 Mac 和 Apple TV 等设备。 该专利描述未来 Apple Watch 可以交互实现编辑图像、绘图、处理文…

02:STM32--EXTI外部中断

目录 一:中断 1:简历 2:AFIO 3:EXTI ​编辑 4:NVIC基本结构 5:使用步骤 二:中断的应用 A:对外式红外传感计数器 1:连接图​编辑 2:函数介绍 3:硬件介绍 4:计数代码 B;旋转编码计数器 1:连接图 2:硬件介绍 3:旋转编码器代码: 一:中断 1:简历 中断&#xff1a;在主程…

Flutter 测试小结

Flutter 项目结构 pubspec.yaml 类似于 RN 的 package.json&#xff0c;该文件分别在最外层及 example 中有&#xff0c;更新该文件后&#xff0c;需要执行的 Pub get lib 目录下的 dart 文件为 Flutter 插件封装后的接口源码&#xff0c;方便在其他 dart 文件中调用 example 目…

python通过S7协议读取西门子200smart数据

发现网上很多关于python通过s7协议控制200smart的代码都失败&#xff0c;我猜应该是版本的问题。自己捣鼓了半天&#xff0c;终于测试成功 from snap7 import util,clientmy_plc client.Client() #建立一个客户端对象 my_plc.set_connection_type(3) #如果是200smart,必须有此…

Flink流批一体计算(14):PyFlink Tabel API之SQL查询

举个例子 查询 source 表&#xff0c;同时执行计算 # 通过 Table API 创建一张表&#xff1a; source_table table_env.from_path("datagen") # 或者通过 SQL 查询语句创建一张表&#xff1a; source_table table_env.sql_query("SELECT * FROM datagen&quo…

QT实现天气预报

1. MainWindow类设计的成员变量和方法 public: MainWindow(QWidget* parent nullptr); ~MainWindow(); protected: 形成文本菜单来用来右键关闭窗口 void contextMenuEvent(QContextMenuEvent* event); 鼠标被点击之后此事件被调用 void mousePressEvent(QMouseEv…

Leetcode每日一题:1444. 切披萨的方案数(2023.8.17 C++)

目录 1444. 切披萨的方案数 题目描述&#xff1a; 实现代码与解析&#xff1a; 二维后缀和 动态规划 原理思路&#xff1a; 1444. 切披萨的方案数 题目描述&#xff1a; 给你一个 rows x cols 大小的矩形披萨和一个整数 k &#xff0c;矩形包含两种字符&#xff1a; A …

Spring(三):Spring中Bean的生命周期和作用域

前言 在 Spring 中&#xff0c;那些组成应用程序的主体及由 Spring IOC 容器所管理的对象&#xff0c;被称之为 bean。简单地讲&#xff0c;bean 就是由 IOC 容器初始化、装配及管理的对象&#xff0c;除此之外&#xff0c;bean 就与应用程序中的其他对象没有什么区别了。而 b…

Oracle数据库运维大全

以下是一些常见的Oracle数据库运维任务和对应的语句脚本示例&#xff1a; 检查数据库实例状态&#xff1a; SELECT instance_name, status, startup_time FROM v$instance; 查看数据库版本和补丁级别&#xff1a; SELECT * FROM v$version; SELECT patch_id, action, status …

LeetCode 热题 100(四):48. 旋转图像、240. 搜索二维矩阵 II、234. 回文链表

一.48. 旋转图像 题目要求&#xff1a;就是一个顺时针的旋转过程。 思路&#xff1a;观察矩阵&#xff0c;得出翻转前第i行的第J个元素 等于 翻转后倒数第i列的第J个元素&#xff0c;举例说明&#xff0c;第1行第2个元素为“2”&#xff0c;翻转后到了 倒数第1列的第2个元素…

MAC环境,在IDEA执行报错java: -source 1.5 中不支持 diamond 运算符

Error:(41, 51) java: -source 1.5 中不支持 diamond 运算符 (请使用 -source 7 或更高版本以启用 diamond 运算符) 进入设置 修改java版本 pom文件中加入 <plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin&l…

vue项目预览pdf功能(解决动态文字无法显示的问题)

最近&#xff0c;因为公司项目需要预览pdf的功能&#xff0c;开始的时候找了市面上的一些pdf插件&#xff0c;都能用&#xff0c;但是&#xff0c;后面因为pdf变成了需要根据内容进行变化的&#xff0c;然后&#xff0c;就出现了需要动态生成的文字不显示了。换了好多好多的插件…

Flink安装与使用

1.安装准备工作 下载flink Apache Flink: 下载 解压 [dodahost166 bigdata]$ tar -zxvf flink-1.12.0-bin-scala_2.11.tgz 2.Flinnk的standalone模式安装 2.1修改配置文件并启动 修改&#xff0c;好像使用默认的就可以了 [dodahost166 conf]$ more flink-conf.yaml 启动 …

【办公自动化】使用Python批量生成PPT版荣誉证书

&#x1f935;‍♂️ 个人主页&#xff1a;艾派森的个人主页 ✍&#x1f3fb;作者简介&#xff1a;Python学习者 &#x1f40b; 希望大家多多支持&#xff0c;我们一起进步&#xff01;&#x1f604; 如果文章对你有帮助的话&#xff0c; 欢迎评论 &#x1f4ac;点赞&#x1f4…

RocketMQ消费者可以手动消费但无法主动消费问题,或生成者发送超时

1.大多数是配置问题 修改rocketmq文件夹broker.conf 2.配置与集群IP或本地IPV4一样 重启 在RocketMQ独享实例中支持IPv4和IPv6双栈&#xff0c;主要是通过在网络层面上同时支持IPv4和IPv6协议栈来实现的。RocketMQ的Broker端、Namesrv端和客户端都需要支持IPv4和IPv6协议&…

Python土力学与基础工程计算.PDF-螺旋板载荷试验

python 求解代码如下&#xff1a; 1. import numpy as np 2. 3. # 已知参数 4. p_a 100 # 标准压力&#xff0c; kPa 5. p np.array([25, 50, 100, 200) # 荷载&#xff0c; kPa 6. s np.array([2.88, 5.28, 9.50, 15.00) / 10 # 沉降量&#xff0c; cm 7. D 10 # 螺旋板直…

C语言:选择+编程(每日一练)

目录 选择题&#xff1a; 题一&#xff1a; 题二&#xff1a; 题三&#xff1a; 题四&#xff1a; 题五&#xff1a; 编程题&#xff1a; 题一&#xff1a;尼科彻斯定理 示例1 题二&#xff1a;等差数列 示例2 本人实力有限可能对一些地方解释和理解的不够清晰&…