IO进程线程day8作业

信号灯集二次函数封装

sem.c

#include<myhead.h>union semun
{int              val;    /* Value for SETVAL */struct semid_ds *buf;    /* Buffer for IPC_STAT, IPC_SET */unsigned short  *array;  /* Array for GETALL, SETALL */struct seminfo  *__buf;  /* Buffer for IPC_INFO(Linux-specific) */
};//定义给信号灯集中的指定信号灯进行赋值
int init_semno(int semid,int semno)
{union semun buf;printf("请输入要给编号为%d的灯设置的值：",semno);scanf("%d",&buf.val);getchar();//调用控制函数if(semctl(semid,semno,SETVAL,buf)==-1){perror("semctl error");return -1;}return 0;
}
//创建或打开共享内存
int open_sem(int semcount)
{//创建key值key_t key=-1;if((key=ftok("/",'s'))==-1){perror("ftok error");return -1;}//通过key值创建一个信号灯集int semid =-1;if((semid=semget(key,semcount,IPC_CREAT|0064))==-1){//对错误码进行判断，if(errno==EEXIST){//直接打开信号灯集即可semid=semget(key,semcount,IPC_CREAT|0664);return semid;}perror("semget error");return -1;}//给信号灯集中的每个灯进行初始化for(int i=0;i<semcount;i++){init_semno(semid,i);}return semid;
}//进行资源申请操作
int P(int semid,int semno)
{//定义要进行的结构体变量struct sembuf buf;buf.sem_num=semno;buf.sem_op=-1;buf.sem_flg=0;//执行函数if(semop(semid,&buf,1)==-1){perror("P error");return -1;}return 0;
}//进行资源释放操作
int V(int semid,int semno)
{//定义要进行的结构体变量struct sembuf buf;buf.sem_num=semno;buf.sem_op=1;buf.sem_flg=0;//执行函数if(semop(semid,&buf,1)==-1){perror("V error");return -1;}return 0;
}//删除信号灯集
int del_sem(int semid)
{//删除信号灯集if(semctl(semid,0,IPC_RMID)==-1){perror("delete error");return -1;}return 0;
}

sem.h

#ifndef _SEM_H_
#define _SEM_H_
//创建或打开共享内存：参数为要申请的信号灯集中包含的灯的个数，返回信号灯集的id
int open_sem(int semcount);//进行资源申请操作：参数为要申请的信号灯id，以及灯的编号
int P(int semid,int semno);//进行释放资源操作：参数为要申请的信号灯，以及灯的编号
int V(int semid,int semno);//删除信号灯集的操作：参数为要删除的信号灯集id
int del_sem(int semid);#endif

shmsnd.c

