rust嵌入式开发之基于await构造应用级临界区

2024-04-14 06:44

本文主要是介绍rust嵌入式开发之基于await构造应用级临界区,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在rust嵌入式开发之await一文中我们讨论了如何用await来实现异步操作的串行化。而并发编程时还有一个更重要的问题需要我们解决:资源竞争。

针对并发时的资源竞争,最简单的办法就是利用系统提供的临界区机制来互斥的使用资源。嵌入式rust提供了critical-section来提供临界区的原语,同时在cortex-m这样的crate中都加以了实现。

嵌入式的临界区有几种实现方式:

  • 单核无系统,关闭中断
  • 多核无系统,关闭中断加核心间的硬件自旋锁
  • ROTS,由系统以库函数/系统调用的方式提供

可以看到,临界区必须在硬件/或控制了硬件的系统【如rust的tock、c的rt-thread等】的支持下实现。如果没有系统,就只能通过关中断来实现互斥访问。

Embassy目前还只是一个有限的运行时,还不是一个ROTS,提供不了系统级的临界区。这就导致在用Embassy开发时,在需要用临界区解决资源竞争时必须快进快出,而无法用在串行化交互这种需要长期持有资源的场景中了,如通过RS485总线同时管理多台设备。

针对这个问题,笔者就考虑如何在应用层面提供不需要关中断就可以实现临界区保护的互斥锁。实质上,就是基于Embassy运行时来实现应用层面的互斥锁。

锁协议

嵌入式的应用场景比较简单,所以直接借鉴java的synchronized语义,即对象级的读写互斥锁,不支持共享读。其实,就嵌入式的应用来说,过于复杂的锁协议也没啥必要,属于过渡设计了。

此外,由于rust稳定版尚不支持异步闭包,所以锁的申请与释放必须分开。当然,对于FnOnce的闭包可以提供with来简化,但由于我们设计互斥锁的目的主要是用于异步串行化的资源长期持有,所以with语句用途有限。

所以呢,可长期持有的互斥锁的锁协议为:

  • 一个数据对象【代表一个资源】用一个可长期持有的锁来提供互斥性的临界区保护
  • 可长期持有的锁,应该有可配置的超时间隔
  • 可长期持有的锁允许竞争性申请,申请到锁的任务方可操作对应的受保护资源
  • 未申请到锁的任务应等待直至超时退出锁的竞争
  • 申请到锁的任务操作完毕后,应主动释放锁
  • 当锁释放时,如果有等待的任务,从中挑选一个授予锁

在锁的持有期内,完全可以执行各种await操作。

实现

由于笔者写的项目为商业项目,无法直接贴出源码,所以我们主要讨论原理并辅以说明性的伪码。

实现原理非常简单:

1、主要依托上篇文章讨论过的await机制,以Embassy运行时为基础来实现锁的超时与竞争调度

2、利用Embassy/嵌入式rust所提供的CriticalSectionRawMutex来保护对锁本身的操作,避免锁操作期间的再入问题

锁对象本身的定义非常简单:

pub struct Lock {//锁的内部数据,主要包括两个部分://1、前篇文章中所提到的用于awake机制的waker等任务调度信息数据//2、竞争锁的排队数据,我是用BTreeMap来管理排队inner: _Lock,//由于锁的申请存在竞争,所以这两类锁的内部数据也是需要保护的,我用了CriticalSectionRawMutex//其可以提供跨线程的保护,也就是可以在中断中一样使用,在我使用的STM32F413芯片中其实就是关中断//所以所有的锁操作必须快进快出,要求尽可能的简短lock: Mutex<CriticalSectionRawMutex, bool>,
}

主要用来提供锁接口并实现对锁对象本身的互斥操作。

_Lock是锁实体,其主要提供对申请锁Future的管理,包括当前持有锁的Future、Future的ID管理以及所有申请锁的请求者队列管理。这些功能都很常规,我们无需赘述。

对_Lock的操作需要用CriticalSectionRawMutex进行保护,以避免再入。

申请锁的Future的poll函数示意如下:

fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {let id = self.id;//首先检查自己能否在竞争中获胜赢得锁if self.lock.check(id) {//竞争获胜Poll::Ready(LockCode::OK(id))}else if !self.polled {//第一次参加竞争,但失败了,需要准备waker,并设置超时。可参考上篇文章self.polled = true;let w: &core::task::Waker = cx.waker();self.waker = Some(w.clone());embassy_time_queue_driver::schedule_wake(self.expires_at.as_ticks(), w);Poll::Pending}else if self.expires_at <= Instant::now() {//超时了self.lock.remove(id);Poll::Ready(LockCode::Timeout)}else{//理论上执行不到,只是总得有个返回值Poll::Pending}
}

我们再看一下锁的check函数的竞争逻辑:

fn check(&self, id: u64) -> bool {//锁对象的操作需要用CriticalSectionRawMutex进行保护以避免再入self.lock(|p|{if p.current == id {//被唤醒并进行检查的Future,就是锁的持有者true}else if p.current == 0 {//锁目前没有人持有,所以立刻将锁变更为自己持有p.current = id;true}else{false}})
}

大家在编写Future的poll函数时必须牢记:一个waker只会执行一次

Waker的wake函数会自动删除自己:

// Don't call `drop` -- the waker will be consumed by `wake`.
crate::mem::forget(self);

所以我在这里所写的poll函数最多有两次执行机会:

  • Future创建后被第一次调度执行poll函数,此时如果锁没有持有者,则本Future将获得锁,此时就执行一次
  • 如果锁已经被其它Future持有,本Future就将被安排等待,这是第一次执行
  • 等待中的Future有两种可能被wake【超时、或锁被释放后自己被选中】,这是第二次执行

