鸿蒙内核源码分析(事件控制篇) | 任务间多对多的同步方案

官方概述

先看官方对事件的描述.

事件（Event）是一种任务间通信的机制，可用于任务间的同步。

多任务环境下，任务之间往往需要同步操作，一个等待即是一个同步。事件可以提供一对多、多对多的同步操作。

  • 一对多同步模型：一个任务等待多个事件的触发。可以是任意一个事件发生时唤醒任务处理事件，也可以是几个事件都发生后才唤醒任务处理事件。

  • 多对多同步模型：多个任务等待多个事件的触发。

鸿蒙提供的事件具有如下特点：

  • 任务通过创建事件控制块来触发事件或等待事件。
  • 事件间相互独立，内部实现为一个32位无符号整型，每一位标识一种事件类型。第25位不可用，因此最多可支持31种事件类型。
  • 事件仅用于任务间的同步，不提供数据传输功能。
  • 多次向事件控制块写入同一事件类型，在被清零前等效于只写入一次。
  • 多个任务可以对同一事件进行读写操作。
  • 支持事件读写超时机制。

再看事件图

注意图中提到了三个概念 事件控制块 事件 任务
接下来结合代码来理解事件模块的实现.

事件控制块长什么样?

typedef struct tagEvent {UINT32 uwEventID;        /**< Event mask in the event control block，//标识发生的事件类型位，事件ID，每一位标识一种事件类型indicating the event that has been logically processed. */LOS_DL_LIST stEventList; /**< Event control block linked list *///读取事件任务链表
} EVENT_CB_S， *PEVENT_CB_S;

简单是简单，就两个变量，如下:
uwEventID：用于标识该任务发生的事件类型，其中每一位表示一种事件类型（0表示该事件类型未发生、1表示该事件类型已经发生），一共31种事件类型，第25位系统保留。

stEventList，这又是一个双向链表， 双向链表是内核最重要的结构体.
LOS_DL_LIST像狗皮膏药一样牢牢的寄生在宿主结构体上stEventList上挂的是所有等待这个事件的任务.

事件控制块<>事件<>任务 三者关系

