python的进程间通信--共享内存

最近看进程间通信方式，刚好自己也在深入学习python，看到python支持共享内存。所以写下这篇笔记。

python中，有一个 multiprocessing.shared_memory.SharedMemory类，用来创建和访问共享内存。

以下是一个例子：

创建共享内存部分，我们使用C代码，此处参考 大大飞鱼老哥的代码： https://blog.csdn.net/ababab12345/article/details/102931841

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdio.h>
#include <sys/mman.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>

#define MMAP_DATA_SIZE 1024

int main(int argc,char * argv[])
{
    char * data;
    int fd = shm_open("/shm-file0001", O_CREAT|O_RDWR, 0777);
    
    if (fd < 0) {
        printf("shm_open failed!
");
        return -1;
    }
    
    ftruncate(fd, MMAP_DATA_SIZE);
    
    data = (char*)mmap(NULL, 1024, PROT_READ|PROT_WRITE, MAP_SHARED, fd, 0);
    if (!data) {
        printf("mmap failed
");
        close(fd);
    }
    
    
    sprintf(data,"This is a share memory! %d
",fd);
    
    munmap(data,MMAP_DATA_SIZE);
    
    
    close(fd);
    getchar();
    
    shm_unlink("/shm-file0001");
    
    return 0;
}

通过xcode编译运行这段C代码：

 python代码部分我们只写一个共享内存的读取：

from multiprocessing import shared_memory

if __name__ == '__main__':
    existing_shm = shared_memory.SharedMemory(name='shm-file0001')
    content = existing_shm.buf.tobytes()
    print(content)
    existing_shm.close()

最终python部分代码运行结果：

进一步，class multiprocessing.managers.SharedMemoryManager提供了一种比较方便的管理共享内存的方式。由SharedMemoryManager返回的sharedMemory,在sharedMemoryManager的shutdown()方法被调用后，都会自动清理掉，不用程序员再额外费心了。