Linux学习第19天:Linux并发与竞争实例: 没有规矩不成方圆

news2024/11/17 21:16:19

Linux版本号4.1.15   芯片I.MX6ULL                                    大叔学Linux    品人间百味  思文短情长


        先说点题外话,上周参加行业年会,停更了一周。接下来的周五就要开启国庆中秋双节模式,所以有的时候,尤其是工作以后想要好好的学习点东西,是多么的难。并且学习必须是一个连续的过程。大家可能会有这样的体会,本来做研发的过程中,突然临时领导分配其他的工作,并且要立马去做的。当集中几天精力完成了领导的任务再回头去看原来手里的工作时,发现有很多东西都记不太清了。这也是我很头疼的一个问题,大家有好的建议或是处理方法可以评论区给我留言。


        本篇笔记主要是学习并发和竞争的实例,主要内容包括原子操作、自旋锁操作、信号量和互斥体

        本笔记的思维导图很简单,如下:

一、原子操作

        本节要实现的功能是利用原子操作来实现对LED设备的互斥操作。

32 /* gpioled 设备结构体 */
33 struct gpioled_dev{
34 dev_t devid; /* 设备号 */
35 struct cdev cdev; /* cdev */
36 struct class *class; /* 类 */
37 struct device *device; /* 设备 */
38 int major; /* 主设备号 */
39 int minor; /* 次设备号 */
40 struct device_node *nd; /* 设备节点 */
41 int led_gpio; /* led 所使用的 GPIO 编号 */
42 atomic_t lock; /* 原子变量 */
43 };

        第 42 行,原子变量 lock,用来实现一次只能允许一个应用访问 LED 灯, led_init 驱动入口函数会将 lock 的值设置为 1。

54 static int led_open(struct inode *inode, struct file *filp)
55 {
56 /* 通过判断原子变量的值来检查 LED 有没有被别的应用使用 */
57 if (!atomic_dec_and_test(&gpioled.lock)) {
58 atomic_inc(&gpioled.lock);/* 小于 0 的话就加 1,使其原子变量等于 0 */
59 return -EBUSY; /* LED 被使用,返回忙 */
60 }
61
62 filp->private_data = &gpioled; /* 设置私有数据 */
63 return 0;
64 }

        第 57~60 行,每次调用 open 函数打开驱动设备的时候先申请 lock,如果申请成功的话就表
示 LED灯还没有被其他的应用使用,如果申请失败就表示 LED灯正在被其他的应用程序使用。
        每次打开驱动设备的时候先使用 atomic_dec_and_test 函数将 lock 减 1,如果 atomic_dec_and_test函数返回值为真就表示 lock 当前值为 0,说明设备可以使用。如果 atomic_dec_and_test 函数返回值为假,就表示 lock 当前值为负数(lock 值默认是 1), lock 值为负数的可能性只有一个,那就是其他设备正在使用 LED。其他设备正在使用 LED 灯,那么就只能退出了,在退出之前调用函数 atomic_inc 将 lock 加 1,因为此时 lock 的值被减成了负数,必须要对其加 1,将 lock 的值变为 0。

        上面一段说的可能有点绕,总的意思就是要想要先申请

111 * @description : 关闭/释放设备
112 * @param – filp : 要关闭的设备文件(文件描述符)
113 * @return : 0 成功;其他 失败
114 */
115 static int led_release(struct inode *inode, struct file *filp)
116 {
117 struct gpioled_dev *dev = filp->private_data;
118
119 /* 关闭驱动文件的时候释放原子变量 */
120 atomic_inc(&dev->lock);
121 return 0;
122 }

        第 120 行, LED 灯使用完毕,应用程序调用 close 函数关闭的驱动文件, led_release 函数执行,调用 atomic_inc 释放 lcok,也就是将 lock 加 1。

142 /* 初始化原子变量 */
143 atomic_set(&gpioled.lock, 1); /* 原子变量初始值为 1 */

        第 143 行,初始化原子变量 lock,初始值设置为 1,这样每次就只允许一个应用使用 LED
灯。

        在测试的APP中有如下程序:

