Chinaunix首页 | 论坛 | 博客

假面师爷

首页　| 　博文目录　| 　关于我

jiamianshiye

  • 博客访问： 154879
  • 博文数量： 24
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 225
  • 用 户 组： 普通用户
  • 注册时间： 2014-08-09 13:04
个人简介

人若是没有理想，那跟咸鱼有什么区别！

文章分类

全部博文（24）

文章存档

2018年（1）

2017年（2）

2016年（8）

2015年（11）

2014年（2）

我的朋友
最近访客
推荐博文
相关博文
linux SystemV的信号量操作semop

分类： LINUX

2017-08-24 14:22:11

参考链接如下：


在apue的介绍里，信号量（semaphore）是一个计数器，用于多进程、多线程对共享数据的访问。为了获取共享资源，进程需要执行下列步骤：
    1.测试控制该资源的信号量。
    2.若此信号量的值为正，则进程可以使用该资源。进程将信号量值减1，表示它使用了一个资源单位。
    3.若此信号量的值为0，则进程进入休眠状态，直至信号量的值大于0 。进程被唤醒后，返回到 1 操作。
上述操作中的信号量增、减操作都是原子操作。可以使用下述流程图来表述信号量的使用。


    在使用信号量集合时，需要先进行创建，之后需要对创建好的信号量集合进行控制设置。控制函数使用semctl：

点击(此处)折叠或打开

  1. int semctl(int semid, int semnum, int cmd, ... /*arg*/);
  2. semid : 创建信号量集合时的id号。
  3. semnum ： 需要控制的信号量集合的下标号。 （0----N）
  4. cmd    ： 参考下表。也可以参考apue。
  5. args    :    这个参数是一个联合体形式。 
  6.      
    union semun {
    int val;               /* used for SETVAL only */
    struct semid_ds *buf;  /* used for IPC_STAT and IPC_SET */
    ushort *array;         /* used for GETALL and SETALL */
};
    cmd Effect
    SETVAL Set the value of the specified semaphore to the value in the val member of the passed-in union semun.
    GETVAL Return the value of the given semaphore.
    SETALL Set the values of all the semaphores in the set to the values in the array pointed to by the array member of the passed-in union semun. The semnum parameter to semctl() isn't used.
    GETALL Gets the values of all the semaphores in the set and stores them in the array pointed to by the array member of the passed-in union semun. The semnum parameter to semctl() isn't used.
    IPC_RMID Remove the specified semaphore set from the system. The semnum parameter is ignored.
    IPC_STAT Load status information about the semaphore set into the struct semid_ds structure pointed to by the buf member of the union semun.

    semctl（）函数可以用来根据semnum参数来对指定的信号量进行初始化，通常用在 对 val 值 进行SETVAL操作，赋值为0. 此时使用semop（）函数进行信号量获取时，由于信号量值为0，所以会发生等待，直到此val的值被修改成正整数。

点击(此处)折叠或打开

  1. int semop(int semid, struct sembuf *sops, unsigned int nsops);
    进行上面流程图操作时使用 semop 函数。semop()函数执行信号量集合上的操作数组，并且是原子操作。semop函数的参数
    

点击(此处)折叠或打开

  1. /* Members might not be in this */

  3. struct sembuf {
  4.     ushort sem_num;   //集合中信号量对象的下标
  5.     short sem_op;    //操作数，正整数、负整数、0
  6.     short sem_flg;    //操作标识 IPC_NOWAIT、SEM_UNDO等。
  7. };

