内存共享 一

下面将讲解进程间通信的另一种方式，使用共享内存。

一、什么是共享内存

顾名思义，共享内存就是允许两个不相关的进程访问同一个逻辑内存。共享内存是在两个正在运行的进程之间共享和传递数据的一种非常有效的方式。不同进程之间共享的内存通常安排为同一段物理内存。进程可以将同一段共享内存连接到它们自己的地址空间中，所有进程都可以访问共享内存中的地址，就好像它们是由用C语言函数malloc分配的内存一样。而如果某个进程向共享内存写入数据，所做的改动将立即影响到可以访问同一段共享内存的任何其他进程。

特别提醒：共享内存并未提供同步机制，也就是说，在第一个进程结束对共享内存的写操作之前，并无自动机制可以阻止第二个进程开始对它进行读取。所以我们通常需要用其他的机制来同步对共享内存的访问，例如前面说到的信号量。有关信号量的更多内容，可以查阅我的另一篇文章：Linux进程间通信——使用信号量

二、共享内存的使得

与信号量一样，在Linux中也提供了一组函数接口用于使用共享内存，而且使用共享共存的接口还与信号量的非常相似，而且比使用信号量的接口来得简单。它们声明在头文件 sys/shm.h中。

1、shmget函数

该函数用来创建共享内存，它的原型为：

[cpp] view plaincopyprint?

  1. int shmget(key_t key, size_t size, int shmflg);

[cpp] view plaincopyprint?

  1. int shmget(key_t key, size_t size, int shmflg);

第一个参数，与信号量的semget函数一样，程序需要提供一个参数key（非0整数），它有效地为共享内存段命名，shmget函数成功时返回一个与key相关的共享内存标识符（非负整数），用于后续的共享内存函数。调用失败返回-1.

不相关的进程可以通过该函数的返回值访问同一共享内存，它代表程序可能要使用的某个资源，程序对所有共享内存的访问都是间接的，程序先通过调用shmget函数并提供一个键，再由系统生成一个相应的共享内存标识符（shmget函数的返回值），只有shmget函数才直接使用信号量键，所有其他的信号量函数使用由semget函数返回的信号量标识符。

第二个参数，size以字节为单位指定需要共享的内存容量

第三个参数，shmflg是权限标志，它的作用与open函数的mode参数一样，如果要想在key标识的共享内存不存在时，创建它的话，可以与IPC_CREAT做或操作。共享内存的权限标志与文件的读写权限一样，举例来说，0644,它表示允许一个进程创建的共享内存被内存创建者所拥有的进程向共享内存读取和写入数据，同时其他用户创建的进程只能读取共享内存。

2、shmat函数

第一次创建完共享内存时，它还不能被任何进程访问，shmat函数的作用就是用来启动对该共享内存的访问，并把共享内存连接到当前进程的地址空间。它的原型如下：

[cpp] view plaincopyprint?

  1. void *shmat(int shm_id, const void *shm_addr, int shmflg);

[cpp] view plaincopyprint?

  1. void *shmat(int shm_id, const void *shm_addr, int shmflg);

第一个参数，shm_id是由shmget函数返回的共享内存标识。

第二个参数，shm_addr指定共享内存连接到当前进程中的地址位置，通常为空，表示让系统来选择共享内存的地址。

第三个参数，shm_flg是一组标志位，通常为0。

调用成功时返回一个指向共享内存第一个字节的指针，如果调用失败返回-1.

3、shmdt函数

该函数用于将共享内存从当前进程中分离。注意，将共享内存分离并不是删除它，只是使该共享内存对当前进程不再可用。它的原型如下：

[cpp] view plaincopyprint?

  1. int shmdt(const void *shmaddr);

[cpp] view plaincopyprint?

  1. int shmdt(const void *shmaddr);

参数shmaddr是shmat函数返回的地址指针，调用成功时返回0，失败时返回-1.

4、shmctl函数

