山西两学一做网站,wordpress 模板 教育,北京网站建设定制,关键词优化seo优化排名#x1f48c; 所属专栏#xff1a;【BES2500x系列】 #x1f600; 作 者#xff1a;我是夜阑的狗#x1f436; #x1f680; 个人简介#xff1a;一个正在努力学技术的CV工程师#xff0c;专注基础和实战分享 #xff0c;欢迎咨询#xff01; #x1f49… 所属专栏【BES2500x系列】 作 者我是夜阑的狗 个人简介一个正在努力学技术的CV工程师专注基础和实战分享 欢迎咨询 欢迎大家这里是CSDN我总结知识的地方喜欢的话请三连有问题请私信 您的点赞、关注、收藏、评论是对我最大的激励和支持 文章目录 前言1 介绍2 功能特性3 同步与通信3.1 通信 4 同步与通信4.1 消息队列4.1.1 定义4.1.2 创建4.1.3发送消息 4.2 邮箱处理4.2.1 定义4.2.2 创建4.2.3 发送/释放邮件4.2.4 获取邮件 总结 前言 大家好又见面了我是夜阑的狗本文是专栏【BES2500x系列】专栏的第4篇文章; 今天开始学习BES2500x系列的一天开启新的征程记录最美好的时刻每天进步一点点。 专栏地址【BES2500x系列】 此专栏是我是夜阑的狗对BES2500x系列开发过程的总结希望能够加深自己的印象以及帮助到其他的小伙伴。 如果文章有什么需要改进的地方还请大佬不吝赐教。 【系列文章索引】 1 介绍 在嵌入式系统中同步和通信是确保系统内各个组件协调工作的两个核心概念。它们对于实现高效、可靠的嵌入式应用至关重要。前面已经讲过同步概念了接下来对通信概念进行简要说明。话不多说那接下来就学习 RTX 系统中通信机制都有哪些吧让我们原文再续书接上回吧。 2 功能特性 在实时操作系统RTOS中任务管理和同步通信是关键组件它们确保系统的高效和有序执行。本文将探讨这些概念特别是线程管理、信号量、互斥锁、消息队列和邮箱处理。
任务管理RTX提供任务创建、调度和优先级管理确保任务按照优先级及时执行。同步与通信包括信号量、互斥锁、消息队列和邮箱促进任务间的同步和数据交换。内存管理内存池和动态内存分配有效管理有限的系统资源。定时器服务虚拟和硬件定时器支持周期性任务和一次性事件触发。中断处理保证中断服务的快速响应同时保持任务的上下文安全。线程安全通过内核级保护机制防止多线程环境下的数据竞争和死锁。
3 同步与通信
3.1 通信 通信是指嵌入式系统中不同组件或任务之间交换信息的过程。有效的通信机制对于分布式系统和多处理器系统尤为重要。嵌入式系统中常用的通信方式包括
序号方法说明1消息队列Message Queues任务间通过发送和接收带有数据的消息来通信支持异步通信。2管道Pipes一种半双工的数据传输方式常用于进程间的通信。3共享内存Shared Memory多个任务可以直接读写同一块内存区域效率高但需要同步机制来避免冲突。4总线Buses如 I2C、SPI、UART等硬件接口用于设备间的数据传输。5远程过程调用RPC允许程序调用网络中另一台计算机上的子程序模拟本地调用。6中断Interrupts硬件触发的事件用于通知 CPU 处理紧急或外部事件是一种快速的通信方式。 同步和通信机制的选择取决于嵌入式系统的具体需求包括实时性、资源限制、复杂度以及系统的可靠性要求。合理设计同步和通信策略是保证嵌入式系统高效稳定运行的关键。
4 同步与通信
4.1 消息队列 消息队列允许线程间安全地传递固定大小的消息提供了异步通信的方式。
4.1.1 定义 消息队列允许线程安全地发送和接收固定大小的数据块。队列维护发送和接收的顺序。一般在文件开头会看到这样的定义osMessageQDef。
代码
// 定义一个名为app_test1_queue的消息队列可存储128个uint32_t类型的元素。
osMessageQDef(app_test1_queue, 128, uint32_t);// 声明一个osMessageQId类型的变量app_test1_queue_id用于保存消息队列的句柄。
// 在程序运行时需要通过调用相关API初始化并获取有效的句柄值。
osMessageQId app_test1_queue_id NULL;这段代码首先使用 osMessageQDef 宏定义了一个名为 app_test1_queue 的消息队列它可以存储128个32位无符号整数。然后声明了一个变量 app_test1_queue_id 用于存储消息队列的标识符句柄初始值设为 NULL 。在实际应用中需要通过操作系统提供的API来初始化这个消息队列并将返回的句柄赋值给app_test1_queue_id 。
/*** 定义一个消息队列。* * 这个宏用于静态定义一个消息队列它会创建一个静态队列控制块和一个用于存储消息的数据缓冲区。* * param name 消息队列的名称。* param queue_sz 队列中能容纳的消息数量。* param type 消息队列中每条消息的数据类型。*/
#define osMessageQDef(name, queue_sz, type) \
static StaticQueue_t os_mq_cb_##name; \
static uint32_t os_mq_data_##name[(queue_sz) * sizeof(type)]; \
const osMessageQDef_t os_messageQ_def_##name \
{ (queue_sz), \{ NULL, 0U, (os_mq_cb_##name), sizeof(StaticQueue_t), \(os_mq_data_##name), sizeof(os_mq_data_##name) } }此宏定义了三个静态变量一个静态队列控制块一个消息数据数组和一个用于OS的消息队列定义结构体。这个结构体包含了队列的大小、指针到静态队列控制块和消息数据数组的地址以及这些数组的大小。这使得在系统运行时能够直接使用这个消息队列而无需动态分配内存。
参数/函数讲解
序号参数/函数说明1osMessageQId声明变量用于存储消息队列的标识符句柄初始值设为NULL。2osMessageQDef定义了静态变量静态队列控制块消息数据数组和用于OS的消息队列定义结构体
4.1.2 创建 通过 osMessageQueueCreate() 函数创建消息队列指定队列容量和消息大小。
代码
/*** 初始化app_test1_queue消息队列。** 这个函数负责创建名为app_test1_queue的消息队列并将成功创建的句柄保存到全局变量app_test1_queue_id。* 如果消息队列创建失败它会记录错误信息并返回-1。** return* - 0: 消息队列创建成功。* - -1: 创建消息队列失败。*/
static int32_t app_test1_queue_init(void)
{// 使用osMessageCreate函数创建消息队列并将句柄保存到全局变量app_test1_queue_id osMessageCreate(osMessageQ(app_test1_queue), NULL);// 检查创建是否成功如果失败则打印错误信息并返回-1if (app_test1_queue_id NULL) {TRACE(0, Failed to Create app_test_thread1_queue);return -1;}// 创建成功返回0return 0;
}这段代码定义了一个名为 app_test1_queue_init 的静态函数用于初始化之前定义的消息队列app_test1_queue 。它通过调用o sMessageCreate 函数创建消息队列并检查返回的句柄是否有效。如果创建失败它会记录错误信息并返回 -1 否则返回 0 表示成功。
参数/函数讲解
序号参数/函数说明1osMessageCreate创建消息队列
4.1.3发送消息 使用 osMessageQueueSend() 或 osMessageQueuePut() 函数向队列发送消息。
代码
/*** 尝试向app_test1_queue中发送消息。** 此函数检查消息队列是否有足够的空间接收至少6条消息。如果队列有足够空间* 它将向队列中放入一个值为0xFF的消息不设置优先级。** 注意这个函数没有处理消息队列满的情况因此在队列满时不会阻塞。*/
void app_test1_queue_put(void)
{// 检查消息队列是否有超过5个空闲槽位if (osMessageGetSpace(app_test1_queue_id) 5) {// 向消息队列app_test1_queue_id中插入一个值为0xFF的消息优先级设为0osMessagePut(app_test1_queue_id, 0xFF, 0);}
}这个函数 app_test1_queue_put 尝试将一个值为 0xFF 的消息放入名为 app_test1_queue 的消息队列中。首先它检查队列是否有足够的空间容纳至少6个新消息。如果满足条件就调用 osMessagePut 将消息放入队列否则不做任何操作。注意这个函数没有处理队列已满的情况所以如果队列已满消息将不会被发送也不会阻塞调用线程。
参数/函数讲解
序号参数/函数说明1osMessageGetSpace检查消息队列的空闲槽位2osMessagePut将消息放入队列
4.2 邮箱处理 邮箱是用于线程间交换结构化数据的对象池。每个邮箱包含一组预先分配的内存块线程可以申请、发送和接收这些内存块。
4.2.1 定义 一般在文件开头会看到这样的定义osMailQDef 。
代码
osMailQDef (app_test1_mailbox, APP_TEST1_MAX_MAILBOX, APP_TEST1_MAIL);
/*** app_test1_mailbox: 邮箱队列定义** 使用osMailQDef宏定义一个名为app_test1_mailbox的邮箱队列最大邮件数为APP_TEST1_MAX_MAILBOX* 邮件类型为APP_TEST1_MAIL。*/// 邮箱队列ID用于后续操作
static osMailQId app_test1_mailbox_id NULL;/*** app_test1_mail_alloc - 分配并初始化一个APP_TEST1_MAIL类型的邮件** param mail 指向邮件指针的指针用于存放新分配的邮件地址。** 返回值: 成功分配时返回0失败则返回非0值。** 此函数为内部使用负责从app_test1_mailbox邮箱队列中分配一个新的邮件并将其地址存储在* 输入参数mail指向的变量中。具体实现省略。*/
static int app_test1_mail_alloc(APP_TEST1_MAIL** mail)
{// ...
}osMailQDef 定义了一个名为 app_test1_mailbox 的邮箱队列用于存储 APP_TEST1_MAIL 类型的数据。APP_TEST1_MAX_MAILBOX 定义了邮箱队列可容纳的最大邮件数量。这个邮箱队列可以用于多线程或任务之间的数据通信确保数据安全地传递。
/*** 定义一个邮箱队列。* * 该宏用于静态定义一个邮箱队列以及相关的OS邮箱队列结构体。它为指定的邮箱队列分配内存* 并初始化OS邮箱队列结构体。* * param name 邮箱队列的名称。* param queue_sz 邮箱队列中邮件的最大数量。* param type 邮件中元素的类型。*/
#define osMailQDef(name, queue_sz, type) \
static uint32_t os_mailQ_m_##name[3((sizeof(type)3)/4)*(queue_sz)]; \
osMailQDef_t os_mailQ_def_##name \
{ {(queue_sz), sizeof(type), (os_mailQ_m_##name)}, NULL, {NULL} }在上述宏定义中 1 第一部分定义了一个静态数组 os_mailQ_m_##name用于存储邮箱队列中的邮件。数组大小根据邮件类型 type 的大小和队列大小 queue_sz 动态计算得出。 2 第二部分定义了一个 osMailQDef_t 类型的结构体 os_mailQ_def_##name其中包含了邮箱队列的配置信息如队列大小、邮件类型大小以及邮件存储区的指针。
参数/函数讲解
序号参数/函数说明1osMailQDef定义了的邮箱队列用于存储 APP_TEST1_MAIL 类型的数据2app_test1_mailbox_id是一个全局变量用于存储邮箱队列的标识符方便后续操作3app_test1_mail_alloc用于从 app_test1_mailbox 中分配一个新的邮件并将分配的邮件地址通过参数 mail 返回4os_mailQ_m_##name用于存储邮箱队列中的邮件5osMailQDef_t定义结构体其中包含了邮箱队列的配置信息
4.2.2 创建 通过 osMailQCreate() 函数创建邮箱指定邮箱的大小和数据类型。
代码
/*** app_test1_mailbox_init - 初始化app_test1_mailbox邮箱队列** return: 成功初始化时返回0失败则返回-1。** 此函数用于初始化之前定义的app_test1_mailbox邮箱队列。它调用osMailCreate函数创建邮箱队列* 并将返回的邮箱ID存储在全局变量app_test1_mailbox_id中。如果创建失败函数会输出错误信息* Failed to Create app_test_thread1_mailbox并返回-1表示初始化失败。*/
static int32_t app_test1_mailbox_init(void)
{app_test1_mailbox_id osMailCreate(osMailQ(app_test1_mailbox), NULL);if (app_test1_mailbox_id NULL) {TRACE(0, Failed to Create app_test_thread1_mailbox);return -1;}return 0;
}这个函数 app_test1_mailbox_init 负责初始化之前通过 osMailQDef 宏定义的 app_test1_mailbox 邮箱队列。如果初始化成功它将返回0如果失败即无法创建邮箱队列它会打印错误信息并返回-1。
参数/函数讲解
序号参数/函数说明1osMailCreate创建邮箱队列
4.2.3 发送/释放邮件 使用 osMailQAlloc() 分配邮箱中的空间然后用 osMailPut() 发送邮件。
代码
/*** app_test1_mail_send - 发送一个APP_TEST1_MAIL类型的邮件到app_test1_mailbox** param mail 需要发送的邮件对象指针。** 返回值: 成功发送时返回0失败则返回非0值。** 此函数用于将一个APP_TEST1_MAIL类型的邮件对象发送到app_test1_mailbox邮箱队列中。* 具体实现省略可能涉及到邮箱队列的同步原语以保证线程安全。*/
static int app_test1_mail_send(APP_TEST1_MAIL* mail)
{// ...
}/*** app_test1_mail_free - 释放app_test1_mailbox中的一个邮件对象** param mail_p 已分配的邮件对象指针。** 返回值: 成功释放时返回0失败则返回非0值。** 此函数用于释放app_test1_mailbox邮箱队列中已分配的一个邮件对象以便于后续再使用。* 具体实现省略可能涉及邮箱队列的同步原语以保证线程安全。*/
static int app_test1_mail_free(APP_TEST1_MAIL* mail_p)
{// ...
}参数/函数讲解
序号参数/函数说明1app_test1_mail_send用于向 app_test1_mailbox 邮箱队列中发送邮件2app_test1_mail_free用于向 app_test1_mailbox 邮箱队列中释放已分配的邮件
4.2.4 获取邮件 线程通过 osMailGet() 函数获取邮件可以选择等待或立即返回。
代码
/*** brief 获取应用测试1的邮件对象* * description 该函数从内部数据结构中获取一个APP_TEST1_MAIL类型的邮件对象。* 如果邮件可用它将分配内存并填充邮件内容然后将其指针返回。* * param[out] mail_p 指向接收APP_TEST1_MAIL结构体指针的指针。* 如果成功获取邮件此参数将被设置为有效邮件对象的指针。* * return 成功获取邮件对象返回0否则返回非0错误代码* -1邮件队列为空* -2内存分配失败* 其他值可能表示其他错误情况** note 实现应考虑线程安全可能需要加锁来保护数据结构。* 如果队列为空可以选择阻塞等待直到有新邮件到达。*/
static int app_test1_mail_get(APP_TEST1_MAIL** mail_p)
{// 实现获取邮件对象的逻辑包括检查队列、分配内存、填充邮件内容等// ...if (/* 邮件队列为空或分配内存失败等错误条件 */) {return -1; // 或者 -2}return 0; // 成功获取邮件
}app_test1_mail_get 函数用于从 app_test1_mailbox 邮箱队列中取出一个邮件对象。当邮箱队列为空时函数可能阻塞等待直到有新的邮件可供消费。函数返回0表示成功获取邮件非0值表示队列为空或出现错误。具体实现细节被省略实际操作中可能需要考虑线程同步问题。
参数/函数讲解
序号参数/函数说明1app_test1_mail_get用于从邮箱队列中取出一个邮件对象 【系列文章索引】 总结 感谢观看这里就是 同步与通信篇 – 消息队列和邮箱处理如果觉得有帮助请给文章点个赞吧让更多的人看到。 也欢迎你关注我。 原创不易还希望各位大佬支持一下你们的点赞、收藏和留言对我真的很重要 最后本文仍有许多不足之处欢迎各位认真读完文章的小伙伴们随时私信交流、批评指正下期再见。 更多专栏订阅: 【LeetCode题解持续更新中】 【恒玄BES】 【鸿蒙系统】 【蓝牙协议栈】 【死机分析】 【Python脚本笔记】 【Java Web项目构建过程】 【微信小程序开发教程】 ⚽ 【JavaScript随手笔记】 【大数据学习笔记华为云】 【程序错误解决方法建议收藏】 【Git 学习笔记】 【软件安装教程】 订阅更多你们将会看到更多的优质内容