62 /* 模拟占用 25S LED */
63 while(1) {
64 sleep(5);
65 cnt++;
66 printf("App running times:%d\r\n", cnt);
67 if(cnt >= 5) break;
68 }

        第 63~68 行的模拟占用 25 秒 LED 的代码。测试 APP 在获取到 LED 灯驱动的使用权以后会使用 25S,在使用的这段时间如果有其他的应用也去获取 LED 灯使用权的话肯定会失败!

二、自旋锁

        自旋锁保护的临界区要尽可能的短。

        考虑驱动的兼容性,合理的选择 API 函数。

33 /* gpioled 设备结构体 */
34 struct gpioled_dev{
35 dev_t devid; /* 设备号 */
36 struct cdev cdev; /* cdev */
37 struct class *class; /* 类 */
38 struct device *device; /* 设备 */
39 int major; /* 主设备号 */
40 int minor; /* 次设备号 */
41 struct device_node *nd; /* 设备节点 */
42 int led_gpio; /* led 所使用的 GPIO 编号 */
43 int dev_stats; /* 设备状态, 0,设备未使用;>0,设备已经被使用 */
44 spinlock_t lock; /* 自旋锁 */
45 };

        第 43 行, dev_stats 表示设备状态,如果为 0 的话表示设备还没有被使用,如果大于 0 的
话就表示设备已经被使用了。第 44 行,定义自旋锁变量 lock。

56 static int led_open(struct inode *inode, struct file *filp)
57 {
58 unsigned long flags;
59 filp->private_data = &gpioled; /* 设置私有数据 */
60
61 spin_lock_irqsave(&gpioled.lock, flags); /* 上锁 */
62 if (gpioled.dev_stats) { /* 如果设备被使用了 */
63 spin_unlock_irqrestore(&gpioled.lock, flags); /* 解锁 */
64 return -EBUSY;
65 }
66 gpioled.dev_stats++; /* 如果设备没有打开,那么就标记已经打开了 */
67 spin_unlock_irqrestore(&gpioled.lock, flags);/* 解锁 */
68
69 return 0;
70 }

        第 61~67 行,使用自旋锁实现对设备的互斥访问,第 61 行调用 spin_lock_irqsave 函数获
取锁,为了考虑到驱动兼容性,这里并没有使用 spin_lock 函数来获取锁。第 62 行判断
dev_stats 是否大于 0,如果是的话表示设备已经被使用了,那么就调用 spin_unlock_irqrestore
函数释放锁,并且返回-EBUSY。如果设备没有被使用的话就在第 66 行将 dev_stats 加 1,表
示设备要被使用了,然后调用 spin_unlock_irqrestore 函数释放锁。自旋锁的工作就是保护
dev_stats 变量, 真正实现对设备互斥访问的是 dev_stats。

121 static int led_release(struct inode *inode, struct file *filp)
122 {
123 unsigned long flags;
124 struct gpioled_dev *dev = filp->private_data;
125
126 /* 关闭驱动文件的时候将 dev_stats 减 1 */
127 spin_lock_irqsave(&dev->lock, flags); /* 上锁 */
128 if (dev->dev_stats) {
129 dev->dev_stats--;
130 }
131 spin_unlock_irqrestore(&dev->lock, flags);/* 解锁 */
132
133 return 0;
134 }

        第 126~131 行,在 release 函数中将 dev_stats 减 1,表示设备被释放了,可以被其他的应用程序使用。将 dev_stats 减 1 的时候需要自旋锁对其进行保护。

150 static int __init led_init(void)
151 {
152 int ret = 0;
153
154 /* 初始化自旋锁 */
155 spin_lock_init(&gpioled.lock);
......
212 return 0;
213 }

        第 155 行,在驱动入口函数 led_init 中调用 spin_lock_init 函数初始化自旋锁。


三、信号量

        使用信号量实现了一次只能有一个应用程序访问 LED 灯,信号量可以导致休眠,因此信号量保护的临界区没有运行时间限制,可以在驱动的 open 函数申请信号量,然后在release 函数中释放信号量。但是信号量不能用在中断中。