与信号量的semctl函数一样，用来控制共享内存，它的原型如下：

[cpp] view plaincopyprint?

  1. int shmctl(int shm_id, int command, struct shmid_ds *buf);

[cpp] view plaincopyprint?

  1. int shmctl(int shm_id, int command, struct shmid_ds *buf);

第一个参数，shm_id是shmget函数返回的共享内存标识符。

第二个参数，command是要采取的操作，它可以取下面的三个值 ：

IPC_STAT：把shmid_ds结构中的数据设置为共享内存的当前关联值，即用共享内存的当前关联值覆盖shmid_ds的值。

IPC_SET：如果进程有足够的权限，就把共享内存的当前关联值设置为shmid_ds结构中给出的值

IPC_RMID：删除共享内存段

第三个参数，buf是一个结构指针，它指向共享内存模式和访问权限的结构。

shmid_ds结构至少包括以下成员：

[cpp] view plaincopyprint?

  1. struct shmid_ds
  2. {
  3. uid_t shm_perm.uid;
  4. uid_t shm_perm.gid;
  5. mode_t shm_perm.mode;
  6. };

[cpp] view plaincopyprint?

  1. struct shmid_ds
  2. {
  3. uid_t shm_perm.uid;
  4. uid_t shm_perm.gid;
  5. mode_t shm_perm.mode;
  6. };

三、使用共享内存进行进程间通信

说了这么多，又到了实战的时候了。下面就以两个不相关的进程来说明进程间如何通过共享内存来进行通信。其中一个文件shmread.c创建共享内存，并读取其中的信息，另一个文件shmwrite.c向共享内存中写入数据。为了方便操作和数据结构的统一，为这两个文件定义了相同的数据结构，定义在文件shmdata.c中。结构shared_use_st中的written作为一个可读或可写的标志，非0：表示可读，0表示可写，text则是内存中的文件。

shmdata.c的源代码如下：

[cpp] view plaincopyprint?

  1. #ifndef _SHMDATA_H_HEADER
  2. #define _SHMDATA_H_HEADER
  3. #define TEXT_SZ 2048
  4. struct shared_use_st
  5. {
  6. int written;//作为一个标志，非0：表示可读，0表示可写
  7. char text[TEXT_SZ];//记录写入和读取的文本
  8. };
  9. #endif

[cpp] view plaincopyprint?

  1. #ifndef _SHMDATA_H_HEADER
  2. #define _SHMDATA_H_HEADER
  3. #define TEXT_SZ 2048
  4. struct shared_use_st
  5. {
  6. int written;//作为一个标志，非0：表示可读，0表示可写
  7. char text[TEXT_SZ];//记录写入和读取的文本
  8. };
  9. #endif

源文件shmread.c的源代码如下：

[cpp] view plaincopyprint?

  1. #include <unistd.h>
  2. #include <stdlib.h>
  3. #include <stdio.h>
  4. #include <sys/shm.h>
  5. #include "shmdata.h"
  6. int main()
  7. {
  8. int running = 1;//程序是否继续运行的标志
  9. void *shm = NULL;//分配的共享内存的原始首地址
  10. struct shared_use_st *shared;//指向shm
  11. int shmid;//共享内存标识符
  12. //创建共享内存
  13. shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666|IPC_CREAT);
  14. if(shmid == -1)
  15. {
  16. fprintf(stderr, "shmget failed\n");
  17. exit(EXIT_FAILURE);
  18. }
  19. //将共享内存连接到当前进程的地址空间
  20. shm = shmat(shmid, 0, 0);
  21. if(shm == (void*)-1)
  22. {
  23. fprintf(stderr, "shmat failed\n");
  24. exit(EXIT_FAILURE);
  25. }
  26. printf("\nMemory attached at %X\n", (int)shm);
  27. //设置共享内存
  28. shared = (struct shared_use_st*)shm;
  29. shared->written = 0;
  30. while(running)//读取共享内存中的数据
  31. {
  32. //没有进程向共享内存定数据有数据可读取
  33. if(shared->written != 0)
  34. {
  35. printf("You wrote: %s", shared->text);
  36. sleep(rand() % 3);
  37. //读取完数据，设置written使共享内存段可写
  38. shared->written = 0;
  39. //输入了end，退出循环（程序）
  40. if(strncmp(shared->text, "end", 3) == 0)
  41. running = 0;
  42. }
  43. else//有其他进程在写数据，不能读取数据
  44. sleep(1);
  45. }
  46. //把共享内存从当前进程中分离
  47. if(shmdt(shm) == -1)
  48. {
  49. fprintf(stderr, "shmdt failed\n");
  50. exit(EXIT_FAILURE);
  51. }
  52. //删除共享内存
  53. if(shmctl(shmid, IPC_RMID, 0) == -1)
  54. {
  55. fprintf(stderr, "shmctl(IPC_RMID) failed\n");
  56. exit(EXIT_FAILURE);
  57. }
  58. exit(EXIT_SUCCESS);
  59. }

