山东大学操作系统实验报告4进程同步实验.doc

计算机科学与技术学院实验报告实验题目：实验四、进程同步实验学号：日期：20120409班级：计基地12姓名： 实验目的：加深对并发协作进程同步与互斥概念的理解，观察和体验并发进程同步与互斥操作的效果，分析与研究经典进程同步与互斥问题的实际解决方案。了解 Linux 系统中 IPC 进程同步工具的用法，练习并发协作进程的同步与互斥操作的编程与调试技术。实验内容：抽烟者问题。假设一个系统中有三个抽烟者进程，每个抽烟者不断地卷烟并抽烟。抽烟者卷起并抽掉一颗烟需要有三种材料：烟草、纸和胶水。一个抽烟者有烟草，一个有纸，另一个有胶水。系统中还有两个供应者进程，它们无限地供应所有三种材料，但每次仅轮流提供三种材料中的两种。得到缺失的两种材料的抽烟者在卷起并抽掉一颗烟后会发信号通知供应者，让它继续提供另外的两种材料。这一过程重复进行。 请用以上介绍的 IPC 同步机制编程，实现该问题要求的功能。硬件环境：处理器：Intel Core i3-2350M CPU 2.30GHz 4 图形：Intel Sandybridge Mobile x86/MMX/SSE2内存：4G操作系统：32位磁盘：20.1 GB软件环境：ubuntu13.04实验步骤：（1）新建定义了producer和consumer共用的IPC函数原型和变量的ipc.h文件。（2）新建ipc.c文件，编写producer和consumer共用的IPC的具体相应函数。（3）新建Producer文件，首先定义producer的一些行为，利用系统调用，建立共享内存区域，设定其长度并获取共享内存的首地址。然后设定生产者互斥与同步的信号灯，并为他们设置相应的初值。当有生产者进程在运行而其他生产者请求时，相应的信号灯就会阻止他，当共享内存区域已满时，信号等也会提示生产者不能再往共享内存中放入内容。（4）新建Consumer文件，定义consumer的一些行为，利用系统调用来创建共享内存区域，并设定他的长度并获取共享内存的首地址。然后设定消费者互斥与同步的信号灯，并为他们设置相应的初值。当有消费进程在运行而其他消费者请求时，相应的信号灯就会阻止它，当共享内存区域已空时，信号等也会提示生产者不能再从共享内存中取出相应的内容。运行的消费者应该与相应的生产者对应起来，只有这样运行结果才会正确。结论分析与体会： 实现方式： Consumer：#include ipc.h int main(int argc,char *argv) int rate = 3; int consumerid=atoi(argv1); buff_h = 101; buff_number = 1; cget_h = 103; cget_number = 1; shm_flg = IPC_CREAT | 0644; buff_ptr = (char *)set_shm(buff_h,buff_number,shm_flg); cget_ptr = (int *)set_shm(cget_h,cget_number,shm_flg); prod_h = 201; pmtx_h = 202; cons_h = 301; cmtx_h = 302;sem_flg = IPC_CREAT | 0644; sem_val = buff_number; prod_sem = set_sem(prod_h,sem_val,sem_flg); sem_val = 0; cons_sem = set_sem(cons_h,sem_val,sem_flg); sem_val = 1; cmtx_sem = set_sem(cmtx_h,sem_val,sem_flg); if(consumerid=0)*cget_ptr=0;while(1) if(buff_ptr0-A=consumerid)down(cons_sem); down(cmtx_sem); sleep(rate); if(buff_ptr0=A)printf(%d The consumer has glue.nThe consumer gets tobacco and papern,getpid(); if(buff_ptr0=B)printf(%d The consumer has paper.nThe consumer gets tobacco and gluen,getpid(); if(buff_ptr0=C)printf(%d The consumer has tobacco.nThe consumer gets glue and papern,getpid(); *cget_ptr = (*cget_ptr+1);if(*cget_ptr%2=0)buff_ptr0=D;elsebuff_ptr0=E;up(cmtx_sem); up(prod_sem); return EXIT_SUCCESS; Producer：#include ipc.hint main(int argc,char *argv)int rate=3;int producerid=atoi(argv1);buff_h=101;buff_number=1;pput_h=102;pput_number=1;shm_flg=IPC_CREAT|0644;buff_ptr = (char *)set_shm(buff_h,buff_number,shm_flg); pput_ptr = (int *)set_shm(pput_h,pput_number,shm_flg);prod_h = 201;pmtx_h = 202;cons_h = 301;cmtx_h = 302;sem_flg = IPC_CREAT|0644; sem_val = buff_number;prod_sem = set_sem(prod_h,sem_val,sem_flg); sem_val = 0; cons_sem = set_sem(cons_h,sem_val,sem_flg); sem_val = 1; pmtx_sem = set_sem(pmtx_h,sem_val,sem_flg); if(producerid=0)buff_ptr0=D;*pput_ptr=0;while(1) if(buff_ptr0-D=producerid)down(prod_sem);down(pmtx_sem);*pput_ptr = (*pput_ptr+1)%3;if(*pput_ptr=0)buff_ptr0 = A;printf(%d The producer gives tobacco and papern,getpid(); if(*pput_ptr=1)buff_ptr0 = B;printf(%d The producer gives tobacco and gluen,getpid(); if(*pput_ptr=2)buff_ptr0 = C;printf(%d The producer gives glue and papern,getpid(); sleep(rate);up(pmtx_sem); up(cons_sem); return EXIT_SUCCESS; Ipc.h：#include ipc.hint get_ipc_id(char *proc_file,h_t h) FILE *pf; int m,n; char lineBUFSZ,columBUFSZ; if(pf = fopen(proc_file,r) = NULL) perror(Proc file not open);exit(EXIT_FAILURE); fgets(line, BUFSZ,pf); while(!feof(pf) m = n = 0;fgets(line, BUFSZ,pf); while(linem = ) m+; while(linem != )column+ = linem+; column = 0; if(atoi(colum) != h) continue; n=0;while(linem = )m+; while(linem != )column+ = linem+;column = 0; m = atoi(colum); fclose(pf); return m; fclose(pf);return -1; int down(int sem_id) struct sembuf buf; buf.sem_op = -1; buf.sem_number = 0;buf.sem_flg = SEM_UNDO; if(semop(sem_id,&buf,1) 0) perror(down error ); exit(EXIT_FAILURE); return EXIT_SUCCESS; int up(int sem_id)struct sembuf buf; buf.sem_op = 1; buf.sem_number = 0; buf.sem_flg = SEM_UNDO;if(semop(sem_id,&buf,1) 0) perror(up error ); exit(EXIT_FAILURE); return EXIT_SUCCESS; int set_sem(h_t sem_h,int sem_val,int sem_flg) int sem_id; Sem_uns sem_arg;if(sem_id = get_ipc_id(/proc/sysvipc/sem,sem_h) 0 ) if(sem_id = semget(sem_h,1,sem_flg) 0) perror(semaphore create error);exit(EXIT_FAILURE); sem_arg.val = sem_val; if(semctl(sem_id,0,SETVAL,sem_arg) 0) perror(semaphore set error); exit(EXIT_FAILURE); return sem_id; char * set_shm(h_t shm_h,int shm_number,int shm_flg) int m,shm_id;char * shm_buf; if(shm_id = get_ipc_id(/proc/sysvipc/shm,shm_h) 0 ) if(shm_id = shmget(shm_h,shm_number,shm_flg) 0) perror(shareMemory set error); exit(EXIT_FAILURE); if(shm_buf = (char *)shmat(shm_id,0,0) (char *)0) perror(get shareMemory error); exit(EXIT_FAILURE); for(m=0; mshm_number; m+) shm_bufm = 0;if(shm_buf = (char *)shmat(shm_id,0,0) (char *)0) perror(get shareMemory error); exit(EXIT_FAILURE); return shm_buf; int set_msq(h_t msq_h,int msq_flg) int msq_id; if(msq_id = get_ipc_id(/proc/sysvipc/msg,msq_h) 0 ) if(msq_id = msgget(msq_h,msq_flg) 0，则该进程继续执行；否则释放队列中第一个等待信号量的进程。PV操作的意义：我们用信号量及PV操作来实现进程的同步和互斥。信号量的数据结构为一个值和一个指针，指针指向等待该信号量的下一个进程。信号量的值与相应资源的使用情况有关。当它的值大于0时，表示当前可用资源的数量；当它的值小于0时，其绝对值表示等待使用该资源的进程个数。信号量的值仅能由PV操作来改变。一般来说，信号量S30时，S表示可用资源的数量。执行一次P操作意味着请求分配一个单位资源，因此S的值减1；当S0时，表示已经没有可用资源，请求者必须等待别的进程释放该类资源，它才能运行下去。而执行一个V操作意味着释放一个单位资源，因此S的值加1；若S0，表示有某些进程正在等待该资源，因此要唤醒一个等待状态的进程，使之运行下去。使用多于 4 个的生产者和消费者，以各种不同的启动顺序、不同的执行速率检测以上示例程序和独立实验程序也能满足同步的要求。因为使用信号量满足进程互斥的要求，任意时刻进入临界区的进程只有一个。而进程是通过信号量唤醒阻塞进程，依然可以实现