大家再看下poll函数,就会发现有一种状态是可以执行第三次的啊,即:check失败 + 已经poll过了 + 未超时。但这种情况我们必须避免出现。因为waker只能执行一次,如果出现这样的情况,这个Future将因为再无法被wake,而永远沉睡在系统任务队列中了。所以我们就需要设法防止这种状态的出现。

因此,在某Future被选中唤醒时,锁管理就会将锁先行授予该Future。即:

if let Some(w) = &n.waker {//这使得被wake后执行poll函数的check时,直接命中【p.current == id】而poll成功pb.current = n.id;w.clone().wake();
}

最后,获得锁后必须显式释放:

//获得锁对象,嵌入式比较简单,可以直接用静态的对象,但由于并发,所获得的锁对象不能是&mut
//这就要求锁的操作都不能是&mut self,而必须是&'self,这就是我们为什么需要外封装的原因
let lo = get_lock_...锁名...();
//竞争锁,10秒超时
let (rc, id, rd) = lo.wait(Duration::from_secs(10)).await;
if rc {if let Some(md) = rd {//在我的实现中,锁和待保护对象进行了泛型化的融合,md就是取到的数据对象...md是&mut的,所以可以进行修改等所有需要的操作...//还可以执行各种异步操作Timer::after_millis(1300).await;//必须显式释放锁,获取失败的id是0,即便调用release也无效lo.release(id);}
}else{//超时,可以在此执行容错处理
}
结语

以上,我们就获得了一个轻便而可靠的应用级的临界区互斥锁。

有了锁,我们就可以根据需要来对静态数据、融入泛型结构中提供数据保护了。

这篇关于rust嵌入式开发之基于await构造应用级临界区的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/902341

相关文章

这15个Vue指令,让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件,按住 Control 和回车键再显示它吗?小菜一碟: <template

中文分词jieba库的使用与实景应用(一)

知识星球:https://articles.zsxq.com/id_fxvgc803qmr2.html 目录 一.定义: 精确模式(默认模式): 全模式: 搜索引擎模式: paddle 模式(基于深度学习的分词模式): 二 自定义词典 三.文本解析   调整词出现的频率 四. 关键词提取 A. 基于TF-IDF算法的关键词提取 B. 基于TextRank算法的关键词提取

水位雨量在线监测系统概述及应用介绍

在当今社会,随着科技的飞速发展,各种智能监测系统已成为保障公共安全、促进资源管理和环境保护的重要工具。其中,水位雨量在线监测系统作为自然灾害预警、水资源管理及水利工程运行的关键技术,其重要性不言而喻。 一、水位雨量在线监测系统的基本原理 水位雨量在线监测系统主要由数据采集单元、数据传输网络、数据处理中心及用户终端四大部分构成,形成了一个完整的闭环系统。 数据采集单元:这是系统的“眼睛”,

Hadoop企业开发案例调优场景

需求 (1)需求:从1G数据中,统计每个单词出现次数。服务器3台,每台配置4G内存,4核CPU,4线程。 (2)需求分析: 1G / 128m = 8个MapTask;1个ReduceTask;1个mrAppMaster 平均每个节点运行10个 / 3台 ≈ 3个任务(4    3    3) HDFS参数调优 (1)修改:hadoop-env.sh export HDFS_NAMENOD

csu 1446 Problem J Modified LCS (扩展欧几里得算法的简单应用)

这是一道扩展欧几里得算法的简单应用题,这题是在湖南多校训练赛中队友ac的一道题,在比赛之后请教了队友,然后自己把它a掉 这也是自己独自做扩展欧几里得算法的题目 题意:把题意转变下就变成了:求d1*x - d2*y = f2 - f1的解,很明显用exgcd来解 下面介绍一下exgcd的一些知识点:求ax + by = c的解 一、首先求ax + by = gcd(a,b)的解 这个

hdu1394(线段树点更新的应用)

题意:求一个序列经过一定的操作得到的序列的最小逆序数 这题会用到逆序数的一个性质,在0到n-1这些数字组成的乱序排列,将第一个数字A移到最后一位,得到的逆序数为res-a+(n-a-1) 知道上面的知识点后,可以用暴力来解 代码如下: #include<iostream>#include<algorithm>#include<cstring>#include<stack>#in

嵌入式QT开发:构建高效智能的嵌入式系统

摘要: 本文深入探讨了嵌入式 QT 相关的各个方面。从 QT 框架的基础架构和核心概念出发,详细阐述了其在嵌入式环境中的优势与特点。文中分析了嵌入式 QT 的开发环境搭建过程,包括交叉编译工具链的配置等关键步骤。进一步探讨了嵌入式 QT 的界面设计与开发,涵盖了从基本控件的使用到复杂界面布局的构建。同时也深入研究了信号与槽机制在嵌入式系统中的应用,以及嵌入式 QT 与硬件设备的交互,包括输入输出设

OpenHarmony鸿蒙开发( Beta5.0)无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息,即可快速实现设备配网,是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递,利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力,实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后,即可发送相关配网数据。同时还支持与常规Sof

zoj3820(树的直径的应用)

题意:在一颗树上找两个点,使得所有点到选择与其更近的一个点的距离的最大值最小。 思路:如果是选择一个点的话,那么点就是直径的中点。现在考虑两个点的情况,先求树的直径,再把直径最中间的边去掉,再求剩下的两个子树中直径的中点。 代码如下: #include <stdio.h>#include <string.h>#include <algorithm>#include <map>#

活用c4d官方开发文档查询代码

当你问AI助手比如豆包,如何用python禁止掉xpresso标签时候,它会提示到 这时候要用到两个东西。https://developers.maxon.net/论坛搜索和开发文档 比如这里我就在官方找到正确的id描述 然后我就把参数标签换过来