[cpp] view plaincopyprint?

  1. #include <unistd.h>
  2. #include <stdlib.h>
  3. #include <stdio.h>
  4. #include <sys/shm.h>
  5. #include "shmdata.h"
  6. int main()
  7. {
  8. int running = 1;//程序是否继续运行的标志
  9. void *shm = NULL;//分配的共享内存的原始首地址
  10. struct shared_use_st *shared;//指向shm
  11. int shmid;//共享内存标识符
  12. //创建共享内存
  13. shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666|IPC_CREAT);
  14. if(shmid == -1)
  15. {
  16. fprintf(stderr, "shmget failed\n");
  17. exit(EXIT_FAILURE);
  18. }
  19. //将共享内存连接到当前进程的地址空间
  20. shm = shmat(shmid, 0, 0);
  21. if(shm == (void*)-1)
  22. {
  23. fprintf(stderr, "shmat failed\n");
  24. exit(EXIT_FAILURE);
  25. }
  26. printf("\nMemory attached at %X\n", (int)shm);
  27. //设置共享内存
  28. shared = (struct shared_use_st*)shm;
  29. shared->written = 0;
  30. while(running)//读取共享内存中的数据
  31. {
  32. //没有进程向共享内存定数据有数据可读取
  33. if(shared->written != 0)
  34. {
  35. printf("You wrote: %s", shared->text);
  36. sleep(rand() % 3);
  37. //读取完数据，设置written使共享内存段可写
  38. shared->written = 0;
  39. //输入了end，退出循环（程序）
  40. if(strncmp(shared->text, "end", 3) == 0)
  41. running = 0;
  42. }
  43. else//有其他进程在写数据，不能读取数据
  44. sleep(1);
  45. }
  46. //把共享内存从当前进程中分离
  47. if(shmdt(shm) == -1)
  48. {
  49. fprintf(stderr, "shmdt failed\n");
  50. exit(EXIT_FAILURE);
  51. }
  52. //删除共享内存
  53. if(shmctl(shmid, IPC_RMID, 0) == -1)
  54. {
  55. fprintf(stderr, "shmctl(IPC_RMID) failed\n");
  56. exit(EXIT_FAILURE);
  57. }
  58. exit(EXIT_SUCCESS);
  59. }

源文件shmwrite.c的源代码如下：

