📄 [ 永远的unix linux下c语言编程--进程通信、消息管理 ].htm
字号:
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<!-- saved from url=(0050)http://www.fanqiang.com/a4/b2/20010508/113803.html -->
<HTML><HEAD><TITLE>[ 永远的UNIX > Linux下C语言编程--进程通信、消息管理 ]</TITLE>
<META content="text/html; charset=gb2312" http-equiv=Content-Type>
<STYLE type=text/css>BODY {
FONT: 12pt 宋体
}
TH {
FONT: 12pt 宋体
}
INPUT {
FONT: 12pt 宋体
}
SELECT {
FONT: 12pt 宋体
}
TEXTAREA {
FONT: 12pt 宋体
}
SELECT {
FONT: 12pt 宋体
}
checkbox {
FONT: 12pt 宋体
}
A:link {
COLOR: #e6a306; TEXT-DECORATION: underline
}
A:visited {
COLOR: #e6a306; TEXT-DECORATION: underline
}
A:hover {
COLOR: #ffff00; TEXT-DECORATION: underline
}
BODY {
FONT-FAMILY: "宋体", "serif"; FONT-SIZE: 12pt
}
TD {
FONT-FAMILY: "宋体", "serif"; FONT-SIZE: 12pt
}
P {
FONT-SIZE: 9pt; LINE-HEIGHT: 150%
}
</STYLE>
<META content="MSHTML 5.00.3700.6699" name=GENERATOR></HEAD>
<BODY background="[ 永远的UNIX Linux下C语言编程--进程通信、消息管理 ].files/bline.gif"
bgColor=#000000 text=#ffffff>
<DIV align=center>
<CENTER>
<TABLE border=0 cellPadding=0 cellSpacing=0 height=400 width=750>
<TBODY>
<TR>
<TD height=45>
<P align=center><IMG alt="[ 永远的UNIX::UNIX技术资料的宝库 ]"
src="[ 永远的UNIX Linux下C语言编程--进程通信、消息管理 ].files/title.gif"></P></TD></TR>
<TR>
<TR>
<TD align=left height=40 vAlign=bottom><SMALL><A
href="http://www.fanqiang.com/">首页</A> > 编程技术 > C/C++ >
正文</SMALL></TD></TR>
<TR>
<TD bgColor=#d09f0d colSpan=5 height=2 width="100%"><IMG height=1
src="[ 永远的UNIX Linux下C语言编程--进程通信、消息管理 ].files/c.gif" width=1></TD></TR>
<TR>
<TD align=middle height=40 vAlign=center><FONT
size=5><B>Linux下C语言编程--进程通信、消息管理</B></FONT></TD></TR>
<TR>
<TD align=middle height=20><FONT color=#999999><SMALL>http://linuxc.51.net
作者:hoyt<HOYTLUO@21CN.COM> (2001-05-08 11:38:03)</SMALL></FONT></TD></TR>
<TR>
<TD align=middle>
<TABLE align=center border=0 cellPadding=0 cellSpacing=0 width=700>
<TBODY>
<TR>
<TD vAlign=top><FONT color=#cccccc>前言:Linux下的进程通信(IPC)
<BR> Linux下的进程通信(IPC)
<BR><BR>1.POSIX无名信号量 <BR>2.System V信号量
<BR>3.System V消息队列 <BR>4.System V共享内存
<BR><BR>--------------------------------------------------------------------------------
<BR>1。POSIX无名信号量 如果你学习过操作系统,那么肯定熟悉PV操作了.PV操作是原子操作.也就是操作是不可以中断的,在一定的时间内,只能够有一个进程的代码在CPU上面执行.在系统当中,有时候为了顺利的使用和保护共享资源,大家提出了信号的概念. 假设我们要使用一台打印机,如果在同一时刻有两个进程在向打印机输出,那么最终的结果会是什么呢.为了处理这种情况,POSIX标准提出了有名信号量和无名信号量的概念,由于Linux只实现了无名信号量,我们在这里就只是介绍无名信号量了. 信号量的使用主要是用来保护共享资源,使的资源在一个时刻只有一个进程所拥有.为此我们可以使用一个信号灯.当信号灯的值为某个值的时候,就表明此时资源不可以使用.否则就表>示可以使用. 为了提供效率,系统提供了下面几个函数
<BR>POSIX的无名信号量的函数有以下几个: <BR><BR>#include
<SEMAPHORE.H><BR><BR>int sem_init(sem_t *sem,int pshared,unsigned int value);
<BR>int sem_destroy(sem_t *sem);
<BR>int sem_wait(sem_t *sem);
<BR>int sem_trywait(sem_t *sem);
<BR>int sem_post(sem_t *sem);
<BR>int sem_getvalue(sem_t *sem);
<BR><BR>sem_init创建一个信号灯,并初始化其值为value.pshared决定了信号量能否在几个进程间共享.由于目前Linux还没有实现进程间共享信号灯,所以这个值只能够取0. sem_destroy是用来删除信号灯的.sem_wait调用将阻塞进程,直到信号灯的值大于0.这个函数返回的时候自动的将信号灯的值的件一.sem_post和sem_wait相反,是将信号灯的内容加一同时发出信号唤醒等待的进程..sem_trywait和sem_wait相同,不过不阻塞的,当信号灯的值为0的时候返回EAGAIN,表示以后重试.sem_getvalue得到信号灯的值.
<BR>由于Linux不支持,我们没有办法用源程序解释了.
<BR>这几个函数的使用相当简单的.比如我们有一个程序要向一个系统打印机打印两页.我们首先创建一个信号灯,并使其初始值为1,表示我们有一个资源可用.然后一个进程调用sem_wait由于这个时候信号灯的值为1,所以这个函数返回,打印机开始打印了,同时信号灯的值为0 了. 如果第二个进程要打印,调用sem_wait时候,由于信号灯的值为0,资源不可用,于是被阻塞了.当第一个进程打印完成以后,调用sem_post信号灯的值为1了,这个时候系统通知第二个进程,于是第二个进程的sem_wait返回.第二个进程开始打印了.
<BR>不过我们可以使用线程来解决这个问题的.我们会在后面解释什么是线程的.编译包含上面这几个函数的程序要加上 -lrt选贤,以连接librt.so库
<BR>2。System V信号量 为了解决上面哪个问题,我们也可以使用System V信号量.很幸运的是Linux实现了System V信号量.这样我们就可以用实例来解释了. System V信号量的函数主要有下面几个.
<BR><BR>#include <SYS types.h> <BR>#include <SYS ipc.h>
<BR>#include <SYS sem.h>
<BR><BR>key_t ftok(char *pathname,char proj);
<BR>int semget(key_t key,int nsems,int semflg);
<BR>int semctl(int semid,int semnum,int cmd,union semun arg);
<BR>int semop(int semid,struct sembuf *spos,int nspos);
<BR><BR>struct sembuf { <BR>short sem_num; /* 使用那一个信号
*/ <BR>short sem_op; /* 进行什么操作 */ <BR>short sem_flg; /*
操作的标志 */ <BR>};
<BR><BR><BR>ftok函数是根据pathname和proj来创建一个关键字.semget创建一个信号量.成功时返回信号的ID,key是一个关键字,可以是用ftok创建的也可以是IPC_PRIVATE表明由系统选用一个关键字. nsems表明我们创建的信号个数.semflg是创建的权限标志,和我们创建一个文件的标志相同.
<BR>semctl对信号量进行一系列的控制.semid是要操作的信号标志,semnum是信号的个数,cmd是操作的命令.经常用的两个值是:SETVAL(设置信号量的值)和IPC_RMID(删除信号灯).arg是一个给cmd的参数.
<BR>semop是对信号进行操作的函数.semid是信号标志,spos是一个操作数组表明要进行什么操作,nspos表明数组的个数. 如果sem_op大于0,那么操作将sem_op加入到信号量的值中,并唤醒等待信号增加的进程. 如果为0,当信号量的值是0的时候,函数返回,否则阻塞直到信号量的值为0. 如果小于0,函数判断信号量的值加上这个负值.如果结果为0唤醒等待信号量为0的进程,如果小与0函数阻塞.如果大于0,那么从信号量里面减去这个值并返回.
<BR>下面我们一以一个实例来说明这几个函数的使用方法.这个程序用标准错误输出来代替我们用的打印机.
<BR><BR>#include <STDIO.H> <BR>#include <UNISTD.H>
<BR>#include <LIMITS.H> <BR>#include <ERRNO.H>
<BR>#include <STRING.H> <BR>#include <STDLIB.H>
<BR>#include <SYS stat.h> <BR>#include <SYS wait.h>
<BR>#include <SYS ipc.h> <BR>#include <SYS sem.h>
<BR><BR>#define PERMS S_IRUSR|S_IWUSR
<BR><BR>void init_semaphore_struct(struct sembuf *sem,int semnum,
<BR>int semop,int semflg) <BR>{ <BR>/* 初始话信号灯结构 */
<BR>sem->sem_num=semnum; <BR>sem->sem_op=semop;
<BR>sem->sem_flg=semflg; <BR>}
<BR><BR>int del_semaphore(int semid) <BR>{ <BR>/*
信号灯并不随程序的结束而被删除,如果我们没删除的话(将1改为0) <BR>可以用ipcs命令查看到信号灯,用ipcrm可以删除信号灯的
<BR>*/ <BR>#if 1 <BR>return semctl(semid,0,IPC_RMID);
<BR>#endif <BR>}
<BR><BR>int main(int argc,char **argv) <BR>{
<BR> char buffer[MAX_CANON],*c; <BR> int i,n;
<BR> int semid,semop_ret,status;
<BR> pid_t childpid;
<BR> struct sembuf semwait,semsignal;
<BR><BR> if((argc!=2)||((n=atoi(argv[1]))<1))
<BR> {
<BR>fprintf(stderr,"Usage:%s number\n\a",argv[0]); <BR>exit(1);
<BR> } <BR> <BR>/*
使用IPC_PRIVATE 表示由系统选择一个关键字来创建 */ <BR>/*
创建以后信号灯的初始值为0 */
<BR> if((semid=semget(IPC_PRIVATE,1,PERMS))==-1)
<BR> {
<BR>fprintf(stderr,"[%d]:Acess Semaphore Error:%s\n\a",
<BR>getpid(),strerror(errno)); <BR>exit(1); <BR> }
<BR><BR>/* semwait是要求资源的操作(-1) */
<BR>init_semaphore_struct(&semwait,0,-1,0); <BR><BR>/*
semsignal是释放资源的操作(+1) */
<BR>init_semaphore_struct(&semsignal,0,1,0); <BR><BR>/*
开始的时候有一个系统资源(一个标准错误输出) */ <BR>if(semop(semid,&semsignal,1)==-1)
<BR> {
<BR>fprintf(stderr,"[%d]:Increment Semaphore Error:%s\n\a",
<BR>getpid(),strerror(errno)); <BR>if(del_semaphore(semid)==-1)
<BR> fprintf(stderr,"[%d]:Destroy Semaphore Error:%s\n\a",
<BR> getpid(),strerror(errno));
<BR>exit(1); <BR> } <BR><BR>/* 创建一个进程链 */ <BR>for(i=0;i<N;I++)
<br> if(childpid=fork()) break;
<BR><BR>sprintf(buffer,"[i=%d]-->[Process=%d]-->[Parent=%d]-->[Child=%d]\n",
<BR>i,getpid(),getppid(),childpid); <BR>c=buffer; <BR><BR>/*
这里要求资源,进入原子操作 */
<BR>while(((semop_ret=semop(semid,&semwait,1))==-1)&&(errno==EINTR));
<BR>if(semop_ret==-1) <BR> {
<BR>fprintf(stderr,"[%d]:Decrement Semaphore Error:%s\n\a",
<BR> getpid(),strerror(errno)); <BR> } <BR>else
<BR> { <BR>while(*c!='\0')fputc(*c++,stderr); <BR>/*
原子操作完成,赶快释放资源 */
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -