当前位置:文档之家› 操作系统实验三进程的管道通信

操作系统实验三进程的管道通信

操作系统实验三进程的管道通信
操作系统实验三进程的管道通信

操作系统实验三进程的

管道通信

Company number:【0089WT-8898YT-W8CCB-BUUT-202108】

实验三进程的管道通信

一、实验目的:

(1)加深对进程概念的理解,明确进程和程序的区别;

(2)学习进程创建的过程,进一步认识并发执行的实质;

(3)分析进程争用资源的现象,学习解决进程互斥的方法;

(4)学习解决进程同步的方法;

(5)掌握Linux系统进程间通过管道通信的具体实现方法。

二、实验内容及要求:

(1)使用系统调用pipe()建立一条管道线,两个子进程分别向管道写一句话(写的内容自己定,但要有该进程的一些信息);

(2)父进程从管道中读出来自两个子进程的消息,显示在屏幕上;

(3)要求:父进程首先接收子进程p1发来的消息,然后再接收子进程p2发来的消息;

(4)两个子进程要并发执行;

(5)实现管道的互斥使用。当一个子进程正在对管道进行写操作时,另一个欲写入管道的子进程必须等待。使用系统调用lockf(fd[1],1,0)实现对管道的加锁操作,用lockf(fd[1],0,0)解除对管道的锁定;

(6)实现父子进程的同步,当父进程试图从一空管道中读取数据时,便进入等待状态,直到子进程将数据写入管道返回后,才将其唤醒。

三、实现:

相关的系统调用

fork() 用于创一个子进程。

格式:int fork();

返回值:在子进程中返回0;在父进程中返回所创建的子进程的ID值;当返回-1时,创建失败。

wait() 常用来控制父进程与子进程的同步。

在父进程中调用wait(),则父进程被阻塞,进入等待队列,等待子进程结束。当子进程结束时,父进程从wait()返回继续执行原来的程序。

返回值:大于0时,为子进程的ID值;等于-1时,调用失败。

exit() 是进程结束时最常调用的。

格式:void exit( int status); 其中,status为进程结束状态。

pipe() 用于创建一个管道

格式:pipe(int fd);

其中fd是一个由两个数组元素fd[0]和fd[1]组成的整型

数组,fd[0]是管道的读端口,用于从管道读出数据,fd[1]是管道的写端口,用于向管道写入数据。

返回值:0 调用成功;-1 调用失败。

sleep() 使调用进程睡眠若干时间,之后唤醒。

格式:sleep(int t); 其中t为睡眠时间。

lockf() 用于对互斥资源加锁和解锁。在本实验中该调用的格式为:

lockf(fd[1],1,0);/* 表示对管道的写入端口加锁。

lockf(fd[1],0,0);/* 表示对管道的写入端口解锁。

write(fd[1],String,Length) 将字符串String的内容写入管道的写入口。read(fd[0],String,Length) 从管道的读入口读出信息放入字符串String中。程序流程图

图1 父进程流程图

图2 子进程P1流程图

四、运行结果及说明

五、源代码

#include <>

#include

#include <>

#include

#include <>

#include <>

#include <>

#include <>

int main( ){

int pid1,pid2,pid3;

int fd[2];

char outpipe[60],inpipe[60];

pipe(fd);//创建一个管道

while ((pid1=fork( ))==-1);

printf("pid1=%d\n",pid1);

if(pid1==0){

printf("The Child process 1 is sending message!\n");

lockf(fd[1],1,0);//互斥

sprintf(outpipe,"This is the child 1 process's message!\n");

write(fd[1],outpipe,60);

sleep(1);//自我阻塞1秒,让出机会执行下一个进程,增加并发度 lockf(fd[1],0,0);

exit(0);

}

else{

while((pid2=fork( ))==-1);

printf("pid2=%d\n",pid2);

if(pid2==0){

printf("The Child process 2 is sending message!\n");

lockf(fd[1],1,0);

sprintf(outpipe,"This is the child 2 process's message!\n"); write(fd[1],outpipe,60);

sleep(1);

lockf(fd[1],0,0);

exit(0);

}

else{

while((pid3=fork( ))==-1);

printf("pid3=%d\n",pid3);

if(pid3==0){

printf("The Child process 3 is sending message!\n");

lockf(fd[1],1,0);

sprintf(outpipe,"This is the child 3 process's message!\n"); write(fd[1],outpipe,60);

sleep(1);

lockf(fd[1],0,0);

exit(0);

}

else{

wait(0);//同步

read(fd[0],inpipe,60);

printf("\n%s",inpipe);

wait(0);

read(fd[0],inpipe,60);

printf("%s\n",inpipe);

wait(0);

read(fd[0],inpipe,60);

printf("%s\n",inpipe);

exit(0);

}

}

}

return 0;

}

六、回答问题

(1)指出父进程与两个子进程并发执行的顺序,并说明原因。

子进程先执行,然后父进程才执行。

这是由进程的同步机制决定的,因为只有子进程向管道中写入信息后,父进程才能读取;否则父进程自己调用wait()系统调用将自己阻塞,将处理机交由子进程。

(2)若不对管道加以互斥控制,会有什么后果

管道进行互斥控制,是为防止两个子进程对管道资源进行争夺而产生信息丢失或覆盖。如果不加控制,那么可能一个子进程写入的信息还没来得及

被父进程读出,另一个子进程又先写入信息,那么之前的进程写入的信息将被覆盖,父进程也就读不到之前进程传递来的信息了。

(3)说明你是如何实现父子进程之间的同步的。

1、父进程读出之前确定管道中有数据,否则阻塞自己。

这一点很容一般到,通过系统调用wait()函数,即可以实现,当子进程结束时父进程才执行,那么此时管道中肯定已经有子进程写入的数据了。

2、子进程在写入之前要确定管道中的数据已经被父进程读出,否则不能写入或者阻塞自己。

3、这可以通过进程间的互斥来间接的办到。因为子进程间的互斥,所以每个子进程在执行开始都对管道pipe加锁,那么这样同时就只能有一个子进程向管道写入数据,并且子进程在向管道中写入数据后还要调用sleep()系统调用睡眠若干时间,那么这样就可以保证父进程能够从管道中读出数据。然后下一子进程才能写入。那么这样就保证了开头所说的子进程在写入之前要确定管道中的数据已经被父进程读出,否则不能写入或者阻塞自己。

Linux系统编程实验六进程间通信

实验六:进程间通信 实验目的: 学会进程间通信方式:无名管道,有名管道,信号,消息队列, 实验要求: (一)在父进程中创建一无名管道,并创建子进程来读该管道,父进程来写该管道(二)在进程中为SIGBUS注册处理函数,并向该进程发送SIGBUS信号(三)创建一消息队列,实现向队列中存放数据和读取数据 实验器材: 软件:安装了Linux的vmware虚拟机 硬件:PC机一台 实验步骤: (一)无名管道的使用 1、编写实验代码pipe_rw.c #include #include #include #include #include #include int main() { int pipe_fd[2];//管道返回读写文件描述符 pid_t pid; char buf_r[100]; char* p_wbuf; int r_num; memset(buf_r,0,sizeof(buf_r));//将buf_r初始化 char str1[]=”parent write1 “holle””; char str2[]=”parent write2 “pipe”\n”; r_num=30; /*创建管道*/ if(pipe(pipe_fd)<0) { printf("pipe create error\n"); return -1; } /*创建子进程*/ if((pid=fork())==0) //子进程执行代码 {

