共享内存读写实验代码,GO代码库,德仔网

代码语言

代码分类

【GO】共享内存读写实验

作者:汶纡 / 发布于2014/11/18/ 1124

共享内存用到的是系统提供的mmap函数，它可以将一个文件映射到虚拟内存的一个区域中，程序使用指针引用这个区域，对这个内存区域的操作会被回写到文件上，Go内置的syscall包中有mmap函数，但是它是经过封装的，返回的是[]byte，没办法做我需求的指针运算，所以我还是用cgo来调用原生的mmap。


	package main
	
	/*
	#cgo linux LDFLAGS: -lrt
	
	#include <fcntl.h>
	#include <unistd.h>
	#include <sys/mman.h>
	
	#define FILE_MODE (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)
	
	int my_shm_new(char *name) {
	 shm_unlink(name);
	 return shm_open(name, O_RDWR|O_CREAT|O_EXCL, FILE_MODE);
	}
	*/
	import "C"
	import (
	 "fmt"
	 "unsafe"
	)
	
	const SHM_NAME = "my_shm"
	const SHM_SIZE = 4 * 1000 * 1000 * 1000
	
	type MyData struct {
	 Col1 int
	 Col2 int
	 Col3 int
	}
	
	func main() {
	 fd, err := C.my_shm_new(C.CString(SHM_NAME))
	 if err != nil {
	 fmt.Println(err)
	 return
	 }
	
	 C.ftruncate(fd, SHM_SIZE)
	
	 ptr, err := C.mmap(nil, SHM_SIZE, C.PROT_READ|C.PROT_WRITE, C.MAP_SHARED, fd, 0)
	 if err != nil {
	 fmt.Println(err)
	 return
	 }
	 C.close(fd)
	
	 data := (*MyData)(unsafe.Pointer(ptr))
	
	 data.Col1 = 100
	 data.Col2 = 876
	 data.Col3 = 8021
	}
	
	
	//该代码片段来自于: http://www.sharejs.com/codes/go/4423

	下面是shm_reader.go的代码：
	package main
	
	/*
	#cgo linux LDFLAGS: -lrt
	
	#include <fcntl.h>
	#include <unistd.h>
	#include <sys/mman.h>
	
	#define FILE_MODE (S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH)
	
	int my_shm_open(char *name) {
	 return shm_open(name, O_RDWR);
	}
	*/
	import "C"
	import (
	 "fmt"
	 "unsafe"
	)
	
	const SHM_NAME = "my_shm"
	const SHM_SIZE = 4 * 1000 * 1000 * 1000
	
	type MyData struct {
	 Col1 int
	 Col2 int
	 Col3 int
	}
	
	func main() {
	 fd, err := C.my_shm_open(C.CString(SHM_NAME))
	 if err != nil {
	 fmt.Println(err)
	 return
	 }
	
	 ptr, err := C.mmap(nil, SHM_SIZE, C.PROT_READ|C.PROT_WRITE, C.MAP_SHARED, fd, 0)
	 if err != nil {
	 fmt.Println(err)
	 return
	 }
	 C.close(fd)
	
	 data := (*MyData)(unsafe.Pointer(ptr))
	
	 fmt.Println(data)
	}

试试其它关键字

　共享内存　

同语言下

可能有用的

汶纡贡献的其它代码(55)