同步---自旋锁

1 自旋锁的基本概念

自旋锁最多只能被一个可执行线程持有,如果一个执行线程试图获得一个已经被使用的自旋锁,那么该线程就会一直进行自旋,等待锁重新可用。在任何时刻,自旋锁都可以防止多余一个的执行线程同时进入临界区。

Linux内核实现的自旋锁是不可递归的,如果你请求一个你已经持有的自旋锁,那么你将会自旋,等待释放这个锁,由于自旋,释放这个锁的操作不会被执行,所以会一直处于自旋忙等待中,于是就被锁死了。

自旋锁可以在中断处理程序中使用。在中断处理程序中使用自旋锁时,一定要在获取锁之前,首先禁止本地中断(当前处理器上的中断请求),否则,中断处理程序就会打断正持有锁的内核代码,有可能试图去争用这个已经被持有的自旋锁,这样一来,中断处理程序就会自旋,但是锁的持有者在这个中断处理程序执行完毕前不可能运行,会造成死锁。注意,需要关闭的只是当前处理器上的中断,如果中断发生在不同的处理器上,即使中断处理程序在同一锁上自旋,也不会妨碍锁的持有者最终释放锁。

自旋锁的实现和体系结构体密切相关,代码往往通过汇编实现,这些与体系结构相关的代码定义在文件asm/spinlock.h中,实际需要用到的接口定义在文件linux/spinlock.h中,内核提供了对自旋锁的操作接口:
请添加图片描述

2 自旋锁在内核的实现

spinlock_t

自旋锁用spinlock_t的实例表示,spinlock_t定义在include/linux/spinlock_types.h

