嵌入式实时操作系统的设计与开发(消息)

消息

从概念上讲,消息机制和邮箱机制很类似,区别在于邮箱一般只能容纳一条消息,而消息则会包含一系列的消息
在这里插入图片描述
系统定义了一个全局变量g_msgctr_header,通过它可以查找到任一已创建的消息容器。
每一个消息容器都可以根据其参数性质(1VS1:1对1的消息通信、1VSn:1对多的消息通信、nVSn:多对多的消息通信、nVS1等)来实现不同的通信方式。

这里的消息容器,只是一个线程间的通信结构acoral_msgctr_t,是消息的存储容器,一个消息容器可以通过它的消息链指针成员,挂载多条消息结构。
而消息结构是消息的容器,一个消息结构包含一条消息。

aCoral并没有采用数组之间存储消息指针的经典实现形式,而是在消息上又包装了一层结构,这样的实现是为了功能上的扩展,只要稍作改进,就可以实现消息功能的进一步增加,如消息最大生存时间,一次唤醒多个等待线程等功能。

//消息容器
typedef struct
{acoral_res_t res; //消息容器也是资源char *name;acoral_list_t msgctr_list;//全局消息容器的挂载钩子unsigned int count; //消息数量unsigned int wait_thread_num; //等待线程数acoral_list_t waiting; //等待线程指针链acoral_list_t msglist;//消息指针链,用于挂载消息
}acoral_msgctr_t;
//消息
typedef struct
{acoral_res_t res;acoral_list_t msglist; //挂载钩子成员,用于将消息结构挂载到消息容器上unsigned int id; //消息标识,用于区分一个消息容器不同消息结构类型的成员,通过它可以实现1VSn的结构。unsigned int count;//消息被接收次数,每接受一次减一,直到0为止。通过它可以实现一次发送,多次接收的功能。unsigned int ttl;//消息最大生存周期,当一个消息生存周期到时,将自动删除,不可以再被接收。void *data; //消息指针
}acoral_msg_t;

如何创建消息容器,以供线程间传递数据使用。

acoral_msgctr_t *acoral_msgctr_create()
{acoral_msgctr_t *msgctr;msgctr = acoral_alloc_msgctr();//申请一片内存空间,分配的方式和过程与线程TCB的分配类似,即从内存资源池中获取一个资源对象供消息容器acoral_msgctr_t使:return (acoral_msgctr_t *)acoral_get_res(&acoral_msgctr_pool_ctrl);if(msgctr == NULL)return NULL;msgctr->name = NULL;msgctr->count = 0;msgctr->wait_thread_num = 0;acoral_init_list(&msgctr->msgctr_list);acoral_init_list(&msgctr->msglist);acoral_init_list(&msgctr->waiting);acoral_list_add2_tail(&msgctr->msgctr_list, &(g_msgctr_header));return msgctr;
}

创建消息,前面提到,消息容器并不直接包含消息,在消息容器之下,还有一层消息结构因而消息的创建,即是先创建消息结构,再将消息挂到消息结构的过程。

acoral_msg_t *acoral_msg_create(unsigned int count,unsigned int id, unsigned int nTtl, void *data)
{acoral_msg_t *msg;msg = acoral_alloc_msg();if(msg == NULL)return NULL;msg->id = id;msg->count = count;msg->ttl = nTtl;msg->data = data;acoral_init_list(&msg->msglist);
}

一个消息的创建接口需要五个参数:消息被接收次数、错误码、消息ID、生存周期和消息指针(指向被发送的消息)。

其中前三个参数都是为了扩展而引入的,aCoral只提供了接口和基本实现,但并未在消息传递具体过程中使用,如果需要进行扩展,只需要简单更改源代码即可,用于功能的扩充。

发送消息:aCoral消息发送是需要先前创建的消息容器队列和消息队列。消息发送时,首先将包含消息的消息结构挂到消息容器的消息链上,然后判断是否有等待的线程,如果有的话,则唤醒最高优先级的线程。

