博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
linux并发控制之读写信号量
阅读量:5082 次
发布时间:2019-06-13

本文共 2006 字,大约阅读时间需要 6 分钟。

读写信号量与信号量之间的关系类似于自旋锁与读写自旋锁。
读写信号量可能会引起进程阻塞,但是它允许N个读执行单元同时访问共享资源,而最多只允许有一个写执行单元访问共享资源;因此,读写信号量是一种相对放宽条件的、粒度稍大于信号量的互斥机制。
注意:
信号量不允许任何操作之间有并发。
理解:
定义于#include<linux/rwsem.h> 实际上在arch/X86/include/asm/rwsem.h 
其结构体为:
struct rw_semaphore {
long
count;
spinlock_t wait_lock;
struct list_head wait_list;
#ifdef CONFIG_DEBUG_LOCK_ALLOC
struct lockdep_map dep_map;
#endif
};
其中读锁和写锁函数为:
static inline void __down_read(struct rw_semaphore *sem)
{
asm volatile("# beginning down_read\n\t"
    
 LOCK_PREFIX _ASM_INC  "(%1)\n\t"
     /* adds 0x00000001 */
     "  jns        1f\n"
     "  call call_rwsem_down_read_failed\n"    //跳转到rwsem_down_read_failed函数
     "1:\n\t"                  //给输出信息占位
     "# ending down_read\n\t"
     : "+m" (sem->count)
     : "a" (sem)
     : "memory", "cc");
}
static inline void __down_write_nested(struct rw_semaphore *sem, int subclass)
{
long tmp;
asm volatile("# beginning down_write\n\t"
     LOCK_PREFIX "  xadd      %1,(%2)\n\t"    //
xadd表示原操作数和目的操作数值相交换,而后相加保存入目的操作数
     /* adds 0xffff0001, returns the old value */
     "  test      %1,%1\n\t"            //
利用test指令检测count变量来实现
     /* was the count 0 before? */
     "  jz        1f\n"
     "  call call_rwsem_down_write_failed\n"
     "1:\n"
     "# ending down_write"
     : "+m" (sem->count), "=d" (tmp)
     : "a" (sem), "1" (RWSEM_ACTIVE_WRITE_BIAS)
     : "memory", "cc");
}
操作:
struct rw_semaphore rw_sem;                                     //定义读写信号量
void init_rwsem(struct rw_semaphore* rw_sem);       //初始化读写信号量
void down_read(struct rw_semaphore* rw_sem);            //获取读信号量
int down_read_trylock(struct rw_semaphore* rw_sem); //尝试获取读信号量
void up_read(struct rw_semaphore* rw_sem);             
void down_write(struct rw_semaphore* rw_sem);           //获取写信号量
int down_write_trylock(struct rw_semaphore* rw_sem);//尝试获取写信号量
void up_write(struct rw_semaphore* rw_sem);             
用例
rw_semaphore sem;   
init_rwsem(&sem);   
down_read(&sem);    
...临界区...          
up_read(&sem);     
down_write(&sem);   
...临界区...             
up_write(&sem);     
另:
void downgrade_write(struct rw_semaphore* sem);
该函数用于把写者降级为读者,有时,这是必要的。
因为写者是互斥的、排它的,因此在写者保护读写信号量期间,任何读者或写者都将无法访问该信号量所保护的共享资源,对于那些当前条件下不需要写操作的访问者,降级为写者,将使得等待访问的读者能够立即访问,从而增加了并发性,提高了效率。

转载于:https://www.cnblogs.com/wangfengju/archive/2013/01/31/6173258.html

你可能感兴趣的文章
awk入门
查看>>
windows下图形学视觉基本库安装不完全指南
查看>>
从博客园迁移到自己用Hexo搭的博客
查看>>
【J】【POJ 1696】
查看>>
用Eclipse进行单元测试JUnit4
查看>>
leetcode 有效的数独
查看>>
关于进程和线程
查看>>
适配器模式
查看>>
kotlin扩展函数
查看>>
C++primer 12.2.2节练习
查看>>
logstash 字段类型转换后 需要刷新
查看>>
14.4.2 Change Buffer 延迟写
查看>>
perl 回调函数
查看>>
什么是REST?以及RESTful的实现
查看>>
苹果开发者账号申请,苹果证书申请,app发布
查看>>
时间序列(五): 大杀器: 循环神经网络
查看>>
javaScript定义函数的三种方式&amp;变量的作用域
查看>>
百(开)度(黑)之星复赛
查看>>
BZOJ1013: [JSOI2008]球形空间产生器sphere
查看>>
直方图中最大矩形面积
查看>>