#include<myhead.h>union semun
{int              val;    /* Value for SETVAL */struct semid_ds *buf;    /* Buffer for IPC_STAT, IPC_SET */unsigned short  *array;  /* Array for GETALL, SETALL */struct seminfo  *__buf;  /* Buffer for IPC_INFO(Linux-specific) */
};//定义给信号灯集中的指定信号灯进行赋值
int init_semno(int semid,int semno)
{union semun buf;printf("请输入要给编号为%d的灯设置的值：",semno);scanf("%d",&buf.val);getchar();//调用控制函数if(semctl(semid,semno,SETVAL,buf)==-1){perror("semctl error");return -1;}return 0;
}
//创建或打开共享内存
int open_sem(int semcount)
{//创建key值key_t key=-1;if((key=ftok("/",'s'))==-1){perror("ftok error");return -1;}//通过key值创建一个信号灯集int semid =-1;if((semid=semget(key,semcount,IPC_CREAT|0064))==-1){//对错误码进行判断，if(errno==EEXIST){//直接打开信号灯集即可semid=semget(key,semcount,IPC_CREAT|0664);return semid;}perror("semget error");return -1;}//给信号灯集中的每个灯进行初始化for(int i=0;i<semcount;i++){init_semno(semid,i);}return semid;
}//进行资源申请操作
int P(int semid,int semno)
{//定义要进行的结构体变量struct sembuf buf;buf.sem_num=semno;buf.sem_op=-1;buf.sem_flg=0;//执行函数if(semop(semid,&buf,1)==-1){perror("P error");return -1;}return 0;
}//进行资源释放操作
int V(int semid,int semno)
{//定义要进行的结构体变量struct sembuf buf;buf.sem_num=semno;buf.sem_op=1;buf.sem_flg=0;//执行函数if(semop(semid,&buf,1)==-1){perror("V error");return -1;}return 0;
}//删除信号灯集
int del_sem(int semid)
{//删除信号灯集if(semctl(semid,0,IPC_RMID)==-1){perror("delete error");return -1;}return 0;
}ubuntu@ubuntu:~/IO进程线程/2.26/sem$ 
ubuntu@ubuntu:~/IO进程线程/2.26/sem$ sem.h
sem.h：未找到命令
ubuntu@ubuntu:~/IO进程线程/2.26/sem$ cat sem.h
#ifndef _SEM_H_
#define _SEM_H_
//创建或打开共享内存：参数为要申请的信号灯集中包含的灯的个数，返回信号灯集的id
int open_sem(int semcount);//进行资源申请操作：参数为要申请的信号灯id，以及灯的编号
int P(int semid,int semno);//进行释放资源操作：参数为要申请的信号灯，以及灯的编号
int V(int semid,int semno);//删除信号灯集的操作：参数为要删除的信号灯集id
int del_sem(int semid);#endif
ubuntu@ubuntu:~/IO进程线程/2.26/sem$ ubuntu@ubuntu:~/IO进程线程/2.26/sem$ cat shmsnd.c
#include<myhead.h>
#include"sem.h"
//一页大小
#define PAGE_SIZE 4096
int main(int argc, const char *argv[])
{//11.创建信号灯集int semid=open_sem(2);//1.创建key值key_t key=-1;if((key=ftok("/",'k'))==-1){perror("ftok error");return -1;}printf("key=%d\n",key);//2.通过keu值创建一个共享内存int shmid=-1;if((shmid=shmget(key,PAGE_SIZE,IPC_CREAT|0064))==-1){perror("shmget error");return -1;}printf("shmid=%d\n",shmid);//3.将共享内存段的数据映射到内存空间char *addr = shmat(shmid,NULL,0);if(addr==(void*)-1){perror("shmat error");return -1;}printf("addr=%p\n",addr);//4.使用共享内存while(1){//22.申请0号灯的资源P(semid,0);printf("please enter:");fgets(addr,PAGE_SIZE,stdin);addr[strlen(addr)-1]=0;printf("数据发送成功\n");//33.释放一号灯的资源V(semid,1);//判断输入内容if(strcmp(addr,"quit")==0){break;}}//5.取消映射关系if(shmdt(addr)==-1){perror("shmdt error");return -1;}//6.删除共享内存if(shmctl(shmid,IPC_RMID,NULL)==-1){perror("shmctl error");return -1;}return 0;
}

shmrcv.c

#include<myhead.h>
#include"sem.h"
//一页大小
#define PAGE_SIZE 4096
int main(int argc, const char *argv[])
{//11.创建信号灯集int semid = open_sem(2);//1.创建key值key_t key=-1;if((key=ftok("/",'k'))==-1){perror("ftok error");return -1;}printf("key=%d\n",key);//2.通过key值创建一个共享内存int shmid=-1;if((shmid=shmget(key,PAGE_SIZE,IPC_CREAT|0064))==-1){perror("shmget error");return -1;}printf("shmid=%d\n",shmid);//3.将共享内存段的数据映射到内存空间char *addr = shmat(shmid,NULL,0);if(addr==(void*)-1){perror("shmat error");return -1;}printf("addr=%p\n",addr);//4.使用共享内存while(1){//22.申请一号灯的资源P(semid,1);//	sleep(1);printf("get text:%s\n",addr);//判断读取内容if(strcmp(addr,"quit")==0){break;}//33.释放0号灯的资源V(semid,0);}//5.取消映射关系if(shmdt(addr)==-1){perror("shmdt error");return -1;}//44.删除信号灯集del_sem(semid);return 0;
}

思维导图：