2022年操作系统实验-进程同步与互斥 .pdf
实验四:进程的管道通信实验题目进程的管道通信实验目的加深对进程概念的理解, 明确进程和程序的区别。学习进程创建的过程,进一步认识进程并发执行的实质。分析进程争用资源的现象,学习解决进程互斥的方法。学习解决进程同步的方法。掌握 Linux系统中进程间通过管道通信的具体实现实验内容使用系统调用 pipe()建立一条管道,系统调用fork()分别创建两个子进程,它们分别向管道写一句话,如:Child process1 is sending a message! Child process2 is sending a message! 父进程分别从管道读出来自两个子进程的信息,显示在屏幕上。当然,仅仅通过屏幕上输出这两句话还不能说明实现了进程的管道通信,为了能够更好的证明和显示出进程的同步互斥和通信,在其中要加入必要的跟踪条件,如一定的输出语句等,来反映程序的并发执行情况实验要求这是一个设计型实验,要求自行、独立编制程序。两个子进程要并发执行。实现管道的互斥使用。 当一个子进程正在对管道进行写操名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 1 页,共 10 页 - - - - - - - - - 作时,另一个欲写入管道的子进程必须等待。使用系统调用lockf(fd1,1,0)实现对管道的加锁操作,用lockf(fd1,0,0)解除对管道的锁定。实现父子进程的同步, 当父进程试图从一空管道中读取数据时,便进入等待状态,直到子进程将数据写入管道返回后,才将其唤醒。为了清楚的反应进程的同步,在子进程完成相应的操作后, 调用sleep()函数睡眠一段时间(程序中定为 3s) 。 父进程先执行 wait()函数,当有子进程执行完毕后, 会得到子进程的返回结果并清理子进程。若子进程没执行完,父进程一直执行wait()进行监听,知道有一个子进程执行完成为僵尸进程。程序中用到的系统调用因为程序时在 linux 系统上进行编写的, 所以其中要利用到相关的linux 提供的系统调用。所用到的系统调用包含在如下头文件中。#include #include #include #include #include #include fork() 用于创一个子进程。格式: int fork(); 名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 2 页,共 10 页 - - - - - - - - - 返回值:在子进程中返回0;在父进程中返回所创建的子进程的 ID 值;当返回 -1 时,创建失败。wait() 常用来控制父进程与子进程的同步。在父进程中调用 wait(),则父进程被阻塞, 进入等待队列, 等待子进程结束。 当子进程结束时, 父进程从 wait()返回继续执行原来的程序。返回值:大于 0 时,为子进程的 ID值;等于-1 时,调用失败。exit() 是进程结束时最常调用的。格式:void exit( int status); 其中,status为进程结束状态。pipe() 用于创建一个管道格式:pipe(int fd); 其中 fd 是一个由两个数组元素fd0和 fd1组成的整型数组,fd0是管道的读端口,用于从管道读出数据,fd1是管道的写端口,用于向管道写入数据。返回值: 0 调用成功; -1 调用失败。sleep() 使调用进程睡眠若干时间,之后唤醒。格式: sleep(int t); 其中 t 为睡眠时间。lockf() 用于对互斥资源加锁和解锁。在本实验中该调用的格式为:lockf(fd1,1,0);/* 表示对管道的写入端口加锁。lockf(fd1,0,0);/* 表示对管道的写入端口解锁。write(fd1,String,Length) 将字符串 String的内容写入管道的写名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 3 页,共 10 页 - - - - - - - - - 入口。read(fd0,String,Length) 从管道的读入口读出信息放入字符串String中。程序流程图程序流程简述父进程:创建管道;创建子进程 1;创建子进程 2;等待从管道中先后读出两个子进程写入的信息,并显示在屏幕上;退出。子进程:将管道的写入口加锁;将信息“ Child process n is sending message! ”输入到变量 OutPipe中,n=1,2;将 OutPipe 中信息写入管道;使自己进入睡眠状态,另一进程执行;从睡眠状态返回,将管道的写入口解锁;名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 4 页,共 10 页 - - - - - - - - - 退出。流程图开始定义相关变量创建管道pipe成功?否是输出出错信心父进程返回?否锁定管道写端将信息写入管道输出追踪信息睡眠等待父进程开锁撤销子进程P1创建子进程P2成功?是否输出出错信息父进程返回?否锁定管道写端否是消息写入管道输出跟踪信息睡眠等待父进程开锁撤销子进程P2是管道中有消息吗有读取管道中消息没有放弃处理机名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 5 页,共 10 页 - - - - - - - - - 程序源代码/*OS_3.c */ #include #include #include #include #include #include int main() pid_t pc1,pc2, pr1,pr2; int fd2; char buf150,buf250,s50; pipe(fd);/* 创建管道 */ pc1 = fork();/* 创建进程 */ if ( pc1 0 ) /* 子进程 1如果出错 */ printf(create child prcocess1 error: %sn, strerror(errno); exit(1); elseif ( pc1 = 0) /* 如果是子进程 1占据 CPU */ lockf(fd1,1,0);/* 对管道加锁 */ sprintf(buf1,child process1 %d is sending messagen,getpid(); write(fd1,buf1,50);/* 子进程 1将信息写入管道*/ printf(Now in process1 %d,Im sending a message. n,getpid();/* 输入跟踪标记 */ sleep(3);/* 子进程 1睡眠 3秒钟 */ lockf(fd1,0,0);/* 解除锁定 */ exit(0); pc2 = fork();/* 创建进程 */ if ( pc2 0 ) /* 子进程正常返回*/ read(fd0,s,50); printf(father process %d has receiced a message:%sn,getpid(),s); else/* 出错 */ printf(error: %sn.n, strerror(errno); pr2 = wait(0); /* 在这里等待子进程结束 */ if ( pr2 0 ) /* 子进程正常返回*/ read(fd0,s,50); printf(father process %d has receiced a message:%sn,getpid(),s); else/* 出错 */ printf(error: %sn.n, strerror(errno); exit(0); 程序运行结果Linux系统下编译连接完运行结果如下图名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 7 页,共 10 页 - - - - - - - - - 对以上运行结果的解释首先程序输出在子进程1 中的追踪语句,表明父进程创建完子进程后处理机由子进程调度2947 为进程 id 值,由 getpid()系统调用得到;然后处理机执行父进程,并且三秒钟后输出子进程写入管道的信息;然后是子进程2 的追踪信息,表明父进程创建子进程2 后处理机交由子进程调度;最后当终端停止三秒钟后输出父进程已经从管道中读取的子进程2 写入的信息回答以下问题:指出父进程与两个子进程并发执行的顺序,并说明原因。答:父进程创建子进程1,然后子进程 1 执行,子进程 1 执行完毕之后父进程执行并创建子进程2,子进程 2 执行,其执行完毕之后父进程执行,程序结束。即子进程先执行,然后父进程才执行。这是由进程的同步机制决定的, 因为只有子进程向管道中写入信息后,父进程才能读取;否则父进程自己调用wait()系统调用将自己阻塞 , 将处理机交由子进程。名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 8 页,共 10 页 - - - - - - - - - 若不对管道加以互斥控制,会有什么后果?答:管道进行互斥控制,是为防止两个子进程对管道资源进行争夺而产生信息丢失或覆盖。如果不加控制,那么可能一个子进程写入的信息还没来得及被父进程读出,另一个子进程又先写入信息,那么之前的进程写入的信息将被覆盖,父进程也就读不到之前进程传递来的信息了。 说明你是如何实现父子进程之间的同步的。答:父子进程的同步主要体现在两个方面1、父进程读出之前确定管道中有数据,否则阻塞自己。这一点很容一般到,通过系统调用wait() 函数,即可以实现,当子进程结束时父进程才执行,那么此时管道中肯定已经有子进程写入的数据了。2、子进程在写入之前要确定管道中的数据已经被父进程读出,否则不能写入或者阻塞自己。3、这可以通过进程间的互斥来间接的办到。因为子进程间的互斥,所以每个子进程在执行开始都对管道pipe 加锁,那么这样同时就只能有一个子进程向管道写入数据,并且子进程在向管道中写入数据后还要调用sleep()系统调用睡眠若干时间,那么这样就可以保证父进程能够从管道中读出数据。然后下一子进程才能写入。那么这样名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 9 页,共 10 页 - - - - - - - - - 就保证了开头所说的 子进程在写入之前要确定管道中的数据已经被父进程读出,否则不能写入或者阻塞自己。名师资料总结 - - -精品资料欢迎下载 - - - - - - - - - - - - - - - - - - 名师精心整理 - - - - - - - 第 10 页,共 10 页 - - - - - - - - -