信号量实现进程同步

#include<sys/mman.h>    
#include<sys/types.h>    
#include<linux/sem.h>    
#include<fcntl.h>    
#include<unistd.h>    
#include<stdio.h>    
#include<errno.h>    
#include<time.h>    
#define MAXSEM 5    /*声明三个信号量ID*/     
int fullid;     
int emptyid;     
int mutxid;        
int main(){     
    struct sembuf P,V;     
    union semun arg;   /* 声明共享主存*/     
    int *array;     
    int *sum;     
    int *set;     
    int *get;   /*将array、sum、set、get映射到共享主存*/     
    array=(
拥有帝国一切，皆有可能。欢迎访问phome.netint *)shmat(shmget(IPC_PRIVATE,sizeof(int)*MAXSEM,IPC_CREAT|0666),0,0);     
    sum=(int *)shmat(shmget(IPC_PRIVATE,sizeof(int),IPC_CREAT|0666),0,0);     
    set=(int *)shmat(shmget(IPC_PRIVATE,sizeof(int),IPC_CREAT|0666),0,0);     
    get=(int *)shmat(shmget(IPC_PRIVATE,sizeof(int),IPC_CREAT|0666),0,0);     
    *get=0;   /*创建信号量fullid、emptyid和mutxid*/     
      
    fullid=semget(IPC_PRIVATE,0666|IPC_CREAT);     
    emptyid=semget(IPC_PRIVATE,0666|IPC_CREAT);     
    mutxid=semget(IPC_PRIVATE,0666|IPC_CREAT);      /*为信号量赋值*/     
    arg.val=0;     
    if(semctl(fullid,0,SETVAL,arg)==-1)   
        perror("semctl setval error");     
    arg.val=MAXSEM;     
    if(semctl(emptyid,0,SETVAL,arg)==-1)   
        perror("semctl setval error");     
拥有帝国一切，皆有可能。欢迎访问phome.net
    arg.val=1;     
    if(semctl(mutxid,0,SETVAL,arg)==-1)   
        perror("semctl setval error");      /*初始化PV*/     
    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;      
        *set=0;      
        while(i<100){       
            semop(emptyid,&P,1);       
            semop(mutxid,&P,1);//对emptyid、mutxid执行P操作            
            array[(*set)%MAXSEM]=i 1;       
            (*set)  ;            
            semop(mutxid,&V,1);         //对emptyid、mutxid执行V操作                
            semop(fullid,&V,1);          //       
            i  ;    }      
        sleep(3);      
        printf("生产者结束\n");      

拥有帝国一切，皆有可能。欢迎访问phome.net        exit(0);      
    }else{     /*创建消费者进程*/       
        if(fork()==0){      while(1){         
            semop(fullid,&P,1);        //对emptyid、mutxid执行P操作         
            semop(mutxid,&P,1);       //           
            if(*get==100)         
                break;         
            *sum =array[(*get)%MAXSEM];         
            printf("The ConmsumerA Get Number %d\n",array[(*get)%MAXSEM]);         
            (*get)  ;         
            if(get==100)         
                printf("The sum is %d\n",sum);         
            semop(mutxid,&V,1);         
            semop(emptyid,&V,1);         
            sleep(1);             }        
        printf("消费者结束\n");        
        exit(0);      }else{     /*创建消费者进程B*/       
            if

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!