牛骨文教育服务平台(让学习变的简单)
博文笔记

linux的进程通信:信号量实例(C语言)

创建时间:2013-07-02 投稿人: 浏览次数:1523
linux的进程通信:信号量实例(C语言) 2012-01-06 06:25:49 标签:信号量 进程 通信 linux C 原创作品,允许转载,转载时请务必以超链接形式标明文章 原始出处 、作者信息和本声明。否则将追究法律责任。http://hector.blog.51cto.com/4229131/758930

 这篇发的很纠结,这不是我原创的代码,是同学写的,我只是想在这记录下来,以后没事可以看看,写转载嘛,又没有转载的来源,翻译就更扯了,勉强写个原创,其实不是我原创啦。 ( ̄▽ ̄)" 有兴趣可以看下,这是关于linux中的信号量的使用的一篇文章。我加了一些注释。

题目是:写一个程序,该程序创建两个进程,分别打印"this is the child process"和"father say hello to child",要求交替打印,输出成"this father is say the hello child to process child",每打印一个单词进程阻塞一段时间。将输出打印到当前目录下的tmp文件中。

答:

  1. #include <stdio.h> 
  2. #include <stdlib.h> 
  3. #include <sys/types.h> 
  4. #include <sys/ipc.h> 
  5. #include <sys/sem.h> 
  6. #include <sys/stat.h> 
  7. #include <fcntl.h> 
  8.  
  9. union semun 
  10. { 
  11.     int val; 
  12.     struct semid_ds *buf; 
  13.     unsigned short int *array; 
  14.     struct seminfo *__buf; 
  15. }; 
  16.  
  17. int main(void) 
  18. { 
  19.     char* buf_child[]={"this", "is", "the", "child", "process"}; 
  20.     char* buf_father[]={"father", "say", "hello", "to", "child"}; 
  21.     int i = 0, semid, fd; 
  22.     pid_t pid; 
  23.     struct sembuf sb; //信号量操作
  24.     union semun sem; 
  25.     semid = semget(1000, 2, 0666 | IPC_CREAT); //申请信号量组,包含2个信号量
  26.  
  27.     sem.val = 0; 
  28.     semctl(semid, 0, SETVAL, sem); //初始化0号信号量为0
  29.     sem.val = 1; 
  30.     semctl(semid, 1, SETVAL, sem); //初始化1号信号量为1
  31.  
  32.     fd=open("tmp",O_CREAT|O_TRUNC|O_WRONLY,0666); 
  33.  
  34.     pid = fork(); 
  35.     switch (pid) { 
  36.         case -1: 
  37.             perror("fork fail"); 
  38.             break; 
  39.         case 0: /* child consume */ 
  40.             srand((unsigned int)getpid()); 
  41.             while (i < 5) { 
  42.                 sb.sem_num = 1; //将1号信号量
  43.                 sb.sem_op = -1; //减1
  44.                 sb.sem_flg = sb.sem_flg & ~IPC_NOWAIT; 
  45.                 semop(semid, &sb, 1); 
  46.  
  47.                 write(fd,buf_child[i], strlen(buf_child[i])); 
  48.                 sleep(rand()); 
  49.                 write(fd,&" ", 1); 
  50.                 i++; 
  51.  
  52.                 sb.sem_num = 0; //将0号信号量
  53.                 sb.sem_op = 1;  //加1
  54.                 sb.sem_flg = sb.sem_flg & ~IPC_NOWAIT; 
  55.                 semop(semid, &sb, 1); //操作信号量
  56.             } 
  57.             break; 
  58.         default:/* parent production  */ 
  59.             srand((unsigned int)getpid()); 
  60.             while (i < 5) { 
  61.                 sb.sem_num = 0; //将0号信号量
  62.                 sb.sem_op = -1; //减1
  63.                 sb.sem_flg = sb.sem_flg & ~IPC_NOWAIT; 
  64.                 semop(semid, &sb, 1); //操作信号量
  65.  
  66.                 write(fd,buf_father[i], strlen(buf_father[i])); 
  67.                 sleep(rand()); 
  68.                 write(fd,&" ", 1); 
  69.                 i++; 
  70.  
  71.                 sb.sem_num = 1; 
  72.                 sb.sem_op = 1; 
  73.                 sb.sem_flg = sb.sem_flg & ~IPC_NOWAIT; 
  74.                 semop(semid, &sb, 1); 
  75.             } 
  76.             break; 
  77.     } 
  78.     return 0; 
  79. } 
声明:该文观点仅代表作者本人,牛骨文系教育信息发布平台,牛骨文仅提供信息存储空间服务。