用信号量进行ipc的问题

iterator

因为建立信号量的时候我想对信号量赋初值.
代码类似于

semid = semget(,,IPC_CREAT|0666);
semctl(semid,,SETVAL,semopts);

在两个进程中都有这样的代码.
这样有个问题,当第一个进程建立好semaphore并初始化后,第二个进程可能会在启动后重新初始化semaphore的值.
请问怎样能让第二个进程知道semaphore已经初始化完成,然后它就不用再去初始化semaphore?

iterator

就是如何判断已经有一个进程用同一个key调用过semget了?

westgarden

semid = semget(mykey, 2, PERMS | IPC_CREAT | IPC_EXCL);    if ((semid == -1) && (errno != EEXIST))         /* real error, so return */       return -1;

westgarden

USP (Unix Systems Programming: Communication, Concurrency, and Threads) 15.2节有详细说明和举例。

1. 
   
2. /* initsemset.c */
   
3. 
   
4. /* A function that creates and initializes a semaphore set
   
5.    containing a single semaphore.
   
6. */
   
7. 
   
8. #include <errno.h>
   
9. #include <signal.h>
   
10. #include <stdio.h>
    
11. #include <time.h>
    
12. #include <sys/sem.h>
    
13. #include <sys/stat.h>
    
14. 
    
15. #define PERMS (S_IRUSR | S_IWUSR)
    
16. #define TEN_MILLION 10000000L
    
17. int initelement(int semid, int semnum, int semvalue);
    
18. 
    
19. int initsemset(key_t mykey, int value, sig_atomic_t *readyp) {
    
20.    int semid;
    
21.    struct timespec sleeptime;
    
22. 
    
23.    sleeptime.tv_sec = 0;
    
24.    sleeptime.tv_nsec = TEN_MILLION;
    
25.    semid = semget(mykey, 2, PERMS | IPC_CREAT | IPC_EXCL);
    
26.    if ((semid == -1) && (errno != EEXIST))         /* real error, so return */
    
27.       return -1;
    
28.    if (semid >= 0) {          /* we created the semaphore, so initialize it */
    
29.       if (initelement(semid, 0, value) == -1)
    
30.          return -1;
    
31.       *readyp = 1;
    
32.       return semid;
    
33.    }
    
34.    if ((semid = semget(mykey, 2, PERMS)) == -1)           /* just access it */
    
35.       return -1;
    
36.    while (*readyp == 0)                            /* wait for initialization */
    
37.       nanosleep(&sleeptime, NULL);
    
38.    return semid;
    
39. }
    

复制代码

使用：

1. 
   
2. static sig_atomic_t ready = 0;
   
3. initsemset(key, value, &ready);
   

复制代码

1. /* initelement.c */
   
2. 
   
3. #include <sys/sem.h>
   
4. 
   
5. int initelement(int semid, int semnum, int semvalue) {
   
6.    union semun {
   
7.       int val;
   
8.       struct semid_ds *buf;
   
9.       unsigned short *array;
   
10.    } arg;
    
11.    arg.val = semvalue;
    
12.    return semctl(semid, semnum, SETVAL, arg);
    
13. }

复制代码

[ 本帖最后由 westgarden 于 2007-11-5 20:27 编辑 ]

iterator

明白了。还有个问题，为什么我CTRL C终止这两个进程后再重启，这个key对应的信号量没有被清除？

westgarden

man ipcs
man ipcrm

G00GLE

原帖由 iterator 于 2007-11-5 21:04 发表
明白了。还有个问题，为什么我CTRL C终止这两个进程后再重启，这个key对应的信号量没有被清除？

System V 的信号量是内核持续性的，系统重启才被清除，或用ipcs手动清除。

iterator

这个问题搞定了,多谢.又遇到一个问题.
因为我是让两个进程共享一段环型队列.那么对于其中一个进程有个初始的读位置,另一个进程有个初始的写位置.(都是0).
如果这两个进程都不退出,那都没有问题.
但一旦有个进程退出(比如说写进程退出),而这时读进程的当前读位置不一定是0.
当写进程再次启动时它仍只会从0位置开始写,因为它不知道读进程的当前读位置,这样就造成了数据的错误.

westgarden

正常退出前保存当前读／写位置。
如果是非正常退出就有点麻烦。