学步园

共享内存是在两个正在运行的进程之间传递数据的一种非常有效的方式。但是他并没有为我们提供同步的机制，因此我们需要用其他的机制来同步对共享内存的访问。对共享内存访问的同步控制必须要由程序员来控制。一种典型的应用是，我们用共享内存来提供对大块内存区域的有效访问，同时通过传递小消息来同步对该内存的访问。如果一个进程向共享内存段写入了数据，所做的改动立即被其他可以访问该共享内存的进程看到。

接口函数：

#include <sys/shm.h><br /> int shmget(key_t key,size_t size,int shmflg);<br /> void *shmat(int shm_id,const void *shm_addr,int shmflg);<br /> int shmctl(int shm_id,int cmd,struct shmid_ds *buf);<br /> int shmdt(const void *shm_addr);

shmget函数创建共享内存；

第一次创建共享内存段时，他不能被任何进程访问。要想启动对该共享内存的访问，必须将其连接到一个进程的地址空间中。shmat函数来完成这部分工作，第二个参数一般设为0，表示让系统来选择共享内存出现的地址。

下面来看个例程，该例程第一个进程将创建一个共享内存段，然后把写到他里面的数据显示出来；第二个例程将连接一个已有的共享内存段，并允许我们向其写入数据。

//头文件shm.h<br /> #define TEXT_SZ 2048<br /> /*定义我们希望分发的共享*/<br /> struct shared_use_at{<br /> //当有数据写入这个结构时，用整形标志write_by_you来通知消费者。<br /> int write_by_you;<br /> char some_text[TEXT_SZ];<br /> };<br /> 进程1：<br /> /*消费者程序，这段程序将创建一共享内存断，然后把写到他里面的数据都显示出来*/<br /> #include <unistd.h><br /> #include <stdlib.h><br /> #include <stdio.h><br /> #include <string.h><br /> #include <sys/types.h><br /> #include <sys/ipc.h><br /> #include <sys/shm.h><br /> #include "shm.h"<br /> int main()<br /> {<br /> int shm_id;<br /> struct shared_use_at *shared_stuff;<br /> void *shared_memory = (void *)0;<br /> int running = 1;</p> <p> srand((unsigned int)getpid());<br /> //创建共享内存段，该共享内存段由key_t类型参数命名<br /> shm_id = shmget((key_t)1234,sizeof(struct shared_use_at),0666|IPC_CREAT);<br /> if(shm_id == -1)<br /> {<br /> fprintf(stderr,"shared memory create failed!");<br /> exit (1);<br /> }<br /> //把创建好的内存段连接到进程地址空间中<br /> shared_memory = shmat(shm_id,0,0);<br /> if(shared_memory == (void *)-1)<br /> {<br /> fprintf(stderr,"shmat failed!");<br /> exit (1);<br /> }</p> <p> shared_stuff = (struct shared_use_at *)shared_memory;<br /> shared_stuff->write_by_you = 0;</p> <p> while(running)<br /> {<br /> //如果标志位1，则显示共享内存段的数据，并且标志位清0<br /> if(shared_stuff->write_by_you)<br /> {<br /> printf("you wrote:%s",shared_stuff->some_text);<br /> sleep(rand()%4);<br /> shared_stuff->write_by_you = 0;<br /> if(strncmp(shared_stuff->some_text,"end",3) == 0)<br /> running = 0;<br /> }<br /> }<br /> //共享内存被分离<br /> if(shmdt(shared_memory) == -1)<br /> {<br /> fprintf(stderr,"shmtd failed!");<br /> exit (1);<br /> }<br /> //删除内存共享段<br /> if(shmctl(shm_id,IPC_RMID,0) == -1)<br /> {<br /> fprintf(stderr,"shmctl(IPC_RMID) failed!");<br /> exit (1);<br /> } </p> <p> return 0;<br /> }<br /> 进程2：<br /> /*生产者程序，这段程序向消费者程序输入数据*/<br /> #include <unistd.h><br /> #include <stdlib.h><br /> #include <stdio.h><br /> #include <string.h><br /> #include <sys/types.h><br /> #include <sys/ipc.h><br /> #include <sys/shm.h><br /> #include "shm.h"<br /> int main()<br /> {<br /> int shm_id;<br /> struct shared_use_at *shared_stuff;<br /> void *shared_memory = (void *)0;<br /> char buffer[BUFSIZ];<br /> int running = 1;</p> <p> srand((unsigned int)getpid());<br /> //创建共享内存段，该共享内存段由key_t类型参数命名<br /> shm_id = shmget((key_t)1234,sizeof(struct shared_use_at),0666|IPC_CREAT);<br /> if(shm_id == -1)<br /> {<br /> fprintf(stderr,"shared memory create failed!");<br /> exit (1);<br /> }<br /> //把创建好的内存段连接到进程地址空间中<br /> shared_memory = shmat(shm_id,0,0);<br /> if(shared_memory == (void *)-1)<br /> {<br /> fprintf(stderr,"shmat failed!");<br /> exit (1);<br /> }</p> <p> shared_stuff = (struct shared_use_at *)shared_memory;</p> <p> while(running)<br /> {<br /> //标志为1，表示进程1会显示数据，等待他<br /> while(shared_stuff->write_by_you == 1)<br /> {<br /> sleep(1);<br /> printf("waiting for client.../n");<br /> }<br /> //当标志为0时，表示进程1已经显示了数据，向共享内存段写数据<br /> printf("enter some text:");<br /> fgets(buffer,BUFSIZ,stdin);</p> <p> strncpy(shared_stuff->some_text,buffer,TEXT_SZ);<br /> //写好了，置位标志位<br /> shared_stuff->write_by_you = 1;<br /> //判断结束附<br /> if(strncmp(buffer,"end",3) == 0)<br /> {<br /> running = 0;<br /> }<br /> }<br /> //共享内存被分离<br /> if(shmdt(shared_memory) == -1)<br /> {<br /> fprintf(stderr,"shmtd failed!");<br /> exit (1);<br /> }</p> <p> return 0;<br /> }<br /> 运行结果：<br /> $ ./shm1 &<br /> [1] 2604<br /> [sea@localhost ~]$ ./shm2<br /> enter some text:see you<br /> you wrote:see you<br /> waiting for client...<br /> waiting for client...<br /> waiting for client...<br /> waiting for client...<br /> enter some text:see me<br /> you wrote:see me<br /> waiting for client...<br /> waiting for client...<br /> enter some text:俄^H恩<br /> you wrote:俄<br /> waiting for client...<br /> waiting for client...<br /> waiting for client...<br /> enter some text:end<br /> you wrote:end<br /> [sea@localhost ~]$