//1、子进程先关闭了管道的写端 close(pipe_fd[1]); //2、让父进程先运行,这样父进程先写子进程才有内容读sleep(2); //3、读取管道的读端,并输出数据 if(read(pipe_fd[0],buf_r, r_num)<0) { printf(“read error!”); exit(-1); } printf(“%s\n”,buf_r); //4、关闭管道的读端,并退出 close(pipe_fd[1]); } else if(pid>0) //父进程执行代码 { //1、父进程先关闭了管道的读端 close(pipe_fd[0]); //2、向管道写入字符串数据 p_wbuf=&str1; write(pipe_fd[1],p_wbuf,sizof(p_wbuf)); p_wbuf=&str2; write(pipe_fd[1],p_wbuf,sizof(p_wbuf)); //3、关闭写端,并等待子进程结束后退出 close(pipe_fd[1]); } return 0; } /*********************** #include #include #include #include #include #include int main() { int pipe_fd[2];//管道返回读写文件描述符 pid_t pid; char buf_r[100]; char* p_wbuf; int r_num;

实验三 进程通信(一)

操作系统实验报告 实验三、进程通信(一) ——管道及共享内存 一、实验目的 熟悉和掌握LINUX系统的管道通信和共享内存通信。 二、实验内容 (一)、管道通信 1、实验原理: 管道是半双工的,数据只能向一个方向流动;需要双方通信时,需要建立起两个管道;单独构成一种独立的文件系统:管道对于管道两端的进程而言,就是一个文件,但它不是普通的文件,它不属于某种文件系统,而是自立门户,单独构成一种文件系统。 数据的读出和写入:一个进程向管道中写的内容被管道另一端的进程读出。 利用系统调用pipe()可创建一个简单的管道。 int fd[2]; pipe(fd); 调用成功,fd[0]存放供读进程使用的文件描述符(管道出口),fd[1]存放供写程使用的文件描述符(管道入口)。 一个进程在由pipe()创建管道后,一般再fork()一个子进程,然后通过管道实现父子进程间的通信,子进程将从父进程那里继承所有打开的文件描述符。则父子两个进程都能访问组成管道的两个文件描述符,这样子进程可以向父进程发送消息(或者相反)。 发送进程利用文件系统的系统调用write(fd[1],buf,size),把buf中size个字符送入fd[1],接收进程利用read(fd[0],buf,size),把从fd[0]读出的size个字符置入buf中。这样管道按FIFO(先进先出)方式传送信息。 2、实验内容: #include main() { int x,fd[2]; char buf[30],s[30]; pipe(fd); while ((x=fork())==-1);