一定要搞明白这三者的关系，否则搞不懂事件模块是如何运作的.

  • 任务是事件的生产者，通过 LOS_EventWrite，向外部广播发生了XX事件，并唤醒此前已在事件控制块中登记过的要等待XX事件发生的XX任务.

  • 事件控制块EVENT_CB_S 是记录者，只干两件事件:

    1.uwEventID按位记录哪些事件发生了，它只是记录，怎么消费它不管的.

    2.stEventList记录哪些任务在等待事件，但任务究竟在等待哪些事件它也是不记录的

  • 任务也是消费者，通过 LOS_EventRead消费，只有任务自己清楚要以什么样的方式，消费什么样的事件.
    先回顾下任务结构体 LosTaskCB 对事件部分的描述如下:

    typedef struct {//...去掉不相关的部分VOID            *taskEvent;  //和任务发生关系的事件控制块UINT32          eventMask;   //对哪些事件进行屏蔽UINT32          eventMode;   //事件三种模式(LOS_WAITMODE_AND，LOS_WAITMODE_OR，LOS_WAITMODE_CLR)} LosTaskCB;    

`taskEvent` 指向的就是 `EVENT_CB_S``eventMask` 屏蔽掉 事件控制块 中的哪些事件`eventMode` 已什么样的方式去消费事件，三种读取模式

    #define LOS_WAITMODE_AND                    4U 	#define LOS_WAITMODE_OR                     2U 	#define LOS_WAITMODE_CLR                    1U	

*   所有事件（`LOS_WAITMODE_AND`）：逻辑与，基于接口传入的事件类型掩码`eventMask`，只有这些事件都已经发生才能读取成功，否则该任务将阻塞等待或者返回错误码。*   任一事件（`LOS_WAITMODE_OR`）：逻辑或，基于接口传入的事件类型掩码`eventMask`，只要这些事件中有任一种事件发生就可以读取成功，否则该任务将阻塞等待或者返回错误码。*   清除事件（`LOS_WAITMODE_CLR`）：这是一种附加读取模式，需要与所有事件模式或任一事件模式结合使用（`LOS_WAITMODE_AND | LOS_WAITMODE_CLR`或 `LOS_WAITMODE_OR | LOS_WAITMODE_CLR`）。在这种模式下，当设置的所有事件模式或任一事件模式读取成功后，会自动清除事件控制块中对应的事件类型位。
  • 一个事件控制块EVENT_CB_S中的事件可以来自多个任务，多个任务也可以同时消费事件控制块中的事件，并且这些任务之间可以没有任何关系!

函数列表

事件可应用于多种任务同步场景，在某些同步场景下可替代信号量。

其中读懂 OsEventWrite 和 OsEventRead 就明白了事件模块.

事件初始化 -> LOS_EventInit

//初始化一个事件控制块
LITE_OS_SEC_TEXT_INIT UINT32 LOS_EventInit(PEVENT_CB_S eventCB)
{UINT32 intSave;intSave = LOS_IntLock();//锁中断eventCB->uwEventID = 0; //其中每一位表示一种事件类型（0表示该事件类型未发生、1表示该事件类型已经发生）LOS_ListInit(&eventCB->stEventList);//事件链表初始化LOS_IntRestore(intSave);//恢复中断return LOS_OK;
}

代码解读:

  • 事件是共享资源，所以操作期间不能产生中断.
  • 初始化两个记录者 uwEventID stEventList

事件生产过程 -> OsEventWrite

LITE_OS_SEC_TEXT VOID OsEventWriteUnsafe(PEVENT_CB_S eventCB， UINT32 events， BOOL once， UINT8 *exitFlag)
{LosTaskCB *resumedTask = NULL;LosTaskCB *nextTask = NULL;BOOL schedFlag = FALSE;eventCB->uwEventID |= events;//对应位贴上标签if (!LOS_ListEmpty(&eventCB->stEventList)) {//等待事件链表判断，处理等待事件的任务for (resumedTask = LOS_DL_LIST_ENTRY((&eventCB->stEventList)->pstNext， LosTaskCB， pendList);&resumedTask->pendList != &eventCB->stEventList;) {//循环获取任务链表nextTask = LOS_DL_LIST_ENTRY(resumedTask->pendList.pstNext， LosTaskCB， pendList);//获取任务实体if (OsEventResume(resumedTask， eventCB， events)) {//是否恢复任务schedFlag = TRUE;//任务已加至就绪队列，申请发生一次调度}if (once == TRUE) {//是否只处理一次任务break;//退出循环}resumedTask = nextTask;//检查链表中下一个任务}}if ((exitFlag != NULL) && (schedFlag == TRUE)) {//是否让外面调度*exitFlag = 1;}
}
//写入事件
LITE_OS_SEC_TEXT STATIC UINT32 OsEventWrite(PEVENT_CB_S eventCB， UINT32 events， BOOL once)
{UINT32 intSave;UINT8 exitFlag = 0;SCHEDULER_LOCK(intSave);	//禁止调度OsEventWriteUnsafe(eventCB， events， once， &exitFlag);//写入事件SCHEDULER_UNLOCK(intSave);	//允许调度if (exitFlag == 1) { //需要发生调度LOS_MpSchedule(OS_MP_CPU_ALL);//通知所有CPU调度LOS_Schedule();//执行调度}return LOS_OK;
}

代码解读:

  1. 给对应位贴上事件标签，eventCB->uwEventID |= events; 注意uwEventID是按位管理的.每个位代表一个事件是否写入，例如 uwEventID = 00010010 代表产生了 1，4 事件

  2. 循环从stEventList链表中取出等待这个事件的任务判断是否唤醒任务. OsEventResume

//事件恢复，判断是否唤醒任务
LITE_OS_SEC_TEXT STATIC UINT8 OsEventResume(LosTaskCB *resumedTask， const PEVENT_CB_S eventCB， UINT32 events)
{UINT8 exitFlag = 0;//是否唤醒if (((resumedTask->eventMode & LOS_WAITMODE_OR) && ((resumedTask->eventMask & events) != 0)) ||((resumedTask->eventMode & LOS_WAITMODE_AND) &&((resumedTask->eventMask & eventCB->uwEventID) == resumedTask->eventMask))) {//逻辑与 和 逻辑或 的处理exitFlag = 1; resumedTask->taskEvent = NULL;OsTaskWake(resumedTask);//唤醒任务，加入就绪队列}return exitFlag;
}

3.唤醒任务OsTaskWake只是将任务重新加入就绪队列，需要立即申请一次调度 LOS_Schedule .

事件消费过程 -> OsEventRead

LITE_OS_SEC_TEXT STATIC UINT32 OsEventRead(PEVENT_CB_S eventCB， UINT32 eventMask， UINT32 mode， UINT32 timeout，BOOL once)
{UINT32 ret;UINT32 intSave;SCHEDULER_LOCK(intSave);ret = OsEventReadImp(eventCB， eventMask， mode， timeout， once);//读事件实现函数SCHEDULER_UNLOCK(intSave);return ret;
}//读取指定事件类型的实现函数，超时时间为相对时间：单位为Tick
LITE_OS_SEC_TEXT STATIC UINT32 OsEventReadImp(PEVENT_CB_S eventCB， UINT32 eventMask， UINT32 mode，UINT32 timeout， BOOL once)
{UINT32 ret = 0;LosTaskCB *runTask = OsCurrTaskGet();runTask->eventMask = eventMask;runTask->eventMode = mode;runTask->taskEvent = eventCB;//事件控制块ret = OsTaskWait(&eventCB->stEventList， timeout， TRUE);//任务进入等待状态，挂入阻塞链表if (ret == LOS_ERRNO_TSK_TIMEOUT) {//如果返回超时runTask->taskEvent = NULL;return LOS_ERRNO_EVENT_READ_TIMEOUT;}ret = OsEventPoll(&eventCB->uwEventID， eventMask， mode);//检测事件是否符合预期return ret;
}

代码解读:

  • 事件控制块是给任务使用的， 任务给出读取一个事件的条件

    1. eventMask 告诉系统屏蔽掉这些事件，对屏蔽的事件不感冒.

    2. eventMode 已什么样的方式去消费事件，是必须都满足给的条件，还是只满足一个就响应.

    3. 条件给完后，自己进入等待状态 OsTaskWait，等待多久 timeout决定，任务自己说了算.

    4. OsEventPoll检测事件是否符合预期，啥意思?看下它的代码就知道了

      //根据用户传入的事件值、事件掩码及校验模式，返回用户传入的事件是否符合预期
LITE_OS_SEC_TEXT UINT32 OsEventPoll(UINT32 *eventID， UINT32 eventMask， UINT32 mode)
{UINT32 ret = 0;//事件是否发生了LOS_ASSERT(OsIntLocked());//断言不允许中断了LOS_ASSERT(LOS_SpinHeld(&g_taskSpin));//任务自旋锁if (mode & LOS_WAITMODE_OR) {//如果模式是读取掩码中任意事件if ((*eventID & eventMask) != 0) {ret = *eventID & eventMask; //发生了}} else {//等待全部事件发生if ((eventMask != 0) && (eventMask == (*eventID & eventMask))) {//必须满足全部事件发生ret = *eventID & eventMask; //发生了}}if (ret && (mode & LOS_WAITMODE_CLR)) {//是否清除事件*eventID = *eventID & ~ret; }return ret; 
}

编程实例

本实例实现如下流程。

示例中，任务Example_TaskEntry创建一个任务Example_Event，Example_Event读事件阻塞，Example_TaskEntry向该任务写事件。可以通过示例日志中打印的先后顺序理解事件操作时伴随的任务切换。

  • 在任务Example_TaskEntry创建任务Example_Event，其中任务Example_Event优先级高于Example_TaskEntry。
  • 在任务Example_Event中读事件0x00000001，阻塞，发生任务切换，执行任务Example_TaskEntry。
  • 在任务Example_TaskEntry向任务Example_Event写事件0x00000001，发生任务切换，执行任务Example_Event。
  • Example_Event得以执行，直到任务结束。
  • Example_TaskEntry得以执行，直到任务结束。
#include "los_event.h"
#include "los_task.h"
#include "securec.h"/* 任务ID */
UINT32 g_testTaskId;/* 事件控制结构体 */
EVENT_CB_S g_exampleEvent;/* 等待的事件类型 */
#define EVENT_WAIT 0x00000001/* 用例任务入口函数 */
VOID Example_Event(VOID)
{UINT32 ret;UINT32 event;/* 超时等待方式读事件，超时时间为100 ticks， 若100 ticks后未读取到指定事件，读事件超时，任务直接唤醒 */printf("Example_Event wait event 0x%x \n"， EVENT_WAIT);event = LOS_EventRead(&g_exampleEvent， EVENT_WAIT， LOS_WAITMODE_AND， 100);if (event == EVENT_WAIT) {printf("Example_Event，read event :0x%x\n"， event);} else {printf("Example_Event，read event timeout\n");}
}UINT32 Example_TaskEntry(VOID)
{UINT32 ret;TSK_INIT_PARAM_S task1;/* 事件初始化 */ret = LOS_EventInit(&g_exampleEvent);if (ret != LOS_OK) {printf("init event failed .\n");return -1;}/* 创建任务 */(VOID)memset_s(&task1， sizeof(TSK_INIT_PARAM_S)， 0， sizeof(TSK_INIT_PARAM_S));task1.pfnTaskEntry = (TSK_ENTRY_FUNC)Example_Event;task1.pcName       = "EventTsk1";task1.uwStackSize  = OS_TSK_DEFAULT_STACK_SIZE;task1.usTaskPrio   = 5;ret = LOS_TaskCreate(&g_testTaskId， &task1);if (ret != LOS_OK) {printf("task create failed .\n");return LOS_NOK;}/* 写g_testTaskId 等待事件 */printf("Example_TaskEntry write event .\n");ret = LOS_EventWrite(&g_exampleEvent， EVENT_WAIT);if (ret != LOS_OK) {printf("event write failed .\n");return LOS_NOK;}/* 清标志位 */printf("EventMask:%d\n"， g_exampleEvent.uwEventID);LOS_EventClear(&g_exampleEvent， ~g_exampleEvent.uwEventID);printf("EventMask:%d\n"， g_exampleEvent.uwEventID);/* 删除任务 */ret = LOS_TaskDelete(g_testTaskId);if (ret != LOS_OK) {printf("task delete failed .\n");return LOS_NOK;}return LOS_OK;
}

运行结果

Example_Event wait event 0x1 
Example_TaskEntry write event .
Example_Event，read event :0x1
EventMask:1
EventMask:0

鸿蒙全栈开发全新学习指南

也为了积极培养鸿蒙生态人才，让大家都能学习到鸿蒙开发最新的技术，针对一些在职人员、0基础小白、应届生/计算机专业、鸿蒙爱好者等人群，整理了一套纯血版鸿蒙（HarmonyOS Next）全栈开发技术的学习路线【包含了大APP实战项目开发】。

本路线共分为四个阶段：

第一阶段：鸿蒙初中级开发必备技能

第二阶段：鸿蒙南北双向高工技能基础：gitee.com/MNxiaona/733GH

第三阶段：应用开发中高级就业技术

第四阶段：全网首发-工业级南向设备开发就业技术：https://gitee.com/MNxiaona/733GH

《鸿蒙 (Harmony OS)开发学习手册》（共计892页）

如何快速入门？

1.基本概念
2.构建第一个ArkTS应用
3.……

开发基础知识:gitee.com/MNxiaona/733GH

1.应用基础知识
2.配置文件
3.应用数据管理
4.应用安全管理
5.应用隐私保护
6.三方应用调用管控机制
7.资源分类与访问
8.学习ArkTS语言
9.……

基于ArkTS 开发

1.Ability开发
2.UI开发
3.公共事件与通知
4.窗口管理
5.媒体
6.安全
7.网络与链接
8.电话服务
9.数据管理
10.后台任务(Background Task)管理
11.设备管理
12.设备使用信息统计
13.DFX
14.国际化开发
15.折叠屏系列
16.……

鸿蒙开发面试真题（含参考答案）:gitee.com/MNxiaona/733GH

鸿蒙入门教学视频：

美团APP实战开发教学：gitee.com/MNxiaona/733GH

写在最后

  • 如果你觉得这篇内容对你还蛮有帮助，我想邀请你帮我三个小忙：
  • 点赞，转发，有你们的 『点赞和评论』，才是我创造的动力。
  • 关注小编，同时可以期待后续文章ing🚀，不定期分享原创知识。
  • 想要获取更多完整鸿蒙最新学习资源，请移步前往小编：gitee.com/MNxiaona/733GH

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

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

相关文章

P8800 [蓝桥杯 2022 国 B] 卡牌

P8800 [蓝桥杯 2022 国 B] 卡牌

P8800 [蓝桥杯 2022 国 B] 卡牌 分析 “最多” -- 二分 1.二分区间&#xff08;凑齐的卡牌套数&#xff09;&#xff1a; l&#xff1a;a[]min&#xff1b;r&#xff1a;(a[]b[])max 2.check(x)&#xff1a; &#xff08;1&#xff09;for循环内&#xff1a; 判断x - a[i…
阅读更多...
最原理的一集——Mathtype公式编号设置（Mathtype7.8+Word）

最原理的一集——Mathtype公式编号设置（Mathtype7.8+Word）

版本 Mathtype7.8Office2019 Word 读完本文你将会 随心所欲&#xff0c;想怎么给公式编号就怎么给公式编号&#xff0c;想从(X.1)开始&#xff0c;就从(X.1)开始大概了解Mathtype公式设置原理给作者点赞 如果你想自己跟着文章做的话 请不要在自己的论文里边直接操作&#…
阅读更多...
【企业动态】爱尔兰客户到访东胜物联，共拓能源管理等解决方案

【企业动态】爱尔兰客户到访东胜物联，共拓能源管理等解决方案

近日&#xff0c;来自爱尔兰的房屋数据监测客户莅临东胜物联&#xff08;杭州黄龙国际中心&#xff09;进行参观考察&#xff0c;双方就未来的广泛合作进行了深入的沟通交流。 来访期间&#xff0c;东胜物联CEO支江峰先生热情接待了客户&#xff0c;并陪同他们参观了产品展厅&…
阅读更多...
WinForm DataGridView 垂直滑动条显示异常

WinForm DataGridView 垂直滑动条显示异常

WinForm DataGridView的垂直滑动条不正常显示&#xff0c;当总行高超过控件高度&#xff08;控件高度为227及以下不会出现该问题&#xff09;时&#xff0c;右下角会出现一个灰框&#xff0c;因为表格控件位处TabControl下&#xff0c;当切换其他选项卡后再切回来时&#xff0c…
阅读更多...
虚拟化界的强强联手：VirtIO与GPU虚拟化的完美结合

虚拟化界的强强联手：VirtIO与GPU虚拟化的完美结合

近距离了解 VirtIO 和 GPU 虚拟化 这是一篇 Linaro 开发团队项目组的科普文章。我们在处理器虚拟化项目中&#xff0c;经常会遇到 VirtIO 相关的问题&#xff1b;比如运行 Andriod 系统的时候需要运行 VirtIO 组件。‍‍‍随着 Cassini 项目和 SOAFEE&#xff08;嵌入式边缘可扩…
阅读更多...
网页html版面分析-- BeauifulSoup（python 文档解析提取）

网页html版面分析-- BeauifulSoup（python 文档解析提取）

介绍 BeauifulSoup 是一个可以从HTML或XML 文件中提取数据的python库&#xff1b;它能通过转换器实现惯用的文档导航、查找、修改文档的方式。 BeauifulSoup是一个基于re开发的解析库&#xff0c;可以提供一些强大的解析功能&#xff1b;使用BeauifulSoup 能够提高提取数据的效…
阅读更多...
【强训笔记】day7

【强训笔记】day7

NO.1 思路&#xff1a;双指针模拟&#xff0c;begin表示最长数字字符串最后一个字符&#xff0c;而len表示数字字符串的长度&#xff0c;i用来遍历&#xff0c;如果为数字&#xff0c;那么定义j变量继续遍历&#xff0c;直到不为数字&#xff0c;i-j如果大于len&#xff0c;就…
阅读更多...
TRIZ理论助力充电桩产业跨越技术瓶颈，实现产业升级！

TRIZ理论助力充电桩产业跨越技术瓶颈，实现产业升级！

随着新能源汽车市场的迅猛发展和电动汽车保有量的不断增加&#xff0c;充电桩作为电动汽车的“能量补给站”&#xff0c;其重要性日益凸显。然而&#xff0c;充电桩产业在发展过程中也面临着诸多技术瓶颈&#xff0c;如何突破这些瓶颈&#xff0c;推动充电桩产业升级成为行业亟…
阅读更多...
【字符串】Leetcode 二进制求和

【字符串】Leetcode 二进制求和

题目讲解 67. 二进制求和 算法讲解 为了方便计算&#xff0c;我们将两个字符串的长度弄成一样的&#xff0c;在短的字符串前面添加字符0&#xff1b;我们从后往前计算&#xff0c;当遇到当前计算出来的字符是> 2’的&#xff0c;那么就需要往前面进位和求余 注意&#xf…
阅读更多...
d3dcompiler_47.dll缺失怎么修复？，修复d3dcompiler_47.dll文件缺失的详细教程

d3dcompiler_47.dll缺失怎么修复？，修复d3dcompiler_47.dll文件缺失的详细教程

d3dcompiler_47.dll缺失怎么修复&#xff1f;遇到这样的问题是不是不知道怎么办&#xff1f;如果你不知道该怎么办&#xff0c;那么小编这篇文章将教大家如何去解决d3dcompiler_47.dll文件缺失。 方法1&#xff1a;下载并安装d3dcompiler_47.dll文件 当出现找不到d3dcompiler_…
阅读更多...
怎么把静图变成gif？推荐一招在线制作

怎么把静图变成gif？推荐一招在线制作

想要实现图片转换gif动图的操作使用什么工具能实现呢&#xff1f;在这个高速发展的时代经常需要在网络中分享、保存各种各样的gif动图。当我们想要将一些静态图片变成有趣的gif图片时&#xff0c;就可以使用gif在线制作&#xff08;https://www.gif.cn/&#xff09;工具&#x…
阅读更多...
ComfyUI 基础教程（十三）：ComfyUI-Impact-Pack 面部修复

ComfyUI 基础教程（十三）：ComfyUI-Impact-Pack 面部修复

SD的WebUI 中的面部修复神器 ADetailer，无法在ComfyUI 中使用。那么如何在ComfyUI中进行面部处理呢？ComfyUI 中也有几个面部修复功能，比如ComfyUI Impact Pack（FaceDetailer），以及换脸插件Reactor和IPAdapter。 ComfyUI-Impact-Pack 是一个功能强大的插件，专为 ComfyUI …
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023