linux system V IPC 信号灯和共享内存实例
#include<sys/types.h>
#include<linux/sem.h>
#include<linux/shm.h>
#include<unistd.h>
#include<stdio.h>
#include<stdlib.h>
#include<errno.h>
#include<time.h>
#define MAXSHM 5 //定义缓冲区数组的下标变量个数
/* 定义3个信号量的内部标识 */
int fullid;
int emptyid;
int mutexid;
/* 主函数 */
int main()
{
/* 定义2个共享内存的ID */
int arrayid;
int getid;
/* 定义共享内存虚拟地址 */
int *array;
int *get;
/* 创建共享内存 */
arrayid=shmget(IPC_PRIVATE,sizeof(int) * MAXSHM,IPC_CREAT|0666);
getid=shmget(IPC_PRIVATE,sizeof(int),IPC_CREAT|0666);
/* 初始化共享内存 */
array=(int *) shmat(arrayid,0,0);
get=(int *) shmat(getid,0,0);
*get=0;
/* 定义信号量数据结构 */
struct sembuf P,V;
union semun arg;
/* 创建信号量 */
fullid=semget(IPC_PRIVATE,1,IPC_CREAT|0666);
emptyid=semget(IPC_PRIVATE,1,IPC_CREAT|0666);
mutexid=semget(IPC_PRIVATE,1,IPC_CREAT|0666);
/*初始化信号量 */
arg.val=0; //初始时缓冲区中无数据
if(semctl(fullid,0,SETVAL,arg)==-1)
{
perror("semctl setval error");
}
arg.val=MAXSHM; //初始时缓冲区中有5个空闲的数组元素
if(semctl(emptyid,0,SETVAL,arg)==-1)
{
perror("semctl setval error");
}
arg.val=1; //初始时互斥信号为1,允许一个进程进入
if(semctl(mutexid,0,SETVAL,arg)==-1)
{
perror("semctl setval error");
}
/* 初始化 P V操作 */
P.sem_num=0;
P.sem_op=-1;
P.sem_flg=SEM_UNDO;
V.sem_num=0;
V.sem_op=1;
V.sem_flg=SEM_UNDO;
/* 生产者进程 */
if(fork()==0)
{
int i=0;
int set=0;
while(i<10)
{
semop(emptyid,&P,1); //对 emptyid执行P操作
semop(mutexid,&P,1); //对 mutexid执行 P操作
array[set%MAXSHM]=i+1;
printf("Producer put number %d to No.%d\n",array[set%MAXSHM],set%MAXSHM);
set++; //写计数加1
semop(mutexid,&V,1); //对mutexid执行 V 操作
semop(fullid,&V,1); //对fullid执行 V 操作
i++;
}
sleep(3); //SLEEP 3秒,等待消费者进程执行完毕
printf("Poducer if over\n");
exit(0);
}
else
{
/* 消费者A进程 */
if(fork()==0)
{
while(1)
{
if(*get==10)
{
break;
}
semop(fullid,&P,1); //对fullid执行 P 操作
semop(mutexid,&P,1); //对mutexid执行 P 操作
printf("The ConsumerA get number from No.%d\n",(*get)%MAXSHM);
(*get)++; //读计数加1
semop(mutexid,&V,1); //对mutexid执行 V 操作
semop(emptyid,&V,1); //对fullid执行 V 操作
sleep(1);
}
printf("ConsunerA is over\n");
exit(0);
}
else
{
/*消费者B进程 */
if(fork()==0)
{
while(1)
{
if(*get==10)
{
break;
}
semop(fullid,&P,1); //对fullid执行 P 操作
semop(mutexid,&P,1); //对mutexid执行 P 操作
printf("The ConsumerB get number from No.%d\n",(*get)%MAXSHM);
(*get)++; //读计数加1
semop(mutexid,&V,1); //对mutexid执行 V 操作
semop(emptyid,&V,1); //对emptyid执行 V 操作
sleep(1);
}
printf("ConsunerB is over\n");
exit(0);
}
}
}
/* 父进程返回后回收3个子进程 */
wait(0);
wait(0);
wait(0);
/* 断开并撤消2个共享内存 */
shmdt(array);
shmctl(arrayid,IPC_RMID,0);
shmctl(get);
shmctl(getid,IPC_RMID,0);
/* 撤消3个信号量集 */
semctl(emptyid,IPC_RMID,0);
semctl(fullid,IPC_RMID,0);
semctl(mutexid,IPC_RMID,0);
exit(0);
}
linux system V IPC 信号灯和共享内存实例相关推荐
- system v和posix的共享内存对比 共享内存位置
参考 http://www.startos.com/linux/tips/2011012822078.html 1)Linux和所有的UNIX操作系统都允许通过共享内存在应用程序之间共享存储空间. 2 ...
- 进程间同步---system v ipc 对象信号灯集
一.信号灯简介 Linux支持System V的信号灯(semaphore),是一种进程间通信的方式,只不过它和管道.FIFO或者共享内存不一样,信号灯主要用于同步或者互斥对共享资源的访问,它的发明来 ...
- Linux(信号,进程间通信)共享内存,信号量,消息队列
信号(signal) 1.1 什么是信号? 信号是在软件层次上对中断机制的一种模拟,是一种异步通信方式 1.2 信号的来源 硬件 [1] 用户在终端按下某些键时,终端驱动程序会发送信号给前台进程 ct ...
- System V IPC
1.概述 System V IPC共有三种类型:System V消息队列.System V 信号量.System V 共享内存区. System V IPC操作函数如下: 2.key_t键和ftok函 ...
- Linux系统中消息队列,共享内存、信号和线程的基本操作使用方法
Linux系统中消息队列,共享内存.信号和线程高级操作 第十一章 消息队列 10.1消息队列定义 10.2 消息队列特点 10.3 key值 10.4 创建消息队列 10.4.1 发送消息 10.4. ...
- system V IPC进程间通信机制一网打尽
目录 必备IPCS命令解析 ipcs ipcrm Linux IPC消息队列 msgget msgsnd msgrcv msgctl Linux IPC信号量 理解信号量 semget semop s ...
- 好文转载 Linux环境进程间通信(五): 共享内存(上)
http://www.ibm.com/developerworks/cn/linux/l-ipc/part5/index1.html 采用共享内存通信的一个显而易见的好处是效率高,因为进程可以直接读写 ...
- Linux环境进程间通信(五): 共享内存(上)
Linux环境进程间通信(五): 共享内存(上) 共享内存可以说是最有用的进程间通信方式,也是最快的IPC形式.两个不同进程A.B共享内存的意思是,同一块物理内存被映射到进程A.B各自的进程地址空间. ...
- Linux应用编程之共享内存实例
1共享内存实例 01 主要内容 上一小节小哥跟大家介绍了一下共享内存的知识,今天主要是做一个实战的演示,从而更好的理解共享内存的原理和实际应用. 02 程序示例 1#include &l ...
最新文章
- A query was run and no Result Maps were found
- SAP 电商云 Spartacus UI 的 urlParameter 配置原理
- Post请求中加不加@RequestBody的区别和formedata与JSON传递的区别
- 【转】微服务架构下分布式事务方案
- Java语言和C语言相比,为什么C语言的运算速度会更快,是因为vjm的性能不行么?
- file does not exist 阿里云OSS图片上传遇到的问题
- 基础的数据处理(1)—出租车数据的基础处理,由gps生成OD(pandas)
- xp母盘制作流程+QQDLL+系统文件DLL修改(转)
- SEO人员,不要见风是雨
- Python在线编辑器推荐
- android srgb模式,一加3固件官方更新:加入屏幕边缘防误触和sRGB显示模式功能
- Rancher Cluster is being upgraded
- HTML5期末大作业:设计网站设计——动漫设计响应式(10页) HTML+CSS+JavaScript 动漫设计制作 简单静态HTML网页作品 动漫设计作业成品 学生个人网站模板
- createBuilderConfig 0XFFFF异常
- 如何区分IPEX一代/二代/三代/四代/五代
- 能远程控制你电脑的苹果充电线正在生产和售卖,走一个?
- 白盒测试——NextDate函数测试(基本路径覆盖法)
- 【转】浅谈程序猿的职业规划,看你如何决定自己的未来吧。
- 如何在微信小程序中使用ECharts图表
- cad高程测绘图lisp_已知CAD中的高程测绘图,很多点,如何求出所有高程的平均值呢?难道只能用计算器一个一个的相加来算吗?...
热门文章
- mysql sql语句里连接符的使用_SQL中group_concat函数,用符号连接查询分组里字段值...
- joblib多线程、多进程学习案例(一)——一步步写多进程任务
- http请求中必备的字符段_React Hooks中这样写HTTP请求可以避免内存泄漏
- 中如何移动物体在画面中的位置_如何在弱光环境中拍摄运动物体
- mysql 大小写问题
- stm32-再谈GPIO
- 程序员如何在百忙中更有效地利用时间,如何不走岔路,不白忙(忙得要有效率,要有收获)...
- 3、通过挂在系统光盘搭建本地yum仓库。
- GCD之线程挂起与恢复
- Java NIO与IO的差别和比較