unsigned int acoral_msg_send(acoral_msgctr_t *msgctr, acoral_msg_t *msg)
{acoral_enter_critical();if (NULL == msgctr){acoral_exit_critical();return MST_ERR_NULL;}if (NULL == msg){acoral_exit_critical();return MSG_ERR_NULL;}//消息数限制if(ACORAL_MESSAGE_MAX_COUNT <= msgctr->count){acoral_exit_critical();return MSG_ERR_COUNT;}//增加消息msgctr->count++;msg->ttl += acoral_get_ticks();acoral_list_add2_tail(&msg->msglist, &msgctr->msglist);//唤醒等待if(msgctr->wait_thread_num > 0){wake_up_thread(&msgctr->wiating);msgctr->wait_thread_num--;}acoral_exit_critical();acoral_sched();return MSGCTR_SUCCED;
}

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

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

相关文章

C++之左值、右值、std::forward、std::move总结(二百五十)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 优质专栏&#xff1a;Audio工程师进阶系列【原创干货持续更新中……】&#x1f680; 人生格言&#xff1a; 人生…

Android Studio 导出 jar

AS版本&#xff1a;Android Studio Giraffe | 2022.3.1 Patch 1 1、File——New Module——Android Library 2、mylibrary——main——新建功能类 3、mylibrary——build.gradle——android {}内复制以下代码——Sync Now //Copy类型 tasks.register(makeJar, Copy) { //删…

react-高阶组件

一、什么是高阶组件 高阶组件&#xff08; Higher-Order Component&#xff0c;HOC &#xff09;是一个以组件作为参数&#xff0c;返回一个新组件的函数。 高阶组件最大的特点就是复用组件逻辑高阶组件本身并不是 React 的 API&#xff0c;而是React组件的一种设计模式&…

自动驾驶,从“宠儿”走进“淘汰赛”

从“一步到位”到场景、技术降维。从拼落地路径&#xff0c;到拼雷达、算力&#xff0c;再到如今的性价比之争&#xff0c;自动驾驶似乎变得愈发“接地气”。 作者|斗斗 编辑|皮爷 出品|产业家 比起去年&#xff0c;黄文欢和张放今年显得更加忙碌。 “自动驾驶赛道&…

windows下-mysql环境配置,以及使用navicat可视化数据库,便捷撰写sql语句。

文章目录 MySQL 连接到本地MySQL 下载MySQL连接基本SQL操作语句创建并查看数据库删除数据库修改数据库插入、删除、修改数据 图形化界面展示数据库 Navicat 基础操作连接本地的mysql数据库撰写sql语句 MySQL 连接到本地 MySQL 下载 直接系统自带应用商城下载&#xff0c;安装最…

MySQL 多表查询 事务 索引

目录 多表查询简介内连接查询 join on外连接查询 left join、right join子连接查询标量子查询列子查询 (in、not in)行子查询表子查询 多表查询案例 事务事务介绍操作 start transaction、commit、rollback事务四大特性(面试题) 索引索引介绍索引原理索引语法 index 上次学习了…

【高阶数据结构】并查集和图

目录 1.数据结构--并查集 2.数据结构--图 1.图的基础概念 2.图的简单实现 2.1.邻接矩阵的图实现 2.2.邻接表的图实现 2.3.图的DFS和BFS 2.4.最小生成树 2.4.1.Kruskal(克鲁斯卡尔算法) 2.4.2.Prim&#xff08;普里姆算法&#xff09; 2.5.最短路径 2.5.1.Dijkstra(…

soc的复位reset/rst问题

本节不去讨论同步复位与异步复位以及异步复位的reset_release&#xff0c;这些问题可参考&#xff1a;芯片设计进阶之路——Reset深入理解——cy413026 本机主要回答一下几个问题。 1.片外的reset信号特别是按键reset怎么防止错误抖动的影响&#xff1f; 常见的处理方法包括两…

大数据-Storm流式框架(三)--Storm搭建教程

一、两种搭建方式 1、storm单节点搭建 2、完全分布式搭建 二、storm单节点搭建 准备 下载地址&#xff1a;Index of /dist/storm 1、环境准备&#xff1a; Java 6 Python 2.6.6 2、上传、解压安装包 3、在storm目录中创建logs目录 mkdir logs 启动 ./storm help …

解决cloudflare pages部署静态页面发生404错误的问题