if (x==0) { close(fd[0]); printf("Child Process!\n"); strcpy(buf,"This is an example\n"); write(fd[1],buf,30); exit(0); } else{ close(fd[1]); printf("Parent Process!\n"); read(fd[0],s,30); printf("%s\n",s); printf("x value in Parent Process:%d!\n",x); } } (1)阅读上述父子进程利用管道进行通信的例子,写出程序的运行结果并分析。 程序运行x=fork()后,创建里一个子进程,在子进程里x的返回值为0,在父进程里x的返回值为7684,则子进程会执行if语句里的代码段,先关闭了管道的读入端,再在屏幕上输出“Child Process!”,然后将“This is an example\n”存入buf数组中,通过调用write()函数将buf数组的内容从管道的写入端写入,而父进程会执行else语句里的代码段,先关闭了管道的写入端,再在屏幕上输出“Parent Process!”,然后通过调用read ()函数将buf数组的内容从管道的读入端读入冰存储在s数组里,接着通过printf()函数将s数组里的内容输出到屏幕上,最后在屏幕上输出父进程中x的值。 (2)编写程序:父进程利用管道将一字符串交给子进程处理。子进程读字符串,将里面的字符反向后再交给父进程,父进程最后读取并打印反向的字符串。 #include main() { int i,x,fd[2]; char buf[20],s[20],cpy[20],m[20]; strcpy(buf,"This is an example\n"); pipe(fd); write(fd[1],buf,20);

实验三 进程通信doc(DOC)

实验三进程通信(二) 实验目的: 1、理解进程通信原理和基本技术 2、了解linux系统进程间通信机构(IPC); 3、理解linux关于共享内存的概念; 4、掌握linux支持进程间共享内存的系统调用; 5、巩固进程同步概念。 实验内容: (一)闹钟。用c语言编程,实现进程间通过信号进行通信。 用fork()创建两个进程,子进程在等待5秒后用系统调用kill()向父进程发送SIGALRM 信号,父进程用系统调用signal()捕捉SIGALRM信号。参考程序如下: #include #include #include static int alarm_fired = 0; //闹钟未设置 //模拟闹钟 void ding(int sig) { alarm_fired = 1; //设置闹钟 } int main() { int pid; printf("alarm application starting\n"); if((pid = fork( )) == 0) { //子进程5秒后发送信号SIGALRM给父进程 sleep(5); kill(getppid(), SIGALRM); //exit(0); return 0; } //父进程安排好捕捉到SIGALRM信号后执行ding函数 printf("waiting for alarm to go off\n"); (void) signal(SIGALRM, ding); pause(); //挂起父进程,直到有一个信号出现 if (alarm_fired) printf("Ding!\n"); printf("done\n");

实验三 进程间通信

实验三进程间通信(2学时) 一、实验目的 (1)了解什么是信号。 (2)熟悉LINUX系统中进程之间软中断通信的基本原理。 (3)熟悉LINUX支持的管道通信方式。 二、实验内容 (1)编写一段程序,使其现实进程的软中断通信。 即:使用系统调用fork()创建两个子进程,再用系统调用signal()让父进程捕捉键盘上来的中断信号(即按 ctrl+c 键);当捕捉到中断信号后,父进程用系统调用kill( )向两个子进程发出信号,子进程捕捉到信号后,分别输出下列信息后终止: Child Process11 is killed by Parent! Child Process12 is killed by Parent! 父进程等待两个子进程终止后,输出如下的信息后终止 Parent Process is killed! 要求:运行以下参考程序并分析结果。 <参考程序> #include #include #include #include void waiting(),stop(),alarming(); int wait_mark; main() { int p1,p2; if(p1=fork()) /*创建子进程p1*/ { if(p2=fork()) /*创建子进程p2*/ { //父进程 wait_mark=1; signal(SIGINT,stop); /*接收到^c信号,转stop*/

signal(SIGALRM,alarming);/*接受SIGALRM*/ waiting(); kill(p1,16); /*向p1发软中断信号16*/ kill(p2,17); /*向p2发软中断信号17*/ wait(0); /*同步*/ wait(0); printf("parent process is killed!\n"); exit(0); //会暂时停止目前进程的执行,直到有信号来到或子进程结束。 } else { wait_mark=1; signal(17,stop); signal(SIGINT,SIG_IGN); /*忽略 ^c信号*/ while (wait_mark!=0); lockf(1,1,0); printf("child process2 is killed by parent!\n"); lockf(1,0,0); exit(0); } } else { wait_mark=1; signal(16,stop); signal(SIGINT,SIG_IGN); /*忽略^c信号*/ while (wait_mark!=0); lockf(1,1,0); printf("child process1 is killed by parent!\n"); lockf(1,0,0); exit(0); } } void waiting() { sleep(5); if (wait_mark!=0) kill(getpid(),SIGALRM); } void alarming()

进程间通信实验报告