sem_op 由调用者赋值，通常在P操作时做-1操作，如果此时val的值为0，则会发生等待。做V操作时+1操作，val的值+1，表示释放了一个信号量资源。
sem_op What happens
Negative Allocate resources. Block the calling process until the value of the semaphore is greater than or equal to the absolute value of sem_op. (That is, wait until enough resources have been freed by other processes for this one to allocate.) Then add (effectively subtract, since it's negative) the value of sem_op to the semaphore's value.
Positive Release resources. The value of sem_op is added to the semaphore's value.
Zero This process will wait until the semaphore in question reaches 0.

下面是实例代码.
由于调用了线程创建，编译时需要链接pthread库： gcc sem_fok.c -lpthread -o sem_fok

点击(此处)折叠或打开

  1. /* sem_fork.c */
  2. #include<sys/types.h>
  3. #include<sys/ipc.h>
  4. #include<sys/sem.h>
  5. #include<unistd.h>
  6. #include<stdio.h>
  7. #include<stdlib.h>
  8. #include<pthread.h>

  10. #define DELAY_TIME 3 /*为了突出演示效果，等待几秒*/
  11. #define        THREAD_NUMS    (4)

  13. /*定义联合体*/
  14. union semun
  15. {
  16.     int val;
  17.     struct semid_ds *buf;
  18.     unsigned short *array;
  19. };

  21. /*函数声明*/
  22. int init_sem(int sem_id,int init_value);/*信号量初始化（赋值）函数*/
  23. int del_sem(int sem_id); /*从系统中删除信号量的函数*/
  24. int sem_p(int sem_id); /*P 操作函数*/
  25. int sem_v(int sem_id); /*V 操作函数*/


  28. int sem_p_idx(int sem_id, int idx);/*P 操作函数*/

  30. /*信号量初始化（赋值）函数*/
  31. int init_sem_idx(int sem_id,int idx, int init_value);
  32. /*V 操作函数*/
  33. int sem_v_idx(int sem_id, int idx);
  34. static void thrRunWait(int idx);
  35. static int g_sem_id = 0;


  38. int main(void)
  39. {
  40.     pthread_t pidRun[THREAD_NUMS];
  41.     int i = 0;
  42.     //int sem_id = 0;

  44.     g_sem_id = semget(ftok(".", 'a'), THREAD_NUMS, 0666|IPC_CREAT);
  45.     if(g_sem_id == -1){    //创建失败后，先清空，重新创建
  46.         printf("semget exist!\n");
  47.         g_sem_id = semget(ftok(".", 'a'), 0, 0666);
  48.         if(g_sem_id == -1){
  49.             printf("semget attach failed!\n");
  50.             return -1;
  51.         }
  52.         semctl(g_sem_id, 0, IPC_RMID);

  54.         g_sem_id = semget(ftok(".", 'a'), THREAD_NUMS, 0666|IPC_CREAT);
  55.         if(g_sem_id != -1){
  56.             printf("semget create ok!\n");
  57.             // return -1;
  58.         }
  59.     }
  60.     //    init_sem(sem_id, THREAD_NUMS);
  61.     for(i = 0; i < THREAD_NUMS; i++){
  62.         init_sem_idx(g_sem_id, i, 0);
  63.     }

  65.     for(i = 0; i < THREAD_NUMS; i++){
  66.         pthread_create(&pidRun[i], NULL, (void *)thrRunWait, (void *)i);    
  67.     }
  68.     sleep(5);
  69.     printf("main start V action--\n");
  70.     sem_v_idx(g_sem_id, 3);
  71.     sem_v_idx(g_sem_id, 2);
  72.     sem_v_idx(g_sem_id, 1);
  73.     sem_v_idx(g_sem_id, 0);
  74.     printf("main V action over\n");

  76.     sleep(3);
  77.     return 0;
  78. }/* main() end*/



  82. /*信号量初始化（赋值）函数*/
  83. int init_sem_idx(int sem_id,int idx, int init_value)
  84. {
  85.     union semun sem_union;
  86.     sem_union.val=init_value; /*init_value为初始值*/
  87.     if(semctl(sem_id,idx,SETVAL,sem_union)==-1)
  88.     {
  89.         perror("Initialize semaphore");
  90.         return -1;
  91.     }
  92.     return 0;
  93. }
  94. /*信号量P操作创建线程*/
  95. static void thrRunWait(int idx)
  96. {
  97.     printf("thrRunWait idx:%d waiting---!\n", idx);
  98.     sem_p_idx(g_sem_id, idx);
  99.     printf("thrRunWait idx:%d run over!\n", idx);
  100.     return ;
  101. }

  103. /*信号量初始化（赋值）函数*/
  104. int init_sem(int sem_id,int init_value)
  105. {
  106.     union semun sem_union;
  107.     sem_union.val=init_value; /*init_value为初始值*/
  108.     if(semctl(sem_id,0,SETVAL,0)==-1)
  109.     {
  110.         perror("Initialize semaphore");
  111.         return -1;
  112.     }
  113.     return 0;
  114. }

  116. /*从系统中删除信号量的函数*/
  117. int del_sem(int sem_id)
  118. {
  119.     union semun sem_union;
  120.     if(semctl(sem_id,0,IPC_RMID,sem_union)==-1)
  121.     {
  122.         perror("Delete semaphore");
  123.         return -1;
  124.     }
  125. }

  127. /*P 操作函数*/
  128. int sem_p_idx(int sem_id, int idx)
  129. {
  130.     struct sembuf sem_b;
  131.     sem_b.sem_num=idx; /*信号量编号，这里单个信号量的编号应该为0*/
  132.     sem_b.sem_op=-1; /*信号量操作，取值为-1表示P操作*/
  133.     sem_b.sem_flg=SEM_UNDO; /*在进程没释放信号量而退出时，系统自动释放该进程中未释放的信号量*/
  134.     if(semop(sem_id,&sem_b,1)==-1)    /*进行Ｐ操作*/
  135.     {
  136.         perror("P operation");
  137.         return -1;
  138.     }
  139.     return 0;
  140. }

  142. /*V 操作函数*/
  143. int sem_v_idx(int sem_id, int idx)
  144. {
  145.     struct sembuf sem_b;
  146.     sem_b.sem_num=idx; /*信号量编号，这里单个信号量的编号应该为0*/
  147.     sem_b.sem_op=1; /*信号量操作，取值为+1表示V操作*/
  148.     sem_b.sem_flg=SEM_UNDO; /*在进程没释放信号量而退出时，系统自动释放该进程中
  149.                  未释放的信号量*/
  150.     if(semop(sem_id,&sem_b,1)==-1)    /*进行V 操作*/
  151.     {
  152.         perror("V operation");
  153.         return -1;
  154.     }
  155.     return 0;
  156. }
 







阅读(2488) | 评论(0) | 转发(0) |
0

上一篇：如何挂载ubi文件系统

下一篇：配置vmware Ubuntu双网卡

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6