typedef struct spinlock {union {struct raw_spinlock rlock;#ifdef CONFIG_DEBUG_LOCK_ALLOC
# define LOCK_PADSIZE (offsetof(struct raw_spinlock, dep_map))struct {u8 __padding[LOCK_PADSIZE];struct lockdep_map dep_map;};
#endif};
} spinlock_t;

spinlock_t由raw_spinlock表示,该类型和spinlock_t定义在同一个文件中:

typedef struct raw_spinlock {arch_spinlock_t raw_lock;
#ifdef CONFIG_GENERIC_LOCKBREAKunsigned int break_lock;
#endif
#ifdef CONFIG_DEBUG_SPINLOCKunsigned int magic, owner_cpu;void *owner;
#endif
#ifdef CONFIG_DEBUG_LOCK_ALLOCstruct lockdep_map dep_map;
#endif
} raw_spinlock_t;

raw_spinlock由arch_spinlock_t 表示,arch_spinlock_t的实现与体系结构相关,所以spinlock_t的实现与体系结构相关,我们看arm实现的代码,在文件arch/arm/include/asm/spinlock_types.h中:

typedef struct {union {u32 slock;struct __raw_tickets {
#ifdef __ARMEB__u16 next;u16 owner;
#elseu16 owner;u16 next;
#endif} tickets;};
} arch_spinlock_t;

owner表示持有这个数字的thread可以获得自旋锁,next表示如果后续再有thread请求获取这个自旋锁,就给他分配这个数字。

spinlock的实现原理:

  1. 刚开始owner=next=0
  2. 第一个thread获取spinlock,可获取成功,此时owner=0,next=0
  3. 第二个thread获取spinlock,如果第一个thread还没有释放spinlock,则next++,next变为1
  4. 第三个thread获取spinlock,如果第一个thread还没有释放spinlock,则next++,next就变为2
  5. 此时第一个thread释放spinlock,则执行owner++,owner=1
  6. 虽然此时第二个thread和第三个thread都在等待spinlock,但是因为第二个thread的next=owner,所以第二个thread可以获取spinlock,第三个spinlock继续等待

这样保证了spinlock的唤醒机制是先到先唤醒,后到后唤醒,保证了公平性。

spin_lock_init

spin_lock_init的定义在include/linux/spinlock.h中

#define spin_lock_init(_lock)				\
do {							\spinlock_check(_lock);				\raw_spin_lock_init(&(_lock)->rlock);		\
} while (0)

spin_lock_init只是对_lock做了一些检查,我们看raw_spin_lock_init的具体实现,只对spinlock_t中的rlock的初始化。raw_spin_lock_init的实现如下,lock是struct raw_spinlock类型

# define raw_spin_lock_init(lock)				\do { *(lock) = __RAW_SPIN_LOCK_UNLOCKED(lock); } while (0)
#endif
#define __RAW_SPIN_LOCK_UNLOCKED(lockname)	\(raw_spinlock_t) __RAW_SPIN_LOCK_INITIALIZER(lockname)#define __RAW_SPIN_LOCK_INITIALIZER(lockname)	\{					\.raw_lock = __ARCH_SPIN_LOCK_UNLOCKED,	\SPIN_DEBUG_INIT(lockname)		\SPIN_DEP_MAP_INIT(lockname) }

__ARCH_SPIN_LOCK_UNLOCKED的值与体系架构有关,在arm架构上:

#define __ARCH_SPIN_LOCK_UNLOCKED	{ { 0 } }

SPIN_DEBUG_INIT(lockname)、SPIN_DEP_MAP_INIT(lockname)是为了调试的,如果不调试什么都不做,所以spin_lock_init只是将互斥锁设置为没有被锁住的状态,即raw_lock的值设为__ARCH_SPIN_LOCK_UNLOCKED

spin_lock

spin_lock的实现在include/linux/spinlock.h中

static __always_inline void spin_lock(spinlock_t *lock)
{raw_spin_lock(&lock->rlock);
}#define raw_spin_lock(lock)	_raw_spin_lock(lock)

spin_lock在单核(up)和多核(smp)的实现不同。

up

在一个处理器下,在文件include/linux/spinlock_api_up.h中定义

#define _raw_spin_lock(lock)			__LOCK(lock)
#define __LOCK(lock) \do { preempt_disable(); ___LOCK(lock); } while (0)

只是关闭了抢占功能

smp

在多处理器下,在文件include/linux/spinlock_api_smp.h中定义

#define _raw_spin_lock(lock) __raw_spin_lock(lock)static inline void __raw_spin_lock(raw_spinlock_t *lock)
{preempt_disable();spin_acquire(&lock->dep_map, 0, 0, _RET_IP_);LOCK_CONTENDED(lock, do_raw_spin_trylock, do_raw_spin_lock);
}

__raw_spin_lock的实现靠do_raw_spin_lock

void do_raw_spin_lock(raw_spinlock_t *lock)
{debug_spin_lock_before(lock);arch_spin_lock(&lock->raw_lock);debug_spin_lock_after(lock);
}

可以看到do_raw_spin_lock的实现与体系结构有关,因为调用了arch_spin_lock,arch_spin_lock中会将next值加1,然后一直判断next和onwer是否相同,如果相同,则获取锁,进入临界区执行,否则会一直判断

所以spin_lock首先会禁止抢占,接着看能不能获得锁,如果能够获得锁,则进入临界区,不能获得,则一直判断,直到可以进去临界区。

spin_unlock

spin_unlock定义在include/linux/spinlock.h中

static __always_inline void spin_unlock(spinlock_t *lock)
{raw_spin_unlock(&lock->rlock);
}
#define raw_spin_unlock(lock)		_raw_spin_unlock(lock)

_raw_spin_unlock在多处理器(SMP)和单处理器(UP)的实现不同

up

在include/linux/spinlock_api_up.h中

#define _raw_spin_unlock(lock)			__UNLOCK(lock)#define __UNLOCK(lock) \do { preempt_enable(); ___UNLOCK(lock); } while (0)

仅仅允许抢占

smp

#define _raw_spin_unlock(lock) __raw_spin_unlock(lock)
static inline void __raw_spin_unlock(raw_spinlock_t *lock)
{spin_release(&lock->dep_map, 1, _RET_IP_);do_raw_spin_unlock(lock);preempt_enable();
}

spin_unlock在单处理器下,把抢占设为允许,在多处理器下,先将owner增加1,然后把抢占设为允许

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

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

相关文章

实习日志----4.播放时段参数设置

由于客户在下发广告时,一则广告可在多个时段播放,这就需要设置多个播放时段的参数。 但在这种情况下,我并不知道用户每次需要下发几个时段,所以前台不能设定死。 因此我要实现这么一个功能,让用户根据自己的需要来动态…

linux系统编程---线程总结

线程总结1 线程的实现线程创建线程退出线程等待线程清理2 线程的属性线程的分离线程的栈地址线程栈大小线程的调度策略线程优先级3 线程的同步互斥锁读写锁条件变量信号量线程是系统独立调度和分配的基本单位。同一进程中的多个线程将共享该进程中的全部系统资源,例…

如何给Linux操作系统(CentOS 7为例)云服务器配置环境等一系列东西

1.首先,你得去购买一个云服务器(这里以阿里云学生服务器为例,学生必须实名认证) 打开阿里云,搜索学生服务器点击进入即可 公网ip为连接云服务器的主机 自定义密码为连接云服务器是需要输入的密码 购买即可 点击云服…

Linux系统编程---I/O多路复用

文章目录1 什么是IO多路复用2 解决什么问题说在前面I/O模型阻塞I/O非阻塞I/OIO多路复用信号驱动IO异步IO3 目前有哪些IO多路复用的方案解决方案总览常见软件的IO多路复用方案4 具体怎么用selectpollepolllevel-triggered and edge-triggered状态变化通知(edge-triggered)模式下…

c#中textbox属性_C#.Net中的TextBox.MaxLength属性与示例

c#中textbox属性Here we are demonstrating use of MaxLength property of TextBox. 在这里,我们演示了TextBox的MaxLength属性的使用。 MaxLength property of TextBox is used to set maximum number of character that we can input into a TextBox. Limit of M…

IIS7 MVC网站生成、发布

(1)生成。 确保System.Web.Mvc.dll在bin目录下 (2)发布网站到文件系统 (3)在IIS中为网站添加应用程序池(一个虚拟目录,一个应用程序池) (4)添加在默认网站下添加虚拟目录 (5)转换为应用程序 至此,部署完毕 …

C语言多维数组

文章目录多维数组数组名下标指向数组的指针作为函数参数的多维数组指针数组小结多维数组 如果某个数组的维数超过1,它就被称为多维数组,例如,下面这个声明: int matrix[6][10]创建了一个包含60个元素的矩阵。但是,它…

fwrite函数的用法示例_C语言中的fwrite()函数(带有示例)

fwrite函数的用法示例C中的fwrite()函数 (fwrite() function in C) Prototype: 原型: size_t fwrite(void *buffer, size_t length, size_t count, FILE *filename);Parameters: 参数: void *buffer, size_t length, size_t count, FILE *filenameRetu…

伙伴算法、slab机制、内存管理函数

文章目录1 伙伴算法页框操作alloc_pages()2 slabslab机制要解决的问题使用高速缓存3 内存管理函数kmallockzallocvmallocvzalloc区别参考文章内核使用struct page结构体描述每个物理页,也叫页框。内核在很多情况下,需要申请连续的页框,而且数…

Javaweb---监听器

1.什么是监听器 监听器就是监听某个对象的状态变化的组件。 事件源:被监听的对象 ----- 三个域对象 request session servletContext 监听器:监听事件源对象 事件源对象的状态的变化都会触发监听器 ---- 62 注册监听器:将监听器与事件源进行…

Linux中的Ramdisk和Initrd

Ramdisk简介先简单介绍一下ramdisk,Ramdisk是虚拟于RAM中的盘(Disk)。对于用户来说,能把RAM disk和通常的硬盘分区(如/dev/hda1)同等对待来使用,例如:redice # mkfs.ext2 /dev/ram0mke2fs 1.38 (30-Jun-200…

slab下kmalloc内核函数实现

文章目录kmalloc的整体实现获取高速缓存高速缓存获取index总结https://blog.csdn.net/qq_41683305/article/details/124554490,在这篇文章中,我们介绍了伙伴算法、slab机制和常见的内存管理函数,接下来,我们看看kmalloc内核函数的…

标题:三羊献瑞

标题:观察下面的加法算式: 其中,相同的汉字代表相同的数字,不同的汉字代表不同的数字。 请你填写“三羊献瑞”所代表的4位数字(答案唯一),不要填写任何多余内容。 思路分析: 首先…

进程虚拟地址管理

文章目录1 地址分布实际使用中的内存区域2 进程的虚拟地址描述用户空间mmap线程之间共享内存地址的实现机制1 地址分布 现在采用虚拟内存的操作系统通常都使用平坦地址空间,平坦地址空间是指地址空间范围是一个独立的连续空间(比如,地址从0扩…

标题:加法变乘法

标题:我们都知道:123 … 49 1225 现在要求你把其中两个不相邻的加号变成乘号,使得结果为2015 比如: 123…10*1112…27*2829…49 2015 就是符合要求的答案。 请你寻找另外一个可能的答案,并把位置靠前的那个乘号左…

【翻译】eXpressAppFramework QuickStart 业务模型设计(四)—— 实现自定义业务类...

这一讲,你将学到如何从头开始实现业务类。为此,将要实现Department和Position业务类。这些类将被应用到之前实现的Contact类中。你将学到引用对象自动生成用户界面的基本要素。 在此之前,我建议你去阅读一下 【翻译】eXpressAppFramework Qui…

内存重映射

文章目录1 kmap2 映射内核内存到用户空间使用remap_pfn_range使用io_remap_pfn_rangemmap文件操作建立VMA和实际物理地址的映射mmap 之前分配 一次性映射mmap 之前分配 Page FaultPage Fault 中分配 映射内核内存有时需要重新映射,无论是从内核到用户空间还是从内…

math.sqrt 有问题_JavaScript中带有示例的Math.sqrt()方法

math.sqrt 有问题JavaScript | Math.sqrt()方法 (JavaScript | Math.sqrt() Method) The Math.sqrt() method is inbuilt in JavaScript to find the square root of a number. In this tutorial, we will learn about the sqrt() method with examples. JavaScript中内置了Mat…

ISAPI Rewrite 实现简单url重写、二级域名重写

实现步骤: 第一步:下载ISAPI_Rewrite.rar,将Rewrite文件夹和httpd.ini直接放在项目根目录下面。 第二步:IIS配置,筛选Rewrite文件夹里面的Rewrite.dll文件,如图: 第三步:在httpd.ini…

用户登录

用户登录 代码namespace 用户登录 {public partial class Form1 : Form{public Form1(){InitializeComponent();}bool b1, b2, b3, b4, b5, b6;private void button1_Click(object sender, EventArgs e){try{if (b1 && b2 && b3 && b4 && b5 &…