进程间通信实验报告 班级:10网工三班学生姓名:谢昊天学号:1215134046 实验目的和要求: Linux系统的进程通信机构 (IPC) 允许在任意进程间大批量地交换数据。本实验的目的是了解和熟悉Linux支持的消息通讯机制及信息量机制。 实验内容与分析设计: (1)消息的创建,发送和接收。 ①使用系统调用msgget (), msgsnd (), msgrev (), 及msgctl () 编制一长度为1k 的消息的发送和接收程序。 ②观察上面的程序,说明控制消息队列系统调用msgctl () 在此起什么作用? (2)共享存储区的创建、附接和段接。 使用系统调用shmget(),shmat(),sgmdt(),shmctl(),编制一个与上述功能相同的程序。(3)比较上述(1),(2)两种消息通信机制中数据传输的时间。 实验步骤与调试过程: 1.消息的创建,发送和接收: (1)先后通过fork( )两个子进程,SERVER和CLIENT进行通信。 (2)在SERVER端建立一个Key为75的消息队列,等待其他进程发来的消息。当遇到类型为1的消息,则作为结束信号,取消该队列,并退出SERVER 。SERVER每接收到一个消息后显示一句“(server)received”。 (3)CLIENT端使用Key为75的消息队列,先后发送类型从10到1的消息,然后退出。最后的一个消息,既是 SERVER端需要的结束信号。CLIENT每发送一条消息后显示一句“(client)sent”。 (4)父进程在 SERVER和 CLIENT均退出后结束。 2.共享存储区的创建,附接和断接: (1)先后通过fork( )两个子进程,SERVER和CLIENT进行通信。 (2)SERVER端建立一个KEY为75的共享区,并将第一个字节置为-1。作为数据空的标志.等待其他进程发来的消息.当该字节的值发生变化时,表示收到了该消息,进行处理.然后再次把它的值设为-1.如果遇到的值为0,则视为结束信号,取消该队列,并退出SERVER.SERVER 每接收到一次数据后显示”(server)received”. (3)CLIENT端建立一个为75的共享区,当共享取得第一个字节为-1时, Server端空闲,可发送请求. CLIENT 随即填入9到0.期间等待Server端再次空闲.进行完这些操作后, CLIENT退出. CLIENT每发送一次数据后显示”(client)sent”. (4)父进程在SERVER和CLIENT均退出后结束。 实验结果: 1.消息的创建,发送和接收: 由 Client 发送两条消息,然后Server接收一条消息。此后Client Server交替发送和接收消息。最后一次接收两条消息。Client 和Server 分别发送和接收了10条消息。message 的传送和控制并不保证完全同步,当一个程序不再激活状态的时候,它完全可能继续睡眠,造成上面现象。在多次send message 后才 receive message.这一点有助于理解消息转送的实现机理。

操作系统实验三(进程通信)

暨南大学本科实验报告专用纸 一、实验目的 学习如何利用管道机制或消息缓冲队列进行进程间的通信,并加深对上述通信机制的理解。提高学生分析问题和解决问题的能力,并学习撰写规范的科学研究报告。 二、实验环境及设备 (一)实验室名称:计算机实验室 (二)主要仪器设备:PC 机、Linux 操作系统环境 三、实验内容 编写一段程序,使用管道来实现父子进程之间的进程通信。子进程项父进程发送自己的进程表示符,以及某字符串。父进程则通过管道读出子进程发来的消息,将消息显示在屏幕上,然后终止。 四、实验调试分析 1、实验函数说明 (1)pipe 头文件 :#include 定义函数: int pipe(int pipedes[2]); 函数说明: pipe()会建立管道,并将文件描述词由参数 pipedes 数组返回。 pipedes[0]为管道里的读取端,所以pipe 用read 调用的 pipedes[1]则为管道的写入端。 返回值: 若成功则返回零,否则返回-1,错误原因存于 errno 中。 错误代码: EMFILE 进程已用完文件描述词最大量 ENFILE 系统已无文件描述词可用。 EFAULT 参数 pipedes 数组地址不合法。 (2)sprintf 函数功能:把格式化的数据写入某个字符串 进程A pipedes[1] pipedes[0] 进程B 写 读

头文件:#include 函数原型:int sprintf( char *buffer, const char *format [, argument] … ); 返回值:字符串长度(strlen) (3)flock 头文件: #include 定义函数: int flock(int fd,int operation); 函数说明: flock()会依参数operation所指定的方式对参数fd所指的文件做各种锁定或解除锁定的动作。此函数只能锁定整个文件,无法锁定文 件的某一区域。 参数 operation有下列四种情况: LOCK_SH 建立共享锁定。多个进程可同时对同一个文件作共享锁定。 LOCK_EX 建立互斥锁定。一个文件同时只有一个互斥锁定。 LOCK_UN 解除文件锁定状态。 LOCK_NB 无法建立锁定时,此操作可不被阻断,马上返回进程。通常与LOCK_SH 或LOCK_EX 做OR(|)组合。 单一文件无法同时建立共享锁定和互斥锁定,而当使用dup()或fork()时文件描述词不会继承此种锁定。 返回值返回0表示成功,若有错误则返回-1,错误代码存于errno。 2、实验调试 实验过程中,由于将字符串"is sending a message to parent!"以字符数组的形式存储的,故只申请了31个字符空间,没有多申请一个字符空间存储末尾的'\0',在程序运行时就会出现错误结果,错误结果如下图所示,理论上应该不会出现错误的,因为在write、read函数中都有限制向管道中写入、读出多少个字符的。但在运行时却出乎意料的出错了,要是申请的空间大于字符个数,就不会出现错误了。在实验过程中还遇到了另一个问题——字符串"is sending a message to parent!"被两次输出。怀疑是该字符串被两次的写入了管道,因为查看程序时只发现一个地方有输出该字符串,该字符串是从管道读出的且只输出一次,该字符串在写入管道时也是只写了一次。总之向管道中写入一次字符串,也读出一次,但是输入该字符串时且输出了两次连续的该字符串,由于实验过程中一直调试该错误程序,没有保留当时的程序,所以没有找到当时错误的原因。

实验报告三进程管理及进程通信

