#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 信号灯和共享内存实例相关推荐

  1. system v和posix的共享内存对比 共享内存位置

    参考 http://www.startos.com/linux/tips/2011012822078.html 1)Linux和所有的UNIX操作系统都允许通过共享内存在应用程序之间共享存储空间. 2 ...

  2. 进程间同步---system v ipc 对象信号灯集

    一.信号灯简介 Linux支持System V的信号灯(semaphore),是一种进程间通信的方式,只不过它和管道.FIFO或者共享内存不一样,信号灯主要用于同步或者互斥对共享资源的访问,它的发明来 ...

  3. Linux(信号,进程间通信)共享内存,信号量,消息队列

    信号(signal) 1.1 什么是信号? 信号是在软件层次上对中断机制的一种模拟,是一种异步通信方式 1.2 信号的来源 硬件 [1] 用户在终端按下某些键时,终端驱动程序会发送信号给前台进程 ct ...

  4. System V IPC

    1.概述 System V IPC共有三种类型:System V消息队列.System V 信号量.System V 共享内存区. System V IPC操作函数如下: 2.key_t键和ftok函 ...

  5. Linux系统中消息队列,共享内存、信号和线程的基本操作使用方法

    Linux系统中消息队列,共享内存.信号和线程高级操作 第十一章 消息队列 10.1消息队列定义 10.2 消息队列特点 10.3 key值 10.4 创建消息队列 10.4.1 发送消息 10.4. ...

  6. system V IPC进程间通信机制一网打尽

    目录 必备IPCS命令解析 ipcs ipcrm Linux IPC消息队列 msgget msgsnd msgrcv msgctl Linux IPC信号量 理解信号量 semget semop s ...

  7. 好文转载 Linux环境进程间通信(五): 共享内存(上)

    http://www.ibm.com/developerworks/cn/linux/l-ipc/part5/index1.html 采用共享内存通信的一个显而易见的好处是效率高,因为进程可以直接读写 ...

  8. Linux环境进程间通信(五): 共享内存(上)

    Linux环境进程间通信(五): 共享内存(上) 共享内存可以说是最有用的进程间通信方式,也是最快的IPC形式.两个不同进程A.B共享内存的意思是,同一块物理内存被映射到进程A.B各自的进程地址空间. ...

  9. Linux应用编程之共享内存实例

    1共享内存实例 01 主要内容     上一小节小哥跟大家介绍了一下共享内存的知识,今天主要是做一个实战的演示,从而更好的理解共享内存的原理和实际应用. 02 程序示例    1#include &l ...

最新文章

  1. A query was run and no Result Maps were found
  2. SAP 电商云 Spartacus UI 的 urlParameter 配置原理
  3. Post请求中加不加@RequestBody的区别和formedata与JSON传递的区别
  4. 【转】微服务架构下分布式事务方案
  5. Java语言和C语言相比,为什么C语言的运算速度会更快,是因为vjm的性能不行么?
  6. file does not exist 阿里云OSS图片上传遇到的问题
  7. 基础的数据处理(1)—出租车数据的基础处理,由gps生成OD(pandas)
  8. xp母盘制作流程+QQDLL+系统文件DLL修改(转)
  9. SEO人员,不要见风是雨
  10. Python在线编辑器推荐
  11. android srgb模式,一加3固件官方更新:加入屏幕边缘防误触和sRGB显示模式功能
  12. Rancher Cluster is being upgraded
  13. HTML5期末大作业:设计网站设计——动漫设计响应式(10页) HTML+CSS+JavaScript 动漫设计制作 简单静态HTML网页作品 动漫设计作业成品 学生个人网站模板
  14. createBuilderConfig 0XFFFF异常
  15. 如何区分IPEX一代/二代/三代/四代/五代
  16. 能远程控制你电脑的苹果充电线正在生产和售卖,走一个?
  17. 白盒测试——NextDate函数测试(基本路径覆盖法)
  18. 【转】浅谈程序猿的职业规划,看你如何决定自己的未来吧。
  19. 如何在微信小程序中使用ECharts图表
  20. cad高程测绘图lisp_已知CAD中的高程测绘图,很多点,如何求出所有高程的平均值呢?难道只能用计算器一个一个的相加来算吗?...

热门文章

  1. mysql sql语句里连接符的使用_SQL中group_concat函数,用符号连接查询分组里字段值...
  2. joblib多线程、多进程学习案例(一)——一步步写多进程任务
  3. http请求中必备的字符段_React Hooks中这样写HTTP请求可以避免内存泄漏
  4. 中如何移动物体在画面中的位置_如何在弱光环境中拍摄运动物体
  5. mysql 大小写问题
  6. stm32-再谈GPIO
  7. 程序员如何在百忙中更有效地利用时间,如何不走岔路,不白忙(忙得要有效率,要有收获)...
  8. 3、通过挂在系统光盘搭建本地yum仓库。
  9. GCD之线程挂起与恢复
  10. Java NIO与IO的差别和比較