- 1、本文档共8页,可阅读全部内容。
- 2、有哪些信誉好的足球投注网站(book118)网站文档一经付费(服务费),不意味着购买了该文档的版权,仅供个人/单位学习、研究之用,不得用于商业用途,未经授权,严禁复制、发行、汇编、翻译或者网络传播等,侵权必究。
- 3、本站所有内容均由合作方或网友上传,本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺!文档内容仅供研究参考,付费前请自行鉴别。如您付费,意味着您自己接受本站规则且自行承担风险,本站不退款、不进行额外附加服务;查看《如何避免下载的几个坑》。如果您已付费下载过本站文档,您可以点击 这里二次下载。
- 4、如文档侵犯商业秘密、侵犯著作权、侵犯人身权等,请点击“版权申诉”(推荐),也可以打举报电话:400-050-0827(电话支持时间:9:00-18:30)。
查看更多
实验报告_实验七实验报告_实验七
浙江大学城市学院实验报告
课程名称 操作系统原理实验
实验项目名称 实验七 进程通信——消息队列
学生姓名 潘唯帆 专业班级 计算1003 学号
实验成绩 指导老师(签名 ) 日期
注意:
? 务请保存好各自的源代码,已备后用。
? 请上传到BB平台。
一. 实验目的和要求
1. 了解Linux系统的进程间通信机构(IPC);
2. 理解Linux关于消息队列的概念;
3. 掌握Linux支持消息队列的系统调用;
4. 巩固进程同步概念。
二、实验内容
实现并发进程间消息的发送与接收。
三、实验步骤
1、消息的发送与接收
1) 编译运行给出的client.c和server.c,观察运行结果。
2) 请给上述程序添加同步控制,实现同步运行。
#include sys/types.h
#include sys/msg.h
#include sys/ipc.h
#define MSGKEY 75
struct msgform
{
long mtype;
char mtext[1000];
}msg;
int msgqid;
void server( )
{
/*创建75#消息队列*/
msgqid=msgget(MSGKEY,0777|IPC_CREAT);
do
{
/*接收消息*/
msgrcv(msgqid,msg,1030,0,0);
printf((server)received\n);
lockf(msg,0,0);
}while(msg.mtype!=1);
/*删除消息队列,归还资源*/
msgctl(msgqid,IPC_RMID,0);
exit(0);
}
main( )
{
server( );
}
#include sys/types.h
#include sys/msg.h
#include sys/ipc.h
#define MSGKEY 75
struct msgform
{
long mtype;
char mtext[1000];
}msg;
int msgqid;
void client()
{
int i;
/*打开75#消息队列*/
msgqid=msgget(MSGKEY,0777);
for(i=10;i=1;i--)
{
msg.mtype=i;
printf((client)sent\n);
/*发送消息*/
msgsnd(msgqid,msg,1024,0);
lockf(msg,1,0);
}
exit(0);
}
main( )
{
client( );
}
2、编写程序:使用消息队列,实现具有下列功能两个程序(进程):
1)程序A负责接受用户来自键盘的输入;
2)程序B负责实时输出用户由程序A接收的字符。
程序A和程序B可分别在两个进程上同时运行。
#include sys/types.h
#include sys/msg.h
#include sys/ipc.h
#define MSGKEY 75
struct msgform
{
long mtype;
char mtext[1000];
}msg;
int msgqid;
void client()
{
int i;
/*打开75#消息队列*/
msgqid=msgget(MSGKEY,0777);
for(i=100;i=1;i--)
{
msg.mtype=i;
scanf(%s,msg.mtext);
/*发送消息*/
msgsnd(msgqid,msg,1024,0);
lockf(msg,1,0);
}
exit(0);
}
main( )
{
client( );
}
#include sys/types.h
#include sys/msg.h
#include sys/ipc.h
#define MSGKEY 75
struct msgform
{
long mtype;
char mtext[1000];
}msg;
int msgqid;
void server( )
{
/*创建75#消息队列*/
msgqid=msgget(MSGKEY,0777|IPC_CREAT);
do
{
/*接收消息*/
msgrcv(msgqid,msg,1030,0,0);
printf((server)received:%s\
文档评论(0)