14 #include <linux/semaphore.h>
33 /* gpioled 设备结构体 */
34 struct gpioled_dev{
35 dev_t devid; /* 设备号 */
36 struct cdev cdev; /* cdev */
37 struct class *class; /* 类 */
38 struct device *device; /* 设备 */
39 int major; /* 主设备号 */
40 int minor; /* 次设备号 */
41 struct device_node *nd; /* 设备节点 */
42 int led_gpio; /* led 所使用的 GPIO 编号 */
43 struct semaphore sem; /* 信号量 */
44 };

        第 43 行,在设备结构体中添加一个信号量成员变量 sem。

48 /*
49 * @description : 打开设备
50 * @param – inode : 传递给驱动的 inode
51 * @param - filp : 设备文件, file 结构体有个叫做 private_data 的成员变量
52 * 一般在 open 的时候将 private_data 指向设备结构体。
53 * @return : 0 成功;其他 失败
54 */
55 static int led_open(struct inode *inode, struct file *filp)
56 {
57 filp->private_data = &gpioled; /* 设置私有数据 */
58
59 /* 获取信号量,进入休眠状态的进程可以被信号打断 */
60 if (down_interruptible(&gpioled.sem)) {
61 return -ERESTARTSYS;
62 }
63 #if 0
64 down(&gpioled.sem); /* 不能被信号打断 */
65 #endif
66
67 return 0;
68 }

        第 60~65行,在 open函数中申请信号量,可以使用 down 函数,也可以使用 down_interruptible函数。如果信号量值大于等于 1 就表示可用,那么应用程序就会开始使用 LED 灯。如果信号量值为 0 就表示应用程序不能使用 LED 灯,此时应用程序就会进入到休眠状态。等到信号量值大于 1 的时候应用程序就会唤醒,申请信号量,获取 LED 灯使用权。

114 /*
115 * @description : 关闭/释放设备
116 * @param – filp : 要关闭的设备文件(文件描述符)
117 * @return : 0 成功;其他 失败
118 */
119 static int led_release(struct inode *inode, struct file *filp)
120 {
121 struct gpioled_dev *dev = filp->private_data;
122
123 up(&dev->sem); /* 释放信号量,信号量值加 1 */
124
125 return 0;
126 }

        第 123 行,在 release 函数中调用 up 函数释放信号量,这样其他因为没有得到信号量而进
入休眠状态的应用程序就会唤醒,获取信号量。

142 static int __init led_init(void)
143 {
144 int ret = 0;
145
146 /* 初始化信号量 */
147 sema_init(&gpioled.sem, 1);
......
204 return 0;
205 }

        第 147 行,在驱动入口函数中调用 sema_init 函数初始化信号量 sem 的值为 1,相当于 sem
是个二值信号量。

四、互斥体

33 /* gpioled 设备结构体 */
34 struct gpioled_dev{
35 dev_t devid; /* 设备号 */
36 struct cdev cdev; /* cdev */
37 struct class *class; /* 类 */
38 struct device *device; /* 设备 */
39 int major; /* 主设备号 */
40 int minor; /* 次设备号 */
41 struct device_node *nd; /* 设备节点 */
42 int led_gpio; /* led 所使用的 GPIO 编号*/
43 struct mutex lock; /* 互斥体 */
44 };

        第 43 行,定义互斥体 lock。

55 static int led_open(struct inode *inode, struct file *filp)
56 {
57 filp->private_data = &gpioled; /* 设置私有数据 */
58
59 /* 获取互斥体,可以被信号打断 */
60 if (mutex_lock_interruptible(&gpioled.lock)) {
61 return -ERESTARTSYS;
62 }
63 #if 0
64 mutex_lock(&gpioled.lock); /* 不能被信号打断 */
65 #endif
66
67 return 0;
68 }

        第 60~65 行,在 open 函数中调用 mutex_lock_interruptible 或者 mutex_lock 获取 mutex,成功的话就表示可以使用 LED 灯,失败的话就会进入休眠状态,和信号量一样。

119 static int led_release(struct inode *inode, struct file *filp)
120 {
121 struct gpioled_dev *dev = filp->private_data;
122
123 /* 释放互斥锁 */
124 mutex_unlock(&dev->lock);
125
126 return 0;
127 }

        第 124 行,在 release 函数中调用 mutex_unlock 函数释放 mutex,这样其他应用程序就可以
获取 mutex 了。