cloudflare pages是一个非常方便的部署静态页面的sass工具。 但是很多人部署上去以后&#xff0c;访问服务会报404错误。什么原因&#xff1f; 原因如下图所示&#xff1a; 注意这个Build output directory, 这个是部署的关键&#xff01; 这个Build output directory目录的…

ETL工具Kettle

1 Kettle的基本概念 一个数据抽取过程&#xff0c;主要包括创建一个作业&#xff08;Job&#xff09;&#xff0c;每个作业由一个或多个作业项&#xff08;Job Entry&#xff09;和连接作业项的作业跳&#xff08;Job Hop&#xff09;组成。每个作业项可以是一个转换&#xff…

TSINGSEE青犀基于AI视频识别技术的平安校园安防视频监控方案

一、背景需求 因学校频频出治安事件&#xff0c;所以必须要加强学校的安防工作&#xff0c;目前来看&#xff0c;大部分校园都建设了视频监控来预防保障校园安全。但是传统的视频监控系统&#xff0c;主要通过设备来录像以及人员时时监控来进行。这种监管方式效率十分低下&…

使用canal实现数据实时同步

canal canal [kə’nl]&#xff0c;译意为水道/管道/沟渠&#xff0c;主要用途是基于 MySQL 数据库增量日志解析&#xff0c;提供增量数据订阅和消费 早期阿里巴巴因为杭州和美国双机房部署&#xff0c;存在跨机房同步的业务需求&#xff0c;实现方式主要是基于业务 trigger…

【API篇】八、Flink窗口函数

文章目录 1、增量聚合之ReduceFunction2、增量聚合之AggregateFunction3、全窗口函数full window functions4、增量聚合函数搭配全窗口函数5、会话窗口动态获取间隔值6、触发器和移除器7、补充 //窗口操作 stream.keyBy(<key selector>).window(<window assigner>)…

lesson2(补充)关于const成员函数

个人主页&#xff1a;Lei宝啊 愿所有美好如期而遇 前言&#xff1a; 将const 修饰的 “ 成员函数 ” 称之为 const 成员函数 &#xff0c; const 修饰类成员函数&#xff0c;实际修饰该成员函数 隐含的 this 指针 &#xff0c;表明在该成员函数中不能对类的任何成员进行修改…

Vue+ElementUI项目打包部署到Ubuntu服务器中

1、修改config/index.js中的assetsPublicPath: /,修改为assetsPublicPath: ./ assetsPublicPath: ./2、在build/utils.js中增加publicPath: ../../ publicPath: ../../3、打开终端&#xff0c;在根目录下执行npm run build进行打包&#xff0c;打包成功后会生成dist npm run…

037-第三代软件开发-系统音量设置

第三代软件开发-系统音量设置 文章目录 第三代软件开发-系统音量设置项目介绍系统音量设置QML 实现C 实现 总结一下 关键字&#xff1a; Qt、 Qml、 volume、 声音、 GPT 项目介绍 欢迎来到我们的 QML & C 项目&#xff01;这个项目结合了 QML&#xff08;Qt Meta-Obj…

听GPT 讲Rust源代码--library/std(8)

题图来自Why is Rust programming language so popular?[1] File: rust/library/std/src/sys/sgx/abi/reloc.rs 在Rust源代码中&#xff0c;sgx/abi/reloc.rs文件的作用是定义了针对Intel Software Guard Extensions (SGX)的重定位相关结构和函数。 该文件中的Rela 结构定义了…

集群节点批量执行 shell 命令

1、SSH 工具本身支持多窗口 比如 MobaXterm&#xff1a; 2、编写脚本通过 ssh 在多台机器批量执行shell命令 创建 ssh_hosts 配置文件&#xff0c;定义需要批量执行的节点&#xff08;必须能够通过 ssh 免密登录&#xff0c;且存在同名用户&#xff09; vim ssh_hostsbig…

Oracle通过透明网关查询SQL Server 报错ORA-00904

Oracle通过透明网关查询SQL Server 报错ORA-00904 问题描述&#xff1a; 只有全表扫描SELECT * 时SQL语句可以正常执行 添加WHERE条件或指定列名查询&#xff0c;查询语句就报错 问题原因&#xff1a; 字段大小写和SQLSERVER中定义的不一致导致查询异常 解决办法&#xff1a; 给…