[cpp] view plaincopyprint?

  1. #include <unistd.h>
  2. #include <stdlib.h>
  3. #include <stdio.h>
  4. #include <string.h>
  5. #include <sys/shm.h>
  6. #include "shmdata.h"
  7. int main()
  8. {
  9. int running = 1;
  10. void *shm = NULL;
  11. struct shared_use_st *shared = NULL;
  12. char buffer[BUFSIZ + 1];//用于保存输入的文本
  13. int shmid;
  14. //创建共享内存
  15. shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666|IPC_CREAT);
  16. if(shmid == -1)
  17. {
  18. fprintf(stderr, "shmget failed\n");
  19. exit(EXIT_FAILURE);
  20. }
  21. //将共享内存连接到当前进程的地址空间
  22. shm = shmat(shmid, (void*)0, 0);
  23. if(shm == (void*)-1)
  24. {
  25. fprintf(stderr, "shmat failed\n");
  26. exit(EXIT_FAILURE);
  27. }
  28. printf("Memory attached at %X\n", (int)shm);
  29. //设置共享内存
  30. shared = (struct shared_use_st*)shm;
  31. while(running)//向共享内存中写数据
  32. {
  33. //数据还没有被读取，则等待数据被读取,不能向共享内存中写入文本
  34. while(shared->written == 1)
  35. {
  36. sleep(1);
  37. printf("Waiting...\n");
  38. }
  39. //向共享内存中写入数据
  40. printf("Enter some text: ");
  41. fgets(buffer, BUFSIZ, stdin);
  42. strncpy(shared->text, buffer, TEXT_SZ);
  43. //写完数据，设置written使共享内存段可读
  44. shared->written = 1;
  45. //输入了end，退出循环（程序）
  46. if(strncmp(buffer, "end", 3) == 0)
  47. running = 0;
  48. }
  49. //把共享内存从当前进程中分离
  50. if(shmdt(shm) == -1)
  51. {
  52. fprintf(stderr, "shmdt failed\n");
  53. exit(EXIT_FAILURE);
  54. }
  55. sleep(2);
  56. exit(EXIT_SUCCESS);
  57. }

[cpp] view plaincopyprint?

  1. #include <unistd.h>
  2. #include <stdlib.h>
  3. #include <stdio.h>
  4. #include <string.h>
  5. #include <sys/shm.h>
  6. #include "shmdata.h"
  7. int main()
  8. {
  9. int running = 1;
  10. void *shm = NULL;
  11. struct shared_use_st *shared = NULL;
  12. char buffer[BUFSIZ + 1];//用于保存输入的文本
  13. int shmid;
  14. //创建共享内存
  15. shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666|IPC_CREAT);
  16. if(shmid == -1)
  17. {
  18. fprintf(stderr, "shmget failed\n");
  19. exit(EXIT_FAILURE);
  20. }
  21. //将共享内存连接到当前进程的地址空间
  22. shm = shmat(shmid, (void*)0, 0);
  23. if(shm == (void*)-1)
  24. {
  25. fprintf(stderr, "shmat failed\n");
  26. exit(EXIT_FAILURE);
  27. }
  28. printf("Memory attached at %X\n", (int)shm);
  29. //设置共享内存
  30. shared = (struct shared_use_st*)shm;
  31. while(running)//向共享内存中写数据
  32. {
  33. //数据还没有被读取，则等待数据被读取,不能向共享内存中写入文本
  34. while(shared->written == 1)
  35. {
  36. sleep(1);
  37. printf("Waiting...\n");
  38. }
  39. //向共享内存中写入数据
  40. printf("Enter some text: ");
  41. fgets(buffer, BUFSIZ, stdin);
  42. strncpy(shared->text, buffer, TEXT_SZ);
  43. //写完数据，设置written使共享内存段可读
  44. shared->written = 1;
  45. //输入了end，退出循环（程序）
  46. if(strncmp(buffer, "end", 3) == 0)
  47. running = 0;
  48. }
  49. //把共享内存从当前进程中分离
  50. if(shmdt(shm) == -1)
  51. {
  52. fprintf(stderr, "shmdt failed\n");
  53. exit(EXIT_FAILURE);
  54. }
  55. sleep(2);
  56. exit(EXIT_SUCCESS);
  57. }

再来看看运行的结果：

分析：

1、程序shmread创建共享内存，然后将它连接到自己的地址空间。在共享内存的开始处使用了一个结构struct_use_st。该结构中有个标志written，当共享内存中有其他进程向它写入数据时，共享内存中的written被设置为0，程序等待。当它不为0时，表示没有进程对共享内存写入数据，程序就从共享内存中读取数据并输出，然后重置设置共享内存中的written为0，即让其可被shmwrite进程写入数据。

