POSIX IPC 命名信号量的实现

POSIX implementation of a named semaphore for IPC

我正在做一项家庭作业,涉及实施信号量以强制 child 进程之间的互斥。我的大部分代码都在工作,只是我没有正确使用信号量。我找到的文章没有多大帮助。有人可以向我解释 POSIX 信号量是如何工作的吗?

例如,如果我有一个 parent 进程使用 fork()execl() 生成 child 个进程:

sem=sem_open("/semaphore1",O_CREAT|O_EXCL,S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP,1);
for (i = 0; i < 3; i++) 
    {
        //three child process are spawned in the image of the parent
        child[i] = fork();

        //establish whether all children were created successfully
        switch (child[i]) 
        {
            //child process creation failed...
            case -1:
                rpterror ((char *)"fork failure", pname);
                exit(1);
            //given that the fork() was successful (the children were spawned successfully)...
            case 0:
                sprintf (pname, "shmc%d", i+1);
                execl("shmc1", pname, ascshmid, (char *)0);
                perror ("execl failed");
                exit (2);
        }
    }

和 children 想要访问和修改共享内存段(由 parent 创建)中的值:

sem=sem_open("/semaphore1", O_RDWR);
while ( !all_out) 
{       /* loop to sell all seats */

    /* puts the process to sleep for an amount of time, then decreases the amount of seats available. Before printing out the new count of seats, the process sleeps again. Finally, it prints the seat count until there are no more seats left.*/
    if (class_ptr->seats_left > 0) 
    {
        sem_wait(sem);
        sleep ( (unsigned)rand()%5 + 1);
        class_ptr->seats_left--;
        sleep ( (unsigned)rand()%5 + 1);
        cout << pname << " SOLD SEAT -- "  << class_ptr->seats_left << " left" <<endl;
        sem_post(sem);
    }

    else
    {
        all_out++;
        cout << pname << " sees no seats left" << endl;
    }
    sleep ( (unsigned)rand()%10 + 1);
}

其中 seats_left 是共享变量。

运行 此代码为我提供了如下所示的输出。共享变量的初始值为 15:

shmc1 SOLD SEAT -- 14 left
shmc2 SOLD SEAT -- 13 left
shmc3 SOLD SEAT -- 12 left
shmc1 SOLD SEAT -- 11 left
shmc2 SOLD SEAT -- 10 left
shmc3 SOLD SEAT -- 9 left
shmc1 SOLD SEAT -- 8 left
shmc2 SOLD SEAT -- 7 left
shmc3 SOLD SEAT -- 6 left
shmc2 SOLD SEAT -- 5 left
shmc1 SOLD SEAT -- 4 left
shmc3 SOLD SEAT -- 3 left
shmc2 SOLD SEAT -- 2 left
shmc1 SOLD SEAT -- 1 left
shmc1 sees no seats left
shmc3 SOLD SEAT -- 0 left
shmc3 sees no seats left
shmc2 SOLD SEAT -- -1 left
shmc2 sees no seats left
Parent removing shm

如您所见,最后是我的进程进入临界区的地方,同时另一个进程正在这样做。有人知道这是为什么吗?

尝试将 sem_wait() 移到 if 语句之外:

sem=sem_open("/semaphore1", O_RDWR);
while (!all_out) {
  sem_wait(sem);
  if (class_ptr->seats_left > 0)  {
    sleep((unsigned)rand()%5 + 1);
    class_ptr->seats_left--;
    sleep((unsigned)rand()%5 + 1);
    cout << pname << " SOLD SEAT -- "  << class_ptr->seats_left << " left" <<endl;
  }
  else {
    all_out++;
    cout << pname << " sees no seats left" << endl;
  }
  sem_post(sem);
  sleep((unsigned)rand()%10 + 1);
}

我认为您对不遵守关键段的进程没有意见(尽管信号量是一种荣誉系统,就像常规的停车灯一样……)。我认为问题只是进程 B 正在等待进程 A 持有的锁,当 A 售出最后一张票并释放锁时,B 抢了锁并卖掉了另一张票,因为它已经检查过票是否可用,并且在售出最后一张之前不再检查。

如果你 运行 的次数足够多,你可能会看到零票、一张票和两张票被超卖的情况。