OpenHarmony 实战开发——内核对象队列之算法详解

前言

OpenAtom OpenHarmony(以下简称“OpenHarmony”) LiteOS-M 内核是面向 IoT 领域构建的轻量级物联网操作系统内核,具有小体积、低功耗、高性能的特点。在嵌入式领域的开发工作中,无论是自研还是移植系统,均绕不开内核,开发者只有掌握内核的相关知识,才能更好地深耕物联网产品领域。OpenHarmony LiteOS-M内核对象队列的算法包括FIFO和FILO,在上一期发布的《OpenHarmony-内核对象队列之算法详解(上)》文章中,我分享了OpenHarmonyLiteOS-M内核对象队列的FIFO的算法,今天给大家介绍另外一种算法——FILO算法。

关键数据结构

首先关注队列的关键数据结构LosQueueCB,有了这个数据,才能理解队列是如何工作的:

typedef struct {UINT8 queue;      /< 消息队列内存区域的指针/UINT16 queueState; /*< 消息队列状态 /UINT16 queueLen;   /*< 消息队列状态个数 /UINT16 queueSize;  /*< 每个消息节点大小 /UINT16 queueID;    /*< 消息身份 /UINT16 queueHead;  /*< 消息队列的头部/UINT16 queueTail;  /*< 消息队列的尾部 /UINT16 readWriteableCnt[OS_READWRITE_LEN];  /*< 消息节点循环队列中读或写的消息个数/LOS_DL_LIST readWriteList[OS_READWRITE_LEN]; /*< 读或写消息阻塞链表/LOS_DL_LIST memList; /*< Pointer to the memory linked list /}LosQueueCB;

queue:指向消息节点内存区域,创建队列时按照消息节点个数乘每个节点大小从动态内存池中申请一片空间。

queueState:队列状态,表明队列控制块是否被使用,有OS_QUEUE_INUSED和OS_QUEUE_UNUSED两种状态。

queueLen:消息节点个数,表示该消息队列最大可存储多少个消息。

queueSize:每个消息节点大小,表示队列每个消息可存储信息的大小。

queueID:消息ID,通过它来操作队列。

消息节点按照循环队列的方式访问,队列中的每个节点以数组下标表示,下面的成员与消息节点循环队列有关:

queueHead:循环队列的头部。

queueTail:循环队列的尾部。

readWriteableCnt[OS_QUEUE_WRITE]:消息节点循环队列中可写的消息个数,为0表示循环队列为满,等于queueLen表示循环队列为空。

readWriteableCnt[OS_QUEUE_READ]:消息节点循环队列中可读的消息个数,为0表示循环队列为空,等于queueLen表示消息队列为满。 readWriteList[OS_QUEUE_WRITE]:写消息阻塞链表,链接因消息队列满而无法写入时需要挂起的TASK。

readWriteList[OS_QUEUE_READ]:读消息阻塞链表,链接因消息队列空而无法读取时需要挂起的TASK。

memList:申请内存块阻塞链表,链接因申请某一静态内存池中的内存块失败而需要挂起的TASK。

关键算法

在计算机程序设计中,“先入先出”和“先入后出”都是处理输入数据的方法。上篇文章向大家介绍了FIFO(先入先出)算法,今天给大家讲解FILO(先入后出)算法。一个先入后出(FILO,First In Last Out)的队列,可以形象地理解为手枪的弹匣,装子弹是“入队列”,射击是“出队列”,最先压入弹匣的子弹是最后射出去的。同理,最先入队列的消息也是在最后处理,这就是FILO(先入后出)算法的本质。

1.1FIFO算法之入队列

第一步:队列初始化

下图呈现了一个初始化后的队列:

截取关键函数LOS_QueueCreate,此函数来源于liteos_m内核代码。

LITE_OS_SEC_TEXT_INIT UINT32 LOS_QueueCreate(CHAR *queueName,UINT16 len,UINT32 *queueID,UINT32 flags,UINT16 maxMsgSize)
{LosQueueCB *queueCB = NULL;UINT32 intSave;LOS_DL_LIST *unusedQueue = NULL;UINT8 *queue = NULL;UINT16 msgSize;...queue = (UINT8 )LOS_MemAlloc(m_aucSysMem0, len  msgSize);...queueCB->queueLen = len;queueCB->queueSize = msgSize;queueCB->queue = queue;queueCB->queueState = OS_QUEUE_INUSED;queueCB->readWriteableCnt[OS_QUEUE_READ] = 0;queueCB->readWriteableCnt[OS_QUEUE_WRITE] = len;queueCB->queueHead = 0;queueCB->queueTail = 0;LOS_ListInit(&queueCB->readWriteList[OS_QUEUE_READ]);LOS_ListInit(&queueCB->readWriteList[OS_QUEUE_WRITE]);LOS_ListInit(&queueCB->memList);LOS_IntRestore(intSave);*queueID = queueCB->queueID;OsHookCall(LOS_HOOK_TYPE_QUEUE_CREATE, queueCB);return

queue指针指向队列的内存,队列分配了len个消息,每个消息的大小为msgSize。与此同时头指针和尾指针的初始化为0,意味着队列为空,还没有消息入队列。

第二步:第一个消息入队列

各类任务可以作为队列的生产者,队列初始化后,任务可以放置第一个消息,在此选择FILO的方式来放置消息。

下图是FIFO插入第一个数据后的内存形态:

FILO的操作包含在OsQueueBufferOperate函数中,这次是进入OS_QUEUE_WRITE_HEAD的分支处理:

static INLINE VOID OsQueueBufferOperate(LosQueueCB *queueCB, UINT32 operateType,VOID bufferAddr, UINT32 bufferSize)
{UINT8 *queueNode = NULL;UINT32 msgDataSize;UINT16 queuePosition;errno_t rc;/ get the queue position /switch (OS_QUEUE_OPERATE_GET(operateType)) {case OS_QUEUE_READ_HEAD:queuePosition = queueCB->queueHead;((queueCB->queueHead + 1) == queueCB->queueLen) ? (queueCB->queueHead = 0) : (queueCB->queueHead++);break;case OS_QUEUE_WRITE_HEAD:(queueCB->queueHead == 0) ? (queueCB->queueHead = (queueCB->queueLen - 1)) : (--queueCB->queueHead);queuePosition = queueCB->queueHead;break;case OS_QUEUE_WRITE_TAIL:queuePosition = queueCB->queueTail;((queueCB->queueTail + 1) == queueCB->queueLen) ? (queueCB->queueTail = 0) : (queueCB->queueTail++);break;...
}

OsQueueBufferOperate是队列内存的核心操作函数,FILO算法的本质是往队列的头部添加数据,入队列的操作抽象为OS_QUEUE_WRITE_HEAD操作。而本次操作和FIFO不一样,插入数据不再移动tail这个“尾巴”指针,后续无论是入队列操作还是出队列操作,tail指针都不会被操作。

第三步:继续生产数据

数据继续生产,第2个消息进入队列后继续移动head指针,如下图所示:

第三个消息也是重复的移动head指针,如下图所示:

第四步:生产数据结束

本次实例以生产者生产四个消息为结束点,最后形态的队列下图所示:

1.2 FIFO算法之出队列

第一步:取出队列头消息。由于这是先入后出的算法,因此第一个出队列的消息是最后入队列的,也就是队列中标注为“第4个”的消息。

消费后的消息空间也是unused空间,在此处用其它颜色标注消费后的消息,便于读者理解队列的变化情况。

回顾一下OsQueueBufferOperate函数的关键代码,这一次是读的分支:

/ get the queue position /
switch (OS_QUEUE_OPERATE_GET(operateType)) {case OS_QUEUE_READ_HEAD:queuePosition = queueCB->queueHead;((queueCB->queueHead + 1) == queueCB->queueLen) ? (queueCB->queueHead = 0) : (queueCB->queueHead++);break;

queueHead是头指针,它的移动代表着出队列的行为,queueHead目前指向“第4个”消息,往后移动一个,应用得到“第4个”消息的返回值。此处可见,最后入队列的消息最先出。

第二步:继续消费

第三个消息被消费的图示:

第二个消息被消费的图示:

第三步:消费完毕

最后一个消息也处理完成,于是head指针和tail指针均移动到下图的位置。队列为空,任务结束。

这时如果把图重新换个方向来看,那么就很容易了解这个算法的本质。Tail指针全程没有用到,如果把它去掉,水平方向的队列改为垂直方向。如下图所示,可见该图片为典型的入栈操作。由此可知,OpenHarmony内核通过头指针的写操作和读操作,把栈的操作兼容到队列中。

总结

本文主要介绍了OpenHarmony内核对象队列的算法之FILO,至此,队列的2个算法都已介绍完毕。通过对FIFO和FILO这2个算法的详解,开发者能够更加全面了解OpenHarmony LiteOS-M 内核队列算法,以便将来在内核开发工作中遇到队列的其他算法,也能够举一反三,迅速掌握。

为了帮助到大家能够更有效的学习OpenHarmony 开发的内容,下面特别准备了一些相关的参考学习资料:

OpenHarmony 开发环境搭建:https://qr18.cn/CgxrRy

《OpenHarmony源码解析》:https://qr18.cn/CgxrRy

  • 搭建开发环境
  • Windows 开发环境的搭建
  • Ubuntu 开发环境搭建
  • Linux 与 Windows 之间的文件共享
  • ……

系统架构分析:https://qr18.cn/CgxrRy

  • 构建子系统
  • 启动流程
  • 子系统
  • 分布式任务调度子系统
  • 分布式通信子系统
  • 驱动子系统
  • ……

OpenHarmony 设备开发学习手册:https://qr18.cn/CgxrRy

在这里插入图片描述

OpenHarmony面试题(内含参考答案):https://qr18.cn/CgxrRy

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

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

相关文章

Pytorch-07 完整训练测试过程

要在PyTorch中使用GPU进行数据集的加载、模型的训练和最后模型的测试&#xff0c;需要将数据集和模型都移动到GPU上&#xff0c;并确保在训练和测试过程中都在GPU上进行计算。以下是一个完整的示例代码&#xff0c;展示了如何在PyTorch中使用GPU进行端到端的训练和测试&#xf…

六月后考研如何备考看这一篇就够了

以下是考研六月后可以参考的规划&#xff1a; 6 月至 8 月&#xff08;强化阶段&#xff09;&#xff1a; 英语&#xff1a;继续背单词&#xff0c;开始刷历年真题中的阅读部分&#xff0c;仔细分析错题原因&#xff0c;总结解题技巧。数学&#xff1a;完成基础阶段的复习后&am…

接口作为返回类型与类作为返回类型一样吗?

LinkedList<Integer> q new LinkedList<>();和Queue<Integer> q new LinkedList<>();一样吗&#xff1f; 我现在想创建一个队列对象&#xff0c;正常情况下我会这样写&#xff1a;Queue<Integer> q new Queue<>(); 但是你仔细想想&am…

使用chatglm.cpp本地部署ChatGLM3-6B模型

ChatGLM3模型介绍 ChatGLM3-6B 是 ChatGLM 系列最新一代的开源模型&#xff0c;在保留了前两代模型对话流畅、部署门槛低等众多优秀特性的基础上&#xff0c;ChatGLM3-6B 引入了如下特性&#xff1a; 更强大的基础模型&#xff1a; ChatGLM3-6B 的基础模型 ChatGLM3-6B-Base …

Yourpassword does not satisfy the current policyrequirements

mysql 新增数据库用户失败 解决方法&#xff1a; 修改校验密码策略等级 set global validate_password.policyLOW;

dataguard 备库关闭后启动流程

startup mount&#xff1b; ---开启adg alter database recover managed standby database using current logfile disconnect from session; -- alter database recover managed standby database cancel; alter database recover managed standby database disconnect…

C++课程设计实验杭州电子科技大学ACM题目(上)

题目一&#xff1a;2013.蟠桃季 题目描述 Problem Description&#xff1a;喜欢西游记的同学肯定都知道悟空偷吃蟠桃的故事&#xff0c;你们一定都觉得这猴子太闹腾了&#xff0c;其实你们是有所不知&#xff1a;悟空是在研究一个数学问题&#xff01;什么问题&#xff1f;他…

【面试】PWM(脉冲宽度调制)相关问题 ——长期更新

1、PWM调节原理 答&#xff1a;通过改变信号的高电平和低电平的持续时间比例来控制输出信号的平均功率或电压。 2、PWM占空比定义 答&#xff1a;在一个脉冲周期内&#xff0c;高电平的时间占整个周期时间的比例。 3、PWM波形的周期和调节精度由谁决定 答&#xff1a;当计数…

全同态加密生态项目盘点:FHE技术的崛起以及应用

撰文&#xff1a;Chris&#xff0c;Techub News 在当今数字化的时代&#xff0c;隐私保护已成为一个全球性的焦点话题&#xff0c;特别是在加密货币和区块链技术快速发展的背景下。虽然当前的隐私技术在保护数据安全方面多有欠缺&#xff0c;引发了广泛的关注和批评&#xff0c…

BUUCTF-WEB3

[极客大挑战 2019]Knife1 1.打开附件链接 一句话木马eval($_POST["Syc"]); 2.中国蚁剑 用中国蚁剑连接 在根目录下找到一个名为flag的文件 3.得到flag [极客大挑战 2019]Upload1 1.打开附件链接 是一个文件上传 2.一句话木马 经过多次尝试都被绕过&#xff0c;更…

【MySQL】数据库的开始

前言 数据库是我们学习编程中一个非常重要的内容&#xff0c;像一些什么什么管理系统&#xff0c;如果想要存储数据都是需要连接数据库的。博主之前写过一篇图书管理系统的博客&#xff0c;那时的我还没接触过数据库&#xff0c;所有的数据都是现成创建的&#xff0c;感兴趣的…

JavaScript面试 题

1.延时加载JS有哪些方式 延时加载 :async defer 例如:<script defer type"type/javascript" srcscript.js></ script> defer:等html全部解析完成,才会执行js代码,顺次执行的 async: js和html解析是同步的,不是顺次执行js脚本(谁先加载完先执行谁)2.JS数…

【C++】菱形继承、菱形虚拟继承、继承与组合

目录 01.概念 02.虚拟继承 原理 03.继承和组合 01.概念 单继承&#xff1a; 一个子类只有一个父类时&#xff0c;称这种继承关系为单继承。 多继承&#xff1a; 一个子类同时有两个及以上的父类时&#xff0c;称这种继承关系为多继承。 菱形继承&#xff1a; 菱形继承是…

一文搞懂oracle事务提交以及脏数据落盘的原则

本文基于oracle 19c 做事务提交以及oracle脏数据落盘的相关解读 第一章 相关进程及组件介绍&#xff1a; 1.LGWR&#xff1a; 重做日志条目在系统全局区域 &#xff08;SGA&#xff09; 的重做日志缓冲区中生成。LGWR 按顺序将重做日志条目写入重做日志文件。如果数据库具有…

【MySQL精通之路】MySQL的使用(3)-命令行连接

本节介绍使用命令行选项来指定如何为MySQL或mysqldump等客户端建立到MySQL服务器的连接。 有关使用类似URI的连接字符串或键值对建立连接的信息&#xff0c;对于MySQL Shell等客户端&#xff0c;请参阅“使用类似URI字符串或键值配对连接到服务器”。 有关无法连接的其他信息&a…

期望薪资26K,北京疯狂游戏golang一面

北京疯狂游戏一面 1、自我介绍 2、财务业务中&#xff0c;你做了哪些设计来保证金额数据的准确性&#xff1f;&#xff08;例如&#xff0c;业务涉及多步骤&#xff0c;某一步出了问题怎么解决&#xff09; 3、如何解决单个业务直接报错的数据准确性问题 4、分布式场景下&a…

理解Vue 3响应式系统原理

title: 理解Vue 3响应式系统原理 date: 2024/5/28 15:44:47 updated: 2024/5/28 15:44:47 categories: 前端开发 tags: Vue3.xTypeScriptSFC优化Composition-APIRef&Reactive性能提升响应式原理 第一章&#xff1a;Vue 3简介 1.1 Vue 3概述 Vue 3的诞生背景&#xff1…

怎么把电脑上的文件传到手机上?可保存文档的云笔记

在职场中&#xff0c;我们经常需要将电脑上的重要文件、资料传到手机上&#xff0c;以便随时查阅和使用。比如&#xff0c;当你在公司完成了一份关键报告&#xff0c;但即将外出与客户沟通&#xff0c;这时如果能将报告传到手机上&#xff0c;就能在移动中随时准备应对客户的咨…

uniapp Androud 离线打包升级APK,覆盖安装不更新问题

Android 打包时在assets/data/dcloud_control.xml文件中&#xff0c;如果配置debug"true" syncDebug"true"&#xff0c;则consle打印有效&#xff0c;不然没有打印数据 <hbuilder debug"true" syncDebug"true"> <apps> …

破解App渠道归因难题,Xinstall助你实现精准数据追踪!

在移动互联网时代&#xff0c;App的推广和运营面临着诸多挑战。其中&#xff0c;渠道归因问题一直困扰着众多推广者。如何准确追踪用户来源&#xff0c;分析不同渠道的推广效果&#xff0c;成为了摆在推广者面前的一大难题。然而&#xff0c;有了Xinstall的出现&#xff0c;这一…