多进程之间的线程利用XSI IPC共享内存分配互斥量进行同步

···

#include <stdio.h>

#include <stdlib.h>

#include <pthread.h>

#include <unistd.h>

#include <sys/wait.h>

#include <errno.h>

#include <sys/types.h>

#include <sys/ipc.h>

#include <sys/shm.h>

#define handle_error_en(en, msg) \

do { errno = en; perror(msg); exit(EXIT_FAILURE); } while (0)

static pthread_mutex_t *mtx;

static void *original_owner_thread(void *ptr){

printf(“[original owner] Setting lock…\n”);

pthread_mutex_lock(mtx);

printf(“[original owner] Locked. Now exiting without unlocking.\n”);

pthread_exit(NULL);//加锁后退出不释放锁

}

int main(){

pid_t pid_robust;

int shmid;

        //利用XSI IPC,分配互斥量的内存 

shmid = shmget(IPC_PRIVATE,sizeof(pthread_mutex_t),IPC_CREAT|IPC_EXCL);

//获取内存区指针

         mtx=shmat(shmid,0,0);

pid_robust = fork();

int proc_status;

int ret;

if(pid_robust <0 ){

                printf(“[main process] fork error!\n”);

return -1;

        } 

if (pid_robust > 0){

pthread_t thr_p;

pthread_mutexattr_t attr;

pthread_mutexattr_init(&attr);

pthread_mutexattr_setpshared(&attr,PTHREAD_PROCESS_SHARED);

pthread_mutexattr_setrobust(&attr, PTHREAD_MUTEX_ROBUST);

pthread_mutex_init(mtx, &attr);

pthread_create(&thr_p, NULL, original_owner_thread, NULL);

}else if(0==pid_robust){

int err_code;

sleep(2);

printf(“[fork main thread] Attempting to lock the robust mutex.\n”);

err_code = pthread_mutex_lock(mtx);

if (err_code == EOWNERDEAD) {

printf(“[fork main thread] pthread_mutex_lock() returned EOWNERDEAD\n”);

printf(“[fork main thread] Now make the mutex consistent\n”);

err_code = pthread_mutex_consistent(mtx);//调用函数进行更换锁的属主,也就是锁从以前拥有者更换为当起线程

if (err_code != 0){

handle_error_en(err_code, “pthread_mutex_consistent”);

}

printf(“[fork main thread] Mutex is now consistent; unlocking\n”);

err_code = pthread_mutex_unlock(mtx);

if (err_code == 0 ){

printf(“[fork main thread] pthread_mutex_lock() unexpectedly succeeded\n”);

}else{

handle_error_en(err_code, “pthread_mutex_unlock”);

}

}else{

printf(“[fork main thread] lock success! %d\n”,err_code);

exit(0);

}

printf(“parent main thread waiting fork process \n”);

sleep(2);

if(waitpid(pid_robust,&proc_status,0) < 0){

printf(“[parent main thread] waiting for fork process error.\n”);

         return 127;

if(WIFEXITED(proc_status)){

return 0;

}

return 127;

}

···

编译:

gcc -lpthread -o  muti_proc_thread_lock muti_proc_thread_lock.c

结果:

参考:

https://baijiahao.baidu.com/s?id=1639746835739880284&wfr=spider&for=pc
Image placeholder
flamingoking
未设置
  98人点赞

没有讨论,发表一下自己的看法吧

推荐文章
Go内存分配跟踪调优

今天小编为大家分享一篇关于Go内存分配跟踪调优的文章,文中涉及到一些压测及跟踪分析的工具,以及问题查找方法,希望能对大家有所帮助。Makeitwork,makeitright,makeitfast.–

自动识别Android不合理的内存分配

写在前面Android开发中我们常常会遇到不合理的内存分配导致的问题,或是频繁GC,或是OOM。按照常规的套路我们需要打开AndroidStudio录制内存分配或者dump内存,然后人工分析,逐个排查

共享内存在不同系统的应用与优劣详解

共享内存是一种使计算机程序能够同时共享内存资源以实现更高性能和更少冗余数据副本的技术。共享系统内存可以在单处理器系统、并行多处理器或集群微处理器上运行。对于分布式系统会有一些差异,但共享内存也可以其上

学习Java必备的线程基础知识

课程推荐:Java开发工程师--学习猿地精品课程 本文的讲解主要从以下几个点展开: 什么是线程线程都有哪几种状态线程的启动和终止线程间的通信利用本文讲解的线程知识,实现一个简单的线程池如果上面列出的这

谁创建谁销毁,谁分配谁释放——JNI调用时的内存管理

在QQ音乐AndroidTV端的Cocos版本的开发过程中,我们希望尽量多的复用现有的业务逻辑,避免重复制造轮子。因此,我们使用了大量的JNI调用,来实现Java层和Native层(主要是C++)的代

原生线程池这么强大,Tomcat 为何还需扩展线程池?

前言Tomcat/Jetty是目前比较流行的Web容器,两者接受请求之后都会转交给线程池处理,这样可以有效提高处理的能力与并发度。JDK提高完整线程池实现,但是Tomcat/Jetty都没有直接使用。

Go编程语言教程_1.6. Go和Python编程语言之间的区别

Golang是一种过程编程语言。它由Google的RobertGriesemer,RobPike和KenThompson于2007年开发,但于2009年作为一种开放源代码编程语言发布。程序通过使用软件

jquery text() val() html()之间的区别是什么?

jquerytext()val()html()之间的区别是什么?●text()获取元素内的文本,相当于js中的innerText●val()获取表单元素的值,相当于js中的input.value●ht

三分钟带你分清Mysql 和Oracle之间的误区

课程推荐:PHP开发工程师--学习猿地精品课程 mysql和Oracle在开发中的使用是随处可见的,那就简单去了解一下这俩款火的不行的数据库。 本质区别:Oracle数据库是一个对象关系数据库管理系统

利用 samba 实现 Ubuntu18.04 与 Windows10 的文件共享

在Ubuntu18.04上安装samba服务 打开终端,使用下面指令安装samba服务。 $sudoaptinstallsamba $sudoaptinstallsmbclient 在Ubuntu1

基于内存和文件存储的 queue worker, 不用 Redis 适合单进程使用没有外部依赖

因为最近要做一个简单的并发任务系统,在github上面找了一圈并没有简单可依赖的库,所以自己写了一个。欢迎大家Review贡献代码。项目地址https://github.com/iflamed/mfw

TPC-C解析系列03_TPC-C基准测试之SQL优化

TPC-C是一个非常严苛的基准测试模型,考验的是一个完备的关系数据库系统全链路的能力。这也是为什么在TPC-C的榜单前列,出现的永远只是大家熟知的那几家在业界有着几十年积累、从关系数据库理论开始发展就

TPC-C解析系列05_TPC-C基准测试之存储优化

TPC-C规范要求被测数据库的性能(tpmC)与数据量成正比。TPC-C的基本数据单元是仓库(warehouse),每个仓库的数据量通常在70MB左右(与具体实现有关)。TPC-C规定每个仓库所获得的

TPC-C解析系列01_TPC-C benchmark测试介绍

作者:阳振坤2019.10导语:自从蚂蚁金服自研数据库OceanBase获得TPC-C测试第一名后,引起了行业内外大量关注,我们衷心的感谢大家对OceanBase的支持与厚爱,也虚心听取外界的意见和建

TPC-C解析系列02_OceanBase如何做TPC-C测试

导语:蚂蚁金服自研数据库OceanBase登顶TPC-C引起业内广泛关注,为了更清楚的展示其中的技术细节,我们特意邀请OceanBase核心研发人员对本次测试进行技术解读,共包括五篇:1)TPC-C基

TPC-C解析系列04_TPC-C基准测试之数据库事务引擎的挑战

OceanBase这次TPC-C测试与榜单上Oracle和DB2等其他数据库在硬件使用上有非常大的不同,OceanBase的数据库服务器使用的是204+3台型号是ecs.i2.16xlarge阿里云E

HPC CHINA 2019:面向E级计算时代的HPC/AI协同设计

蓝天飘白云,牧场奶茶香。蒙古大营雄风在,琴声传远方。骑马又滑沙,豪饮河套王。敖包相会歌一曲,笑发少年狂。中国一年一度高性能计算领域的盛会——全国高性能计算学术年会(HPCCHINA2019)在内蒙古呼

企业级RPC框架zRPC

课程推荐:GO开发工程师--学习猿地精品课程 近期比较火的开源项目go-zero是一个集成了各种工程实践的包含了Web和RPC协议的功能完善的微服务框架,今天我们就一起来分析一下其中的RPC部分zRP

超大规模商用 K8s 场景下,阿里巴巴如何动态解决容器资源的按需分配问题?

导读:资源利用率一直是很多平台管理和研发人员关心的话题。本文作者通过阿里巴巴容器平台团队在这一领域的工作实践,整理出了一套资源利用提升的方案,希望能够带给大家带来一些讨论和思考。引言不知道大家有没有过

看完知乎轮子哥的编程之路,我只想说,收下我的膝盖…

vczh,本名陈梓瀚,因知乎的个人信息介绍上写有“专业造轮子”,所以江湖人称“轮子哥”。vczh大学时代就在微软实习,毕业后即加入微软。开始时是在微软上海,后来进入北京的微软亚洲研究院。现已移居美国西

敏捷开发流程之Scrum:3个角色、5个会议、12原则

本文主要从Scrum的定义和目的、敏捷宣言、Scrum中的人员角色、Scrum开发流程、敏捷的12原则等几方面帮助大家理解Scrum敏捷开发的全过程。一、Scrum的定义和目的Scrum是一个用于开发

【Python 1-5】Python教程之——字符串

课程推荐:Python开发工程师--学习猿地--送9个上线商业项目 字符串字符串就是一系列字符。在Python中,用引号括起的都是字符串,其中的引号可以是单引号,也可以是双引号,如下所示:"Thisi

GoWeb教程_09.3. 避免 XSS 攻击

随着互联网技术的发展,现在的Web应用都含有大量的动态内容以提高用户体验。所谓动态内容,就是应用程序能够根据用户环境和用户请求,输出相应的内容。动态站点会受到一种名为“跨站脚本攻击”(CrossSit

XSS漏洞简介

课程推荐《前端工程师--赠送8个商业项目--学习猿地精品推荐》XSS漏洞简介跨站脚本攻击(XSS),是最普遍的Web应用安全漏洞。这类漏洞能够使得攻击者嵌入恶意脚本代码到正常用户会访问到的页面中,当正

Java 8 并发教程:线程和执行器

Thread和Runnable 所有的现代操作系统都通过进程和线程来支持并发。进程是通常彼此独立运行的程序的实例,比如,如果你启动了一个Java程序,操作系统产生一个新的进程,与其他程序一起并行执行。