linux 进程间读写锁,Linux系统编程—进程间同步

我们知道,线程间同步有多种方式,比如:信号量、互斥量、读写锁,等等。那进程间如何实现同步呢?本文介绍两种方式:互斥量和文件锁。

##互斥量mutex

我们已经知道了互斥量可以用于在线程间同步,但实际上,互斥量也可以用于进程间的同步。为了达到这一目的,可以在pthread_mutex_init初始化之前,修改其属性为进程间共享。mutex的属性修改函数主要有以下几个:

主要应用函数:

pthread_mutexattr_t mattr 类型:用于定义互斥量的属性

pthread_mutexattr_init函数:初始化一个mutex属性对象

pthread_mutexattr_destroy函数:销毁mutex属性对象 (而非销毁锁)

pthread_mutexattr_setpshared函数:修改mutex属性。

int pthread_mutexattr_setpshared(pthread_mutexattr_t *attr, int pshared);

我们重点看第二个参数:pshared,它有以下两个取值:

**线程锁:**PTHREAD_PROCESS_PRIVATE (mutex的默认属性即为线程锁,进程间私有)

**进程锁:**PTHREAD_PROCESS_SHARED

要想实现进程间同步,需要将mutex的属性改为PTHREAD_PROCESS_SHARED。

#include

#include

#include

#include

#include

#include

#include

#include

struct mt {

int num;

pthread_mutex_t mutex;

pthread_mutexattr_t mutexattr;

};

int main(void)

{

int i;

struct mt *mm;

pid_t pid;

mm = mmap(NULL, sizeof(*mm), PROT_READ|PROT_WRITE, MAP_SHARED|MAP_ANON, -1, 0);

memset(mm, 0, sizeof(*mm));

pthread_mutexattr_init(&mm->mutexattr); //初始化mutex属性对象

pthread_mutexattr_setpshared(&mm->mutexattr, PTHREAD_PROCESS_SHARED); //修改属性为进程间共享

pthread_mutex_init(&mm->mutex, &mm->mutexattr); //初始化一把mutex琐

pid = fork();

if (pid == 0) {

for (i = 0; i < 10; i++) {

sleep(1);

pthread_mutex_lock(&mm->mutex);

(mm->num)++;

pthread_mutex_unlock(&mm->mutex);

printf("-child----------num++ %d\n", mm->num);

}

} else if (pid > 0) {

for ( i = 0; i < 10; i++) {

sleep(1);

pthread_mutex_lock(&mm->mutex);

mm->num += 2;

pthread_mutex_unlock(&mm->mutex);

printf("-------parent---num+=2 %d\n", mm->num);

}

wait(NULL);

}

pthread_mutexattr_destroy(&mm->mutexattr); //销毁mutex属性对象

pthread_mutex_destroy(&mm->mutex); //销毁mutex

munmap(mm,sizeof(*mm)); //释放映射区

return 0;

}

AAffA0nNPuCLAAAAAElFTkSuQmCC

##文件锁

顾名思义,就是通过文件实现锁机制。具体来讲,是通过借助 fcntl函数来实现锁机制。当操作文件的进程没有获得锁时,虽然可以打开文件,但无法对文件执行执行read、write操作。

###fcntl函数:

函数原型:

int fcntl(int fd, int cmd, … /* arg */ );

函数作用:

获取、设置文件访问控制属性。

参数介绍:

参数cmd有以下取值:

F_SETLK (struct flock *)设置文件锁(trylock)

F_SETLKW (struct flock *) 设置文件锁(lock)W --> wait

F_GETLK (struct flock *)获取文件锁

数据类型flock原型如下:

struct flock {

​ …

​ short l_type; 锁的类型:F_RDLCK 、F_WRLCK 、F_UNLCK

​ short l_whence; 偏移位置:SEEK_SET、SEEK_CUR、SEEK_END

​ off_t l_start; 起始偏移:1000

​ off_t l_len; 长度:0表示整个文件加锁

​ pid_t l_pid; 持有该锁的进程ID:(F_GETLK only)

​ …

};

###进程间文件锁示例

多个进程对加锁文件进行访问:

#include

#include

#include

#include

#include

#include

void sys_err(char *str)

{

perror(str);

exit(1);

}

int main(int argc, char *argv[])

{

int fd;

struct flock f_lock;

if (argc < 2) {

printf("./a.out filename\n");

exit(1);

}

if ((fd = open(argv[1], O_RDWR)) < 0)

sys_err("open");

f_lock.l_type = F_WRLCK; /*选用写琐*/

// f_lock.l_type = F_RDLCK; /*选用读琐*/

f_lock.l_whence = SEEK_SET;

f_lock.l_start = 0;

f_lock.l_len = 0; /* 0表示整个文件加锁 */

fcntl(fd, F_SETLKW, &f_lock);

printf("get flock\n");

sleep(10);

f_lock.l_type = F_UNLCK;

fcntl(fd, F_SETLKW, &f_lock);

printf("un flock\n");

close(fd);

return 0;

}

AAffA0nNPuCLAAAAAElFTkSuQmCC

文件锁类似于读写锁,依然遵循“读共享、写独占”特性。但是,如果进程不加锁直接操作文件,依然可访问成功,但数据势必会出现混乱。

既然文件锁可用应用在进程中,那在多线程中,可以使用文件锁吗?

答案是不行的。因为多线程间共享文件描述符,而给文件加锁,是通过修改文件描述符所指向的文件结构体中的成员变量来实现的。因此,多线程中无法使用文件锁。

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

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

相关文章

程序员:开汽车,难道我要知道汽车的原理才能把车开好吗?

一个网友的迷惑&#xff1a; 我工作&#xff15;年了&#xff0c;一直做&#xff2a;&#xff12;&#xff25;&#xff25;的项目&#xff0c;前几天去面试&#xff0c;一个人问我JDBC有几种连接方式&#xff0c;这个问题这么多年以来我从来没有遇见过&#xff0c;不知道大家 …

杭州某知名xxxx公司急招大量java以及大数据开发工程师

因公司战略以及业务拓展&#xff0c;收大量java攻城狮以及大数据开发攻城狮. 职位信息&#xff1a; java攻城狮: https://job.cnblogs.com/offer/56032 大数据开发攻城狮: https://job.cnblogs.com/offer/56033 欢迎博客园的XDJM自荐和推荐&#xff01; 此招聘长期有效 欢迎留言…

35.6. /etc/dnsmasq.d/dnsmasq.address.conf

vim /etc/dnsmasq.d/dnsmasq.address.confaddress/www.mydomain.com/172.16.0.254deny domain address/www.facebook.com/127.0.0.1 address/www.google.com/127.0.0.135.6.1. 域名劫持 将域名解析到错误的地址&#xff0c;这样可以屏蔽一些网站。 address/www.facebook.com/12…

请求地址操作中的(int*)

例如 float b3.14,*a&b; int *p(int *)a; 表示将指针a的类型转换为整型指针再赋给p。

linux初始化内存盘卡住,Linux系统内存磁盘初始化技术详细解析

转自&#xff1a;http://m.zol.com.cn/article/1271270.html?viaindexLinux内存初始化技术(initrd)用于支持两阶段的系统引导过程&#xff0c;是在系统启动过程中被挂载的临时root文件系统(译者注&#xff1a;这里的root文件系统是指的根文件系统)。initrd包含很多可执行程序和…

程序员是程序中的临时变量,用完扔掉?

今天看到某人从坟墓里刨出的文章&#xff0c;挺有意思的。 程序员&#xff0c;到了一定年龄&#xff0c;如果没有机会转到领导级&#xff0c;至少是项目经理&#xff0c;能独立领导团队完成项目&#xff0c;还是停留在编码的层次&#xff0c;那么被迫离开的危险会是很高的&…

属性依赖注入

1.依赖注入方法 手动装配和自动装配 2.手动装配 2.1 基于xml装配 2.1.1 构造方法 <!-- 构造方法注入<constructor-arg>name:参数名type:类型value: --> <bean id"user" class"g_xml.constructor.User"><constructor-arg name"id…

windows下实现自己的第一个python脚本文件并.exe运行

前言 python可以做很多事情&#xff0c;比如知乎上的回答&#xff0c;每天来到公司都要打开AS&#xff0c; QQ和微信,为了省事决定用python写一个简单的脚本来实现。。脚本内容只有几行,python的代码真的好简洁。。。 import os os.startfile("C:\Program Files (x86)\Ten…

C++中引用()基础认识

对于习惯使用C进行开发的朋友们&#xff0c;在看到c中出现的&符号&#xff0c;可能会犯迷糊&#xff0c;因为在C语言中这个符号表示了取地址符&#xff0c;但是在C中它却有着不同的用途&#xff0c;掌握C的&符号&#xff0c;是提高代码执行效率和增强代码质量的一个很好…

