标签:include 读取数据 less 阻塞 hmc 进程 效率 star end
本系列文章主要是学习记录Linux下进程间通信的方式。
常用的进程间通信方式:管道、FIFO、消息队列、信号量以及共享存储。
参考文档:《UNIX环境高级编程(第三版)》
参考视频:Linux进程通信 推荐看看,老师讲得很不错
Linux核心版本:2.6.32-431.el6.x86_64
注:本文档只是简单介绍IPC,更详细的内容请查看参考文档和相应视频。
本文介绍利用共享内存进行进程间的通信
1 struct shmid_ds { 2 struct ipc_perm shm_perm; /* Ownership and permissions */ 3 size_t shm_segsz; /* Size of segment (bytes) */ 4 time_t shm_atime; /* Last attach time */ 5 time_t shm_dtime; /* Last detach time */ 6 time_t shm_ctime; /* Last change time */ 7 pid_t shm_cpid; /* PID of creator */ 8 pid_t shm_lpid; /* PID of last shmat(2)/shmdt(2) */ 9 shmatt_t shm_nattch; /* No. of current attaches */ 10 ... 11 };
1 #include <sys/ipc.h> 2 #include <sys/shm.h> 3 int shmget(key_t key, size_t size, int shmflg); 4 说明:创建共享内存 5 返回:成功返回内存中共享内存的的标识ID;失败返回-1; 6 参数key:用户指定的共享内存键值; 7 参数size:共享内存大小; 8 参数shmflg:IPC_CREAT、IPC_EXCL等权限组合。
1 #include <sys/ipc.h> 2 #include <sys/shm.h> 3 int shmctl(int shmid, int cmd, struct shmid_ds *buf); 4 说明:共享内存控制 5 参数shmid:共享内存ID; 6 参数buf:共享内存属性指针; 7 参数cmd:IPC_STAT:获取共享内存段属性;IPC_SET:设置共享内存段属性;
IPC_RMID:删除共享内存段;SHM_LOCK:锁定共享内存段页面(页面映射到屋里内存不和外存进行换入换出操作);
SHM_UNLOCK:解除共享内存段页面的锁定。
1 #include <sys/types.h> 2 #include <sys/shm.h> 3 void *shmat(int shmid, const void *shmaddr, int shmflg); 4 说明:共享内存映射 5 返回:成功返回共享内存映射到进程虚拟内存空间中的地址;失败返回-1; 6 int shmdt(const void *shmaddr); 7 说明:共享内存解除映射; 8 返回:如果失败,则返回-1; 9 参数shmid:共享内存ID; 10 参数shmaddr:映射到进程虚拟内存空间的地址,建议设置为0,由操作系统分配; 11 参数shmflg:若shmaddr设置为0,则shmflg也设置为0。SHM_RND:随机;SHMLBA:地址为2的乘方;SHM_RDONLY:只读方式链接。 12 注:子进程不继承父进程创建的共享内存,大家是共享的,子进程继承父进程映射的地址。
(1)案例一:同步使用共享内存
父进程向共享内存中写入数据,子进程等待父进程写入数据并从中读取数据。对共享进程的同步使用管道实现。
管道的头文件:
1 #ifndef __TELL_H__ 2 #define __TELL_H__ 3 4 //管道初始化 5 extern void init(void); 6 7 //利用管道进行等待 8 extern void wait_pipe(void); 9 10 //利用管道进行通知 11 extern void notify_pipe(void); 12 13 //销毁管道 14 extern void destroy_pipe(void); 15 16 #endif
管道的C文件:
1 #include <stdio.h> 2 #include <stdlib.h> 3 #include <string.h> 4 #include "tell.h" 5 6 static int fd[2]; 7 8 //管道初始化 9 void init(void) 10 { 11 if (pipe(fd) < 0) { 12 perror("pipe error"); 13 } 14 } 15 16 //利用管道进行等待 17 void wait_pipe(void) 18 { 19 char c; 20 //管道读写默认是阻塞性的 21 if (read(fd[0], &c, 1) < 0) { 22 perror("wait pipe error"); 23 } 24 } 25 26 //利用管道进行通知 27 void notify_pipe(void) 28 { 29 char c = ‘c‘; 30 if (write(fd[1], &c, 1) != 1) { 31 perror("notify pipe error"); 32 } 33 } 34 35 //销毁管道 36 void destroy_pipe(void) 37 { 38 close(fd[0]); 39 close(fd[1]); 40 }
父子进程对共享进程的访问:
1 #include <sys/types.h> 2 #include <sys/shm.h> 3 #include <stdio.h> 4 #include <stdlib.h> 5 6 int main(void) 7 { 8 int shmid; 9 if ((shmid = shmget(IPC_PRIVATE, 1024, IPC_CREAT | IPC_EXCL | 0777)) < 0) { 10 perror("shmget error"); 11 exit(1); 12 } 13 pid_t pid; 14 init(); //初始化管道 15 if ((pid = fork()) < 0) { 16 perror("fork error"); 17 exit(1); 18 } else if (pid > 0) { //父进程 19 int *pi = (int *)shmat(shmid, 0, 0); 20 if (pi == (int *)-1) { 21 perror("shmat error"); 22 exit(1); 23 } 24 //往共享内存中写入数据(通过操作映射的地址即可) 25 *pi = 100; 26 *(pi + 1) = 20; 27 //操作完毕,解除共享内存的映射 28 shmdt(pi); 29 //通知子进程读取数据 30 notify_pipe(); 31 //销毁管道 32 destroy_pipe(); 33 //等待子进程结束 34 wait(0); 35 } else { //子进程 36 //子进程阻塞,等待父进程先往内存中写入数据 37 wait_pipe(); 38 //子进程从共享内存中读取数据 39 //子进程进行共享内存的映射 40 int *pi = (int *)shmat(shmid, 0, 0); 41 if (pi == (int *)-1) { 42 perror("shmat error"); 43 exit(1); 44 } 45 printf("start: %d, end: %d\n", *pi, *(pi+1)); 46 //读取完毕后解除映射 47 shmdt(pi); 48 //删除共享内存 49 shmctl(shmid, IPC_RMID, NULL); 50 //销毁管道 51 destroy_pipe(); 52 } 53 54 return 0; 55 }
测试步骤:
1、编译:[root@192 ipc]# gcc -o bin/cal_shm -Iinclude tell.c cal_shm.c
2、运行:
标签:include 读取数据 less 阻塞 hmc 进程 效率 star end
原文地址:https://www.cnblogs.com/mrlayfolk/p/13047317.html