進(jìn)程間通信之： 共享內(nèi)存
加入技術(shù)交流群
3．使用實(shí)例
該實(shí)例說(shuō)明如何使用基本的共享內(nèi)存函數(shù)。首先是創(chuàng)建一個(gè)共享內(nèi)存區(qū)（采用的共享內(nèi)存的鍵值為IPC_PRIVATE，是因?yàn)楸緦?shí)例中創(chuàng)建的共享內(nèi)存是父子進(jìn)程之間的共用部分），之后創(chuàng)建子進(jìn)程，在父子兩個(gè)進(jìn)程中將共享內(nèi)存分別映射到各自的進(jìn)程地址空間之中。
父進(jìn)程先等待用戶輸入，然后將用戶輸入的字符串寫入到共享內(nèi)存，之后往共享內(nèi)存的頭部寫入“WROTE”字符串表示父進(jìn)程已成功寫入數(shù)據(jù)。子進(jìn)程一直等到共享內(nèi)存的頭部字符串為“WROTE”，然后將共享內(nèi)存的有效數(shù)據(jù)（在父進(jìn)程中用戶輸入的字符串）在屏幕上打印。父子兩個(gè)進(jìn)程在完成以上工作之后，分別解除與共享內(nèi)存的映射關(guān)系。
最后在子進(jìn)程中刪除共享內(nèi)存。因?yàn)楣蚕韮?nèi)存自身并不提供同步機(jī)制，所以應(yīng)該額外實(shí)現(xiàn)不同進(jìn)程之間的同步（例如：信號(hào)量）。為了簡(jiǎn)單起見(jiàn)，在本實(shí)例中用標(biāo)志字符串來(lái)實(shí)現(xiàn)非常簡(jiǎn)單的父子進(jìn)程之間的同步。
這里要介紹的一個(gè)命令是ipcs，這是用于報(bào)告進(jìn)程間通信機(jī)制狀態(tài)的命令。它可以查看共享內(nèi)存、消息隊(duì)列等各種進(jìn)程間通信機(jī)制的情況，這里使用了system()函數(shù)用于調(diào)用shell命令“ipcs”。程序源代碼如下所示：
/*shmem.c*/
#includesys/types.h>
#includesys/ipc.h>
#includesys/shm.h>
#includestdio.h>
#includestdlib.h>
#includestring.h>
#defineBUFFER_SIZE2048
intmain()
{
pid_tpid;
intshmid;
char*shm_addr;
charflag[]=WROTE;
char*buff;
/*創(chuàng)建共享內(nèi)存*/
if((shmid=shmget(IPC_PRIVATE,BUFFER_SIZE,0666))0)
{
perror(shmget);
exit(1);
}
else
{
printf(Createshared-memory:%dn,shmid);
}
/*顯示共享內(nèi)存情況*/
system(ipcs-m);
pid=fork();
if(pid==-1)
{
perror(fork);
exit(1);
}
elseif(pid==0)/*子進(jìn)程處理*/
{
/*映射共享內(nèi)存*/
if((shm_addr=shmat(shmid,0,0))==(void*)-1)
{
perror(Child:shmat);
exit(1);
}
else
{
printf(Child:Attachshared-memory:%pn,shm_addr);
}
system(ipcs-m);
/*通過(guò)檢查在共享內(nèi)存的頭部是否標(biāo)志字符串WROTE來(lái)確認(rèn)
父進(jìn)程已經(jīng)向共享內(nèi)存寫入有效數(shù)據(jù)*/
while(strncmp(shm_addr,flag,strlen(flag)))
{
printf(Child:Waitforenabledata...n);
sleep(5);
}
/*獲取共享內(nèi)存的有效數(shù)據(jù)并顯示*/
strcpy(buff,shm_addr+strlen(flag));
printf(Child:Shared-memory:%sn,buff);
/*解除共享內(nèi)存映射*/
if((shmdt(shm_addr))0)
{
perror(shmdt);
exit(1);
}
else
{
printf(Child:Deattachshared-memoryn);
}
system(ipcs-m);
/*刪除共享內(nèi)存*/
if(shmctl(shmid,IPC_RMID,NULL)==-1)
{
perror(Child:shmctl(IPC_RMID)n);
exit(1);
}
else
{
printf(Deleteshared-memoryn);
}
system(ipcs-m);
}
else/*父進(jìn)程處理*/
{
/*映射共享內(nèi)存*/
if((shm_addr=shmat(shmid,0,0))==(void*)-1)
{
perror(Parent:shmat);
exit(1);
}
else
{
printf(Parent:Attachshared-memory:%pn,shm_addr);
}
sleep(1);
printf(nInputsomestring:n);
fgets(buff,BUFFER_SIZE,stdin);
strncpy(shm_addr+strlen(flag),buff,strlen(buff));
strncpy(shm_addr,flag,strlen(flag));
/*解除共享內(nèi)存映射*/
if((shmdt(shm_addr))0)
{
perror(Parent:shmdt);
exit(1);
}
else
{
printf(Parent:Deattachshared-memoryn);
}
system(ipcs-m);
waitpid(pid,NULL,0);
printf(Finishedn);
}
exit(0);
}
linux操作系統(tǒng)文章專題:linux操作系統(tǒng)詳解（linux不再難懂）
評(píng)論