linux无法访问443端口,linux – 为什么我无法在Ubuntu上ping端口443?

我通过iptables打开了端口443&#xff1a;pkts bytes target prot opt in out source destination45 2428 ACCEPT all -- lo * 0.0.0.0/0 0.0.0.0/06 1009 ACCEPT tcp -- * * 0.0.0.0/0 0.0.0.0/0 tcp dpt:80141 10788 ACCEPT tcp -- * * 0.0.0.0/0 0.0.0.0/0 tcp dpt:220 0 AC…

MediaWiki安装配置(Linux)【转】

阅读目录 2.1 本例子的安装环境如下&#xff1a;转自&#xff1a;http://blog.csdn.net/gao36951/article/details/43965527 版权声明&#xff1a;本文为博主原创文章&#xff0c;未经博主允许不得转载。 目录(?)[-] 1MediaWiki简介 2MediaWiki安装21 本例子的安装环境如…

提高编程水平的一段必经之路,研读官方文档

刚才看了 论坛里 jinxfei 的十年总结&#xff08;14&#xff09;&#xff1a;从CS转向BS, 说实话&#xff0c;大部分内容我没有太仔细的看&#xff0c;不过如下的一段引起了我的注意&#xff1a; 真正让我心里有底的&#xff0c;还是在看了官方文档之后&#xff1a;http://str…

在Asp.net core返回PushStream

最近用asp.net core webapi实现了一个实时视频流的推送功能&#xff0c;在Asp.net中&#xff0c;这个是通过PushStreamContent来实现的。 基于对asp.net core的知识&#xff0c;随手写了一个&#xff08;要求控制器继承自Controller基类&#xff09; [HttpGet] public async Ta…

顺序栈的代码实现

栈是一种限定只在表尾进行插入或删除操作的线性表&#xff0c;栈也是线性表。表头称为栈的底部,表尾称为栈的顶部,表为空称为空栈。 栈又称为后进先出的线性表,栈也有两种表示:顺序栈与链式栈。顺序栈是利用一组地址连续的存储单元。依次存放从栈底到栈顶的数据元素。 #includ…

Linux5观察doc目录并截屏,linux截屏命令

linux系统我们有时需要用到截屏功能&#xff0c;下面由学习啦小编为大家整理了linux截屏命令的相关知识&#xff0c;希望对大家有帮助!linux截屏命令详解import检测&#xff1a;import --versionimprot安装&#xff1a;sudo apt-get install importimport常用命令&#xff1a;1…

eclipse+tomcat开发web程序

环境&#xff1a;windows 7Eclipse Java EE IDE for Web Developerstomcat 7.02 插件&#xff1a;tomcatPluginV321.zip 一.配置Tomcat插件 我们创建一个myplugins文件夹用于存放插件&#xff0c;myplugins位于D:/Program Files/J2EE目录下。eclipse安装路径为&#xff1a;D:/P…

LoadRunner参数包含逗号

loadrunner的参数以逗号区分&#xff0c; 如果参数本身包含逗号&#xff0c;则会报错 使用","将逗号包起来即可&#xff0c;如下图 转载于:https://www.cnblogs.com/cherrysu/p/8507649.html

软件创业见闻

今天应一位朋友的邀请&#xff0c;过去蹭了个饭吃&#xff0c;顺便坐了一个下午在聊着。这位老哥是一家软件公司的老板&#xff0c;原来是从硬件销售转型到做软件这一块。因为说到软件这一块&#xff0c;我就很想了解一下这位老哥对于2009年的大势是怎么看的&#xff0c;在2009…

如何采用设置标志的方法来区分循环队列的满和空

设立一个标志位,比如说是flag 最开始时队列为空,设flag0 当入队的时候让flag1 出队的时候flag0 然后再加上判断队头队尾指针是否重合 重合,且flag0,则为空 重合且flag1,则为满

linux内核定义的常用信号6,linux复习

(3)设定apache服务器的网页根目录&#xff1a;/home/htdocs(4)在此apache服务器上设定一个目录/home/htdocs/inside,且此目录只允许IP地址为192.168.1.5的主机访问(5)定义apache服务器以独立进程的方式运行2、某系统管理员需每天做一定的重复工作&#xff0c;请按照下列要求&am…