实验三进程管理及进程通信 实验环境: Linux操作系统 实验目的: (1)利用Linux提供的系统调用设计程序,加深对进程概念的理解。 (2)体会系统进程调度的方法和效果。 (3)了解进程之间的通信方式以及各种通信方式的使用。 实验方法: 用vi 编写c 程序(假定程序文件名为prog1.c)编 译程序 $ gcc -o prog1.o prog1.c 或 $ cc -o prog1.o prog1.c 运行 $./prog1.o 实验内容及步骤: 实验1 编写程序。显示进程的有关标识(进程标识、组标识、用户标识等)。经过5 秒钟后,执行另一个程序,最后按用户指示(如:Y/N)结束操作。 编程截图:

运行结果: 实验2 参考例程1,编写程序。实现父进程创建一个子进程。体会子进程与父进程分 别获得不同返回值,进而执行不同的程序段的方法。 例程1:利用fork()创建子进程 /* 用fork()系统调用创建子进程的例子*/ main() { int i; if (fork()) /*父进程执行的程序段*/ i=wait(); /* 等待子进程结束*/{ printf("It is parent process.\n"); printf("The child process,ID number %d, is finished.\n",i); } else{

Printf(“It is child process.\n”); Sleep(10); Exit(); } } 运行结果: 思考: 子进程是如何产生的?又是如何结束的?子进程被创建后它的运行环境是怎样建立的? 答:是由父进程用fock()函数创建形成的,通过exit()函数自我结束,子进程被创建后核心 将其分配一个进程表项和进程标识符,检查同时运行的进程数目,并且拷贝进程表项的数据,由子进程继承父进程所有文件。 实验3 参考例程2,编写程序。父进程通过循环语句创建若干子进程。探讨进程的家族树 以及子进程继承父进程的资源的关系。 例程2:循环调用fork()创建多个子进程。 /*建立进程树*/ #include main() { int i; printf(“My pid is %d, my father’s pid is %d\n”,getpid() ,getppid()); for(i=0; i<3; i++) if(fork()==0) printf(“%d pid=%d ppid=%d\n”, i,getpid(),getppid()); else { j=wait(0); Printf(“%d:The chile %d is finished.\n”,getpid(),j);

实验三进程通信

实验三进程通信 一.实验学时与类型 学时:2,课外学时:自定 实验类型:设计性实验 二.实验目的 了解Linux的软中断、管道、消息队列、共享存储区等进程间通信方式。 三.实验容 1. 软中断通信机制 (1) 请编写一个程序:循环输出“how are you?”,在按下Ctrl+C后中断显示,输出“Byebye!”后退出程序。 #include #include int k=1; void int_func(int sig) //软中断处理函数 { k=0; } Int main() { signal(SIGINT,int_func);//预置软中断信号处理函数 While(k==1) Printf(“how are you?\n”); Printf(“byebye!”); } (2)使用信号机制实现父子进程同步,父进程先输出A,然后子进程输出B。 #include #include int k=1; void func(int sig) { k=0; } main() { int pid;

pid=fork(); if(pid>0) { printf(“A\n”); kill(pid,12); } else if(pid==0) { signal(12,func); while(k==1) sleep(1); printf(“B\n”); } } 2. 管道机制 (1) 父子进程通过管道传送一串字符。要求:子进程随机从键盘输入一串字符,通过管道发给父进程,父进程从管道中将消息读出并显示出来。 #include #include main() { int pid, fd[2] ; char outpipe[50], inpipe[50]; pipe(fd); pid=fork(); if (pid==0) { Printf(“please input some message:\n”); Fgets(inpipe,sizeof(inpipe),stdin); write(fd[1],inpipe,50); } else if (pid>0); { wait(0); Printf(“father get this message:\n”); read(fd[0],outpipe,50); printf(“%s\n”,outpipe); } }

实验三进程间通信

实验三进程间通信班级: xxx 学号: xxx 姓名: xxx 分数: 1、实验目的: Linux系统的进程通信机构(IPC)允许在任意进程间大批量的交换数据。本实验的目的是了解和熟悉Linux支持的通信机制、共享存储区机制及信号量机制。 2、实验预备内容: 阅读Linux系统的等源码文件,熟悉Linux的三种通信机制。 3、实验内容: (1)消息的创建,发送和接收 (2)使用系统调用msgget(),msgsnd(),msgrev()及msgctl()编制一长度为1k的消息发送和接收程序。 <程序设计> (1)为了便于操作和观察结果,用一个程序作为“引子”,先后fork()两个子进程,SERVER和CLIENT,进行通信。 (2)SERVER端建立一个Key为75的消息队列,等待其他进程发来的消息。当遇到类型为1的消息,则作为结束信号,取消该队列,并退出SERVER。SERVER 每接收到一个消息后显示一句“(server)received”。 (3)CLIENT端使用Key为75的消息队列,先后发送类型从10到1的消息,然后退出。最后一个消息,即是SERVER端需要的结束信号。CLIENT每发送一条 信息后显示一句“(client)sent”。 (4)父进程在SERVER和CLIENT均退出后结束。 4、源代码及运行截图: #include <> #include #include #include #define MSGKEY 75 struct msgform { long mtype; char mtext[1030]; }msg; int msgqid,i; void CLIENT() { int i; msgqid=msgget(MSGKEY,0777); for (i=10;i>=1;i--) { =i;

操作系统实验三进程地管道通信