2、程序shmwrite取得共享内存并连接到自己的地址空间中。检查共享内存中的written，是否为0，若不是，表示共享内存中的数据还没有被完，则等待其他进程读取完成，并提示用户等待。若共享内存的written为0，表示没有其他进程对共享内存进行读取，则提示用户输入文本，并再次设置共享内存中的written为1，表示写完成，其他进程可对共享内存进行读操作。

四、关于前面的例子的安全性讨论

这个程序是不安全的，当有多个程序同时向共享内存中读写数据时，问题就会出现。可能你会认为，可以改变一下written的使用方式，例如，只有当written为0时进程才可以向共享内存写入数据，而当一个进程只有在written不为0时才能对其进行读取，同时把written进行加1操作，读取完后进行减1操作。这就有点像文件锁中的读写锁的功能。咋看之下，它似乎能行得通。但是这都不是原子操作，所以这种做法是行不能的。试想当written为0时，如果有两个进程同时访问共享内存，它们就会发现written为0，于是两个进程都对其进行写操作，显然不行。当written为1时，有两个进程同时对共享内存进行读操作时也是如些，当这两个进程都读取完是，written就变成了-1.

要想让程序安全地执行，就要有一种进程同步的进制，保证在进入临界区的操作是原子操作。例如，可以使用前面所讲的信号量来进行进程的同步。因为信号量的操作都是原子性的。

五、使用共享内存的优缺点

1、优点：我们可以看到使用共享内存进行进程间的通信真的是非常方便，而且函数的接口也简单，数据的共享还使进程间的数据不用传送，而是直接访问内存，也加快了程序的效率。同时，它也不像匿名管道那样要求通信的进程有一定的父子关系。

2、缺点：共享内存没有提供同步的机制，这使得我们在使用共享内存进行进程间通信时，往往要借助其他的手段来进行进程间的同步工作。

时间： 2024-10-13 05:23:27

内存共享 一的相关文章

PHP共享内存段实现，使用shmop函数实现内存共享

所谓内存共享:就是多个应用程序公用一个内存段,在A程序中可以获取B程序存储在这个内存段的数据,也就是数据共享. shmop是PHP提供的函数集,在配置PHP的时候使用 -enable-shmop后,就可以使用这个函数集提供的函数, shmop对LINUX更加友好,而对于WINDOWS来说就不怎样了,不支持CGI和CLI模式~有点尴尬. 来说说他提供的一些函数: ftok函数:生成一个数字或叫做键或key.$key = ftok(fileName, mode); 一般情况下,这个fileName可

进程通信之内存共享篇

进程通信之_ 内存共享 概念:共享内存是被多个进程共享的一部分物理内存.共享内存是进程间的共享数最快的方法,一个进程向共享内存区域写入数据,共享这个内存区域的所有进程就可以写入数据,所有进程就可以立刻看到其中的内容. 实现步骤;1.创建共享内存,使用shmget函数2.映射共享内存,将这段创建的共享内存映射到具体的进程空间去,使用shmat函数 创建:int shmget (key_t key,int size,int shmflg)key 标识内存功效的键值0/ipc_private.成功返回

进程通信（二）&mdash;&mdash; 信号量&amp;内存共享

内存共享是进程间常用的通信方式,可以实现两个完全独立的进程通信. 在访问共享内存时,同时需要信号量进行访问控制. 使用ipcs -m命令可以查看系统共享内存,ipce -m + key 可以删除指定的共享内存. 对共享内存操作时,使用信号量对共享内存进行保护,类似与线程中的互斥锁.都可以看做是通过PV操作实现临界资源保护. P:对信号量标记位-1,获取信号量,如果标记位为0,表示有其他进程占用资源,无法获取. V:对信号量标记位+1,释放信号量,将资源释放,给其他进程使用. 信号量和内存共享需要