143 static int __init led_init(void)
144 {
145 int ret = 0;
146
147 /* 初始化互斥体 */
148 mutex_init(&gpioled.lock);
......
205 return 0;
206 }

        第 148 行,在驱动入口函数中调用 mutex_init 初始化 mutex。

五、总结

        本片笔记主要是巩固上次课学习的并发和竞争相关内容,主要包括原子操作、自旋锁、信号量和互斥体。


本文为参考正点原子开发板配套教程整理而得,仅用于学习交流使用,不得用于商业用途。

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

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

相关文章

代码随想录算法训练营day6| 哈希表理论基础、242.有效的字母异位词、349. 两个数组的交集、202. 快乐数、1. 两数之和

目录 一、哈希表理论 hash function ​编辑hash collision 常见哈希结构 1&#xff09;set 2&#xff09;map 二、&#xff08;leetcode 242&#xff09;有效的字母异位词 三、&#xff08;leetcode 349&#xff09;两个数组的交集 四、&#xff08;leetcode 202&…

移动应用中的视频直播美颜sdk集成指南

在今天的移动应用生态系统中&#xff0c;视频直播已经成为了与用户互动、分享体验和传播信息的强大工具。与此同时&#xff0c;直播美颜技术也逐渐崭露头角&#xff0c;让直播主和用户在镜头前呈现出最佳状态。本文将为您提供一份详尽的指南&#xff0c;教您如何在移动应用中集…

Day56:组件库封装-TypeScript入门

配置 安装tsc工具进行编译 npm i typescript -g 查看版本号&#xff1a;tsc -v 编译ts代码-需要使用tsc编译之后才能运行&#xff0c;TS为JS的衍生&#xff0c;浏览器不能直接识别TS语法&#xff1a;tsc xxx.ts 运行ts代码&#xff1a;node xxx.js 或者直接运行ts代码——t…

怎么将aac转换成mp3格式?

怎么将aac转换成mp3格式&#xff1f;AAC&#xff08;它的全称为Advanced Audio Coding&#xff09;是一种高级音频编码格式。它采用了数字音频压缩算法&#xff0c;旨在提供更高的音频质量和更低的比特率。AAC和Mp3一样都是一种有损压缩算法&#xff0c;通过移除人耳无法察觉的…

林木种苗生产vr虚拟实训教学降低培训等待周期

林业种植管理在保护水土流失、气候变化及经济社会发展中发挥重要的作用&#xff0c;林业教学往往需要进入林区进行实操察验&#xff0c;在安全性、时间及效率上难以把控&#xff0c;因此有更多林业畜牧院校创新性地引进VR虚拟现实技术。 在林业领域&#xff0c;实地调查是获取准…

【蓝桥杯选拔赛真题63】Scratch云朵降雨 少儿编程scratch图形化编程 蓝桥杯选拔赛真题解析

目录 scratch云朵降雨 一、题目要求 编程实现 二、案例分析 1、角色分析

批量查询中通快递单号,高效省时

您是否曾经为了查询多个中通快递单号而感到烦恼&#xff1f;传统的查询方式需要您一个个手动输入单号&#xff0c;不仅费时还容易出错。现在&#xff0c;有一个简单的方法可以解决这个问题&#xff0c;那就是使用固乔快递查询助手软件进行批量查询。下面就让我们一起来了解具体…

DockerKubernetes ❀ Service下Port端口区分

文章目录 概述案例 概述 在Kubernetes中&#xff0c;Service&#xff08;svc&#xff09;是一种抽象机制&#xff0c;用于将一组 Pod 暴露给其他应用程序或服务。Service 可以有三种类型的端口&#xff1a; nodePort&#xff1a;这是 Service 在节点上公开的端口。可以使用此…

Quartz 体系结构

Quartz的体系结构 Quartz的重要组件 Scheduler 用于与调度程序交互的主程序接口。 Scheduler调度程序-任务执行计划表&#xff0c;只有安排进执行计划的任务Job&#xff08;通过scheduler.scheduleJob方法安排进执行计划&#xff09;&#xff0c;当它预先定义的执行时间到了的时…

25626-2018 冲击压路机 课堂随笔