实验三进程的管道通信 一、实验目的: (1)加深对进程概念的理解,明确进程和程序的区别; (2)学习进程创建的过程,进一步认识并发执行的实质; (3)分析进程争用资源的现象,学习解决进程互斥的方法; (4)学习解决进程同步的方法; (5)掌握Linux系统进程间通过管道通信的具体实现方法。 二、实验内容及要求: (1)使用系统调用pipe()建立一条管道线,两个子进程分别向管道写一句话(写的内容自己定,但要有该进程的一些信息); (2)父进程从管道中读出来自两个子进程的消息,显示在屏幕上;(3)要求:父进程首先接收子进程p1发来的消息,然后再接收子进程p2发来的消息; (4)两个子进程要并发执行; (5)实现管道的互斥使用。当一个子进程正在对管道进行写操作时,另一个欲写入管道的子进程必须等待。使用系统调用lockf(fd[1],1,0)实现对管道的加锁操作,用lockf(fd[1],0,0)解除对管道的锁定; (6)实现父子进程的同步,当父进程试图从一空管道中读取数据时,便进入等待状态,直到子进程将数据写入管道返回后,才将其唤醒。 三、实现: 相关的系统调用

fork() 用于创一个子进程。 格式:int fork(); 返回值:在子进程中返回0;在父进程中返回所创建的子进程的ID值;当返回-1时,创建失败。 wait() 常用来控制父进程与子进程的同步。 在父进程中调用wait(),则父进程被阻塞,进入等待队列,等待子进程结束。当子进程结束时,父进程从wait()返回继续执行原来的程序。 返回值:大于0时,为子进程的ID值;等于-1时,调用失败。 exit() 是进程结束时最常调用的。 格式:void exit( int status); 其中,status为进程结束状态。 pipe() 用于创建一个管道 格式:pipe(int fd); 其中fd是一个由两个数组元素fd[0]和fd[1]组成的整型 数组,fd[0]是管道的读端口,用于从管道读出数据,fd[1]是管道的写端口,用于向管道写入数据。 返回值:0 调用成功;-1 调用失败。 sleep() 使调用进程睡眠若干时间,之后唤醒。 格式:sleep(int t); 其中t为睡眠时间。

操作系统上实验报告3

操作系统实验三报告 实验题目: 进程管理及进程通信 实验环境: 虚拟机Linux操作系统 实验目的: 1.利用Linux提供的系统调用设计程序,加深对进程概念的理解。 2.体会系统进程调度的方法和效果。 3.了解进程之间的通信方式以及各种通信方式的使用。

实验内容: 例程1: 利用fork()创建子进程 #include<> #include<> #include<> main() { int i; if (fork()) i=wait(0); /*父进程执行的程序段*/ /* 等待子进程结束*/ printf("It is parent process.\n"); printf("The child process,ID number %d, is finished.\n",i); } else{ printf("It is child process.\n"); sleep(10); /*子进程执行的程序段*/ exit(1); /*向父进程发出结束信号*/ } } 运行结果: 思考:子进程是如何产生的又是如何结束的子进程被创建后它的运行环境是怎样建立的

答:子进程是通过函数fork()创建的,通过exit()函数自我结束的,子进程被创建后核心将为其分配一个进程表项和进程标识符,检查同时运行的进程数目,并且拷贝进程表项的数据,由子进程继承父进程的所有文件。 例程2: 循环调用fork()创建多个子进程 #include<> #include<> #include<> main() { int i,j; printf(“My pid is %d, my father’s p id is %d\n”,getpid() ,getppid()); for(i=0; i<3; i++) if(fork()==0) printf(“%d pid=%d ppid=%d\n”, i,getpid(),getppid()); else { j=wait(0); Printf(“ %d:The chile %d is finished.\n” ,getpid(),j); } } 运行结果:

实验五 进程间通信(二)

湖北工业大学工程技术学院实验报告 课程名称:操作系统实验内容:实验五进程间通信(二) 学院:工程技术学院专业班级:11gb软件2班 教师:贺红艳成绩: 一、实验目的 1、掌握linux系统中进程通信的基本原理。 2、学会使用linux系统中关于进程通信的一些系统调用。 3、掌握信号与共享存储区的使用方法。 二、相关知识背景: (一)信号 1、信号的基本概念 每个信号都对应一个正整数常量(称为signal number,即信号编号。定义在系统头文件中),代表同一用户的诸进程之间传送事先约定的信息的类型,用于通知某进程发生了某异常事件。每个进程在运行时,都要通过信号机制来检查是否有信号到达。若有,便中断正在执行的程序,转向与该信号相对应的处理程序,以完成对该事件的处理;处理结束后再返回到原来的断点继续执行。实质上,信号机制是对中断机制的一种模拟,故在早期的UNIX版本中又把它称为软中断。 ⑴信号与中断的相似点: ①采用了相同的异步通信方式; ②当检测出有信号或中断请求时,都暂停正在执行的程序而转去执行相应的处理程序; ③都在处理完毕后返回到原来的断点; ④对信号或中断都可进行屏蔽。 ⑵信号与中断的区别: ①中断有优先级,而信号没有优先级,所有的信号都是平等的; ②信号处理程序是在用户态下运行的,而中断处理程序是在核心态下运行; ③中断响应是及时的,而信号响应通常都有较大的时间延迟。 ⑶信号机制具有以下三方面的功能: ①发送信号。发送信号的程序用系统调用kill( )实现; ②预置对信号的处理方式。接收信号的程序用signal( )来实现对处理方式的预置; ③收受信号的进程按事先的规定完成对相应事件的处理。 2、信号的发送 信号的发送,是指由发送进程把信号送到指定进程的信号域的某一位上。如果目标进程正在一个可被中断的优先级上睡眠,核心便将它唤醒,发送进程就此结束。一个进程可能在其信号域中有多个位被置位,代表有多种类型的信号到达,但对于一类信号,进程却只能记住其中的某一个。进程用kill( )向一个进程或一组进程发送一个信号。 3.对信号的处理 当一个进程要进入或退出一个低优先级睡眠状态时,或一个进程即将从核心态返回用户态时,核心都要检查该进程是否已收到软中断。当进程处于核心态时,即使收到软中断