内存共享

共享内存共享内存是进程间通信中最简单的方式之一. 共享内存允许两个或更多进程访问同 一块内存,就如同 malloc() 函数向不同进程返回了指向同一个物理内存区域的指针.当一 个进程改变了这块地址中的内容的时候,其它进程都会察觉到这个更改. 因为所有进程共享同一块内存, 共享内存在各种进程间通信方式中具有最高的效率. 访 问共享内存区域和访问进程独有的内存区域一样快, 并不需要通过系统调用或者其它需要切 入内核的过程来完成.同时它也避免了对数据的各种不必要的复制

Delphi如何实现内存共享

原文来自: http://my.oschina.net/pc100/blog/380956 一.原理     通过使用“内存映射文件”,实现内存共享 二.主要操作     共享内存结构:   PShareMem = ^TShareMem;   TShareMem = Record     id:string[10];     name:string[20];     age:Integer;  end;     基本变量:     shareMemName:string; //共享内存名    

SAP开发经验之内存共享

内存传值 1用户内存共享 1.1   Sap内存: 1.1.1 共享范围:被所有的主session访问,内存数据可以在同一个session中不同程序之间,或者不同session之间共享. 1.1.2 作用范围:整个中端session时间内有效. 1.1.3 用法: SET PARAMETER ID ‘MAT’ FIELD P_MATNR. GET PARAMETER ID ‘MAT’ FIELD P_MATNR. 1.2   ABAP内存: 1.2.1  共享范围:在一个session不同程序之

内存共享和过量使用区别在哪里

[TechTarget中国原创] 共享(sharing)和过量使用(overcommitment)这两种内存管理技术都能够帮助提升系统整合性,但是在使用它们之前,管理员应该首先了 解二者之间的细微差别. 一台服务器能够支持的虚拟机数量通常取决于物理硬件所能够提供的可用计算资源.大多数资源,比如处理器周期.存储I/O和网络带宽等,都能够相对简单地进 行共享.这种做法的原理在于负载并不总是处于忙碌状态,因此共享——或者过度使用——资源能够实现更高等级的负载整合,因此为虚拟机分配的资源总量和可以 超过

C/C++ 进程间通信 内存共享

介绍内存共享前,说下之前的误区,觉得,可以用指针来在父子进程中传递数据,其实,在fork()后,父子进程的地址空间是相互独立的!所以在父子进程间传递指针是没有意义的. 这里就涉及到物理地址和逻辑地址(或称虚拟地址)的概念. 从逻辑地址到物理地址的映射称为地址重定向.分为: 静态重定向--在程序装入主存时已经完成了逻辑地址到物理地址和变换,在程序执行期间不会再发生改变. 动态重定向--程序执行期间完成,其实现依赖于硬件地址变换机构,如基址寄存器. 逻辑地址:CPU所生成的地址.CPU产生的逻辑地址

进程间通信（4）---最高效的进程间通信方式--内存共享

内存共享   内存共享,它也是一种进程间通信的方式,它是在虚拟地址空间中堆和栈地址空间的中间的共享映射区中开辟一块地址,然后由页表和mmu在物理内存中开辟一段空间,其他进程如果获取到了这个内存的ID便可以和另外的进程共享这段内存. 内存共享的特点:高效,它比其他的进程间通信的方式都要高效因为它直接看到的就是相当于他自己的一块内存.  要用到的函数: int shmget(key_t key, size_t size, int shmflg);//创建共享内存 void *shmat(int sh

python 中的Array,Value及内存共享

官网文档的例子 1 from multiprocessing import Process, Value, Array 2 3 def f(n, a): 4 n.value = 3.1415927 5 for i in range(len(a)): 6 a[i] = -a[i] 7 8 if __name__ == '__main__': 9 num = Value('d', 0.0) 10 arr = Array('i', range(10)) 11 12 p = Process(target