声明 本文是学习GB-T 25626-2018 冲击压路机. 而整理的学习笔记,分享出来希望更多人受益,如果存在侵权请及时联系我们 1 范围 本标准规定了冲击压路机(以下简称压路机)的术语和定义&#xff0c;分类&#xff0c;要求&#xff0c;试验方法&#xff0c;检验规则&#xff0c;标…

Vue3+Elementplus引入面包屑功能

&#x1f341; 作者&#xff1a;知识浅谈&#xff0c;CSDN博客专家&#xff0c;阿里云签约博主&#xff0c;InfoQ签约博主&#xff0c;华为云云享专家&#xff0c;51CTO明日之星 &#x1f4cc; 擅长领域&#xff1a;全栈工程师、爬虫、ACM算法 &#x1f492; 公众号&#xff1a…

it设备系统联网监控

随着网络的兴起和应用的深入&#xff0c;网络安全问题日益突出。在这种环境下&#xff0c;IT网络监控应运而生。它就像一个无形的守护者&#xff0c;密切关注我们的网络空间&#xff0c;确保我们的信息安全。  简单来说&#xff0c;IT网络监控就是通过技术手段对网络进行实时…

Cookie 和 Session机制

Cookie HTTP 协议自身是属于 "无状态" 协议. "无状态" 的含义指的是: 默认情况下 HTTP 协议的客户端和服务器之间的这次通信, 和下次通信之间没有直接的联系. 但是实际开发中, 我们很多时候是需要知道请求之间的关联关系的. 例如登陆网站成功后, 第二次访…

C++ -- IO流

目录 C语言的输入与输出 CIO流 C标准IO流 C文件IO流 文件常见的打开方式如下 以二进制的形式操作文件 以文本的形式操作文件 读写结构体 stringstream的简单介绍 C语言的输入与输出 C语言中我们用到的最频繁的输入输出方式就是scanf ()与printf()。 scanf(): 从标准输…

“构建可靠的前端测试环境与主页搭建实践“

目录 引言1. Mock.js的安装配置及使用1.1 安装Mock.js1.2 引入mockjs造假数据 2. 主页搭建实践1.1 设计主页结构配置路由 总结 引言 在现代软件开发中&#xff0c;前端测试和主页搭建是至关重要的环节。本文将介绍如何使用Mock.js进行安装配置和使用&#xff0c;并探讨如何构建…

解决方案|法大大电子签:3招击破汽车销售效率及成本难题!

近日&#xff0c;国家发改委、工业和信息化部、公安部等13部门联合发布《关于促进汽车消费的若干措施》&#xff0c;进一步稳定和扩大汽车消费&#xff0c;优化汽车购买使用管理制度和市场环境&#xff0c;更大力度促进新能源汽车持续健康发展。主要措施包含支持老旧汽车更新消…

云原生Kubernetes:K8S资源控制之污点与容忍

目录 一、理论 1.污点 2.容忍 3. Pod启动阶段 4. 故障排除步骤 5.对节点执行维护操作 二、实验 1.污点 2.容忍 三、问题 1.pod上配置容忍生成资源报错 四、总结 一、理论 1.污点 &#xff08;1&#xff09;作用 节点亲和性,是Pod的一种属性(偏好或硬性要求) ,它…

基于Java的超市进销存系统springboot18

大家好✌&#xff01;我是CZ淡陌。一名专注以理论为基础实战为主的技术博主&#xff0c;将再这里为大家分享优质的实战项目&#xff0c;本人在Java毕业设计领域有多年的经验&#xff0c;陆续会更新更多优质的Java实战项目&#xff0c;希望你能有所收获&#xff0c;少走一些弯路…

软件测试内容整理

1. 软件测试 1.1. 定义 软件测试&#xff08;英语&#xff1a;Software Testing&#xff09;&#xff0c;描述一种用来促进鉴定软件的正确性、完整性、安全性和质量的过程。换句话说&#xff0c;软件测试是一种实际输出与预期输出之间的审核或者比较过程。 软件测试的经典定…

vue微前端qiankun框架学习到项目实战

微前端架构 一、什么是微前端架构 微前端是一种多个团队通过独立发布功能的方式来共同构建现代化web应用的技术手段及方法策略。 微前端借鉴了微服务的架构理念&#xff0c;将一个庞大的前端应用才分为多个独立灵活的小型应用&#xff0c;每个应用都可以独立开发&#…