实验三 进程间通信

实验三进程间通信 UNIX/LINUX系统的进程间通信机构(IPC)允许在任意进程间大批量地交换数据。本实验的目的是了解和熟悉LINUX支持的信号量机制、管道机制、消息通信机制及共享存储区机制。 (一)信号量机制实验 【实验目的】 1、了解什么是信号。 2、熟悉LINUX系统中进程之间软中断通信的基本原理。 【实验内容】 本次实验共3部分,前两部分必做。 1、编写一段程序,使用系统调用fork( )创建两个子进程,再用系统调用signal( )让父进程捕捉键盘上来的中断信号(即按ctrl+c键),当捕捉到中断信号后,父进程用系统调用kill( )向两个子进程发出信号,子进程捕捉到信号后,分别输出下列信息后终止:Child process 1 is killed by parent! Child process 2 is killed by parent! 父进程等待两个子进程终止后,输出以下信息后终止: Parent process is killed! <参考程序> # include # include # include main() { int p1, p2; signal(SIGINT,stop);//signal()初始位置 while((p1=fork())==-1); if(p1>0) {① while((p2=fork())= =-1); If(p2>0) { ② wait_mark=1; waiting(0); kill(p1,10); kill(p2,12); wait(); wait);

实验四进程的管道通信实验

实验四进程的管道通信实验 【实验目的】 1、了解什么是管道 2、熟悉UNIX/LINUX支持的管道通信方式 【实验内容】 1、编制一段程序,实现进程的管道通信。使用pipe()建立一条管道线。两个子进程p1和p2分别向管道各写一句话: Child 1 is sending message! Child 2 is sending message! 而父进程则从管道中读出来自于两个子进程的信息,显示在屏幕上。 <参考程序> # include # include # include int pid1,pid2; main() { int fd[2]; char OutPipe[100],InPipe[100]; pipe(fd); while((pid1=fork())= = -1); if(pid1= =0) { lockf(fd[1],1,0); sprintf(OutPipe,” child 1 process is sending message!”); write(fd[1],OutPipe,50); sleep(5); lockf(fd[1],0,0); exit(0); } else { while((pid2=fork())= = -1); if(pid2= =0) { lockf(fd[1],1,0); sprintf(OutPipe,” child 2 process is sending message!”); write(fd[1],OutPipe,50); sleep(5);

lockf(fd[1],0,0); exit(0); } else { wait(0); read(fd[0],InPipe,50); printf(“%s\n”,InPipe); wait(0); read(fd[0],InPipe,50); printf(“%s\n”,InPipe); exit(0); } } } 实验要求:运行程序并分析结果。 2.在父进程中用pipe()建立一条管道线,往管道里写一句话,两个子进程接收这句话。【实验报告】 1、列出调试通过程序的清单,分析运行结果。 2、给出必要的程序设计思路和方法(或列出流程图)。 3、总结上机调试过程中所遇到的问题和解决方法及感想。 【实验相关资料】 一、什么是管道 UNIX系统在OS的发展上,最重要的贡献之一便是该系统首创了管道(pipe)。这也是UNIX系统的一大特色。 所谓管道,是指能够连接一个写进程和一个读进程的、并允许它们以生产者—消费者方式进行通信的一个共享文件,又称为pipe文件。由写进程从管道的写入端(句柄1)将数据写入管道,而读进程则从管道的读出端(句柄0)读出数据。 句柄 读出端 句柄 二、管道的类型: 1、有名管道 一个可以在文件系统中长期存在的、具有路径名的文件。用系统调用mknod( )建立。它克服无名管道使用上的局限性,可让更多的进程也能利用管道进行通信。因而其它进程可以

实验三2_Linux进程间通信

实验三2_Linux进程间通信 实验三 Linux进程间通信 一、实验目的 熟悉Linux下进程间通信机制,能够使用系统提供的各种通信机制实现并发进程间的数据交换。 二、实验题目 分别使用Linux下的共享存储区、消息、管道等通信机制,编程实现并发进程之间的相互通信。 三、背景材料 (一)需要用到的系统调用 实验可能需要用到的主要系统调用和库函数在下面列出,详细的使用方法说明通过“man 2 系统调用名”或者“man 3 函数名”命令获取。 fork() 创建一个子进程,通过返回值区分是在父进程还是子进程中执行; wait() 等待子进程执行完成; getpid() 获取当前进程id; shmget() 建立一个共享存储区; shmctl() 操纵一个共享存储区; shmat() 把一个共享存储区附接到进程内存空间; shmdt() 把一个已经附接的共享存储区从进程内存空间断开; msgget() 建立一个消息队列; msgctl() 操纵一个消息队列; msgsnd() 发送消息; msgrcv() 接收消息;

signal() 设置对信号的处理方式或处理过程; pipe() 打开管道; lockf() 锁定一个文件。 (二)使用共享存储区的示例程序 下面程序主要用来演示共享存储区的使用方法:首先要使用shmget得到共享存储区句柄(可以新建或连接已有的共享存储区,以关键字标识),然后使用shmat挂接到进程的存储空间(这样才能够访问),当使用完后,使用shmctl释放(shmctl 还可以完成一些其他功能)。这种使用逻辑也适用于消息和信号量。示例程序代码如下: #include #include #include #include #include int main(void) { int x, shmid; int *shmptr; if((shmid=shmget(IPC_PRIVATE, sizeof(int), IPC_CREAT|0666)) < 0) printf("shmget error"), exit(1); //函数原型int shmget(key_t key,int size,int shmflg); 函数用于创建(或者获取)一 key键值指定的共享内存对象,返回该对象的系统标识符:shmid;size 是创个由

实验二,进程通信,管道共享内存

操作系统实验报告 实验二:进程通信(一)——管道及共享存 一、实验目的 ?了解进程之中相互通信的方式 ?加深对管道通信的了解 ?了解共享存通信的程序设计方法 ?了解和熟悉Linux支持的共享存储区机制 二、实验容和步骤 任务一、 (1)阅读以上父子进程利用管道进行通信的例子(例1),写出程序的运行结果并分析。 (2)编写程序:父进程利用管道将一字符串交给子进程处理。子进程读字符串,将里面的字符反向后再交给父进程,父进程最后读取并打印反向的字符串 任务二、 1)阅读例2的程序,运行一次该程序,然后用ipcs命令查看系统中共享存储区的情况,再次执行该程序,再用ipcs命令查看系统中共享存的情况,对两次的结果进行比较,并分析原因。最后用

ipcrm命令删除自己建立的共享存储区。(有关ipcs和ipcrm介绍见后面一页) (2)每个同学登陆两个窗口,先在一个窗口中运行例3程序1(或者只登陆一个窗口,先在该窗口中以后台方式运行程序1),然后在另一个窗口中运行例3程序2,观察程序的运行结果并分析。 运行结束后可以用ctrl+c结束程序1的运行。 (3)编写程序:使用系统调用shmget(),shmat(),shmdt(),shmctl(),编制程序。要求在父进程中生成一个30字节长的私有共享存段。 接下来,设置一个指向共享存段的字符指针,将一串大写字母写入到该指针指向的存贮区。调用fork()生成子进程,让子进程共享存段中的容。接着,将大写字母改成小写,子进显示程修改共享存中的容。之后,子进程将脱接共享存段并退出。父进程在睡眠5秒后,在此显示共享存段中的容(此时已经是小写字母)。 三、代码及运行结果分析 1.任务1(1) ①代码: #include #include #include #include #include #include int main() { int x,fd[2]; char buf[30],s[30]; pipe(fd); while((x=fork())==-1);

实验四进程的管道通信实验

实验四进程的管道通信实验 (实验估计学时:2学时) 实验目的 1、了解什么是管道 2、熟悉UNIX/LINUX 支持的管道通信方式 实验内容 编写程序实现进程的管道通信。用系统调用pipe()建立一管道,二个子进程P1和P2分别向管道各写一句话: Child 1 is sending a message! Child 2 is sending a message! 父进程从管道中读出二个来自子进程的信息并显示(要求先接收P1,后P2)。 实验指导 一、什么是管道 UNIX系统在OS的发展上,最重要的贡献之一便是该系统首创了管道(pipe)。这也是UNIX系统的一大特色。 所谓管道,是指能够连接一个写进程和一个读进程的、并允许它们以生产者一消费者方 式进行通信的一个共享文件,又称为pipe文件。由写进程从管道的写入端(句柄1)将数据写入管道,而读进程则从管道的读出端(句柄0)读出数据。 读出端 写入端 、管道的类型: 1、有名管道 一个可以在文件系统中长期存在的、具有路径名的文件。用系统调用mknod()建立。它 克服无名管道使用上的局限性,可让更多的进程也能利用管道进行通信。因而其它进程可以知道它的存在,并能利用路径名来访问该文件。对有名管道的访问方式与访问其他文件一样, 需先用open()打开。 2、无名管道 一个临时文件。利用pipe()建立起来的无名文件(无路径名)。只用该系统调用所返回的文件描述符来标识该文件,故只有调用pipe()的进程及其子孙进程才能识别此文件描述 符,才能利用该文件(管道)进行通信。当这些进程不再使用此管道时,核心收回其索引结点。 二种管道的读写方式是相同的,本文只讲无名管道。 3、pipe文件的建立 分配磁盘和内存索引结点、为读进程分配文件表项、为写进程分配文件表项、分配用户 文件描述符 4、读/写进程互斥 内核为地址设置一个读指针和一个写指针,按先进先出顺序读、写。 为使读、写进程互斥地访问pipe文件,需使各进程互斥地访问pipe文件索引结点中的 直接地址项。因此,每次进程在访问pipe文件前,都需检查该索引文件是否已被上锁。若 是,进程便睡眠等待,否则,将其上锁,进行读/写。操作结束后解锁,并唤醒因该索引结 点上锁而睡眠的进程。

相关主题
文本预览
相关文档 最新文档