为什么我的生产者-消费者阻塞？

Question

我的代码在这里：http://pastebin.com/Fi3h0E0P

这是输出

0
Should we take order today (y or n): y
Enter order number: 100
More customers (y or n): n

Stop serving customers right now. Passing orders to cooker:
There are total of 1 order(s)
1
Roger, waiter. I am processing order #100

目标是服务员必须接受订单，然后将它们交给厨师。服务员必须等待厨师完成所有比萨饼，送出比萨饼，然后接受新订单。

我在之前的帖子here 中询问了 P-V 的工作原理。

我认为这与\n 消费无关？我尝试了wait() 的各种组合，但都不起作用。

我在哪里做错了？

主要部分在这里：

//Producer process
 if(pid > 0)
 {
    while(1)
    {
      printf("0");
      P(emptyShelf); // waiter as P finds no items on shelf;
      P(mutex); // has permission to use the shelf
      waiter_as_producer();
      V(mutex); // cooker now can use the shelf
      V(orderOnShelf); // cooker now can pickup orders

      wait();
      printf("2");
      P(pizzaOnShelf);
      P(mutex);
      waiter_as_consumer();
      V(mutex);
      V(emptyShelf);
      printf("3 ");
    }
 }
    if(pid == 0)
    {
     while(1)
    {
     printf("1");
     P(orderOnShelf); // make sure there is an order on shelf
     P(mutex); //permission to work
     cooker_as_consumer(); // take order and put pizza on shelf
     printf("return from cooker");
     V(mutex); //release permission
     printf("just released perm");
     V(pizzaOnShelf); // pizza is now on shelf
     printf("after");
     wait();
     printf("4");

    }
  }

所以我想这是执行路径： 进入waiter_as_producer，然后进入子进程（cooker），然后将控制权交还给父进程，完成waiter_as_consumer，切换回子进程。这两个等待切换回父级（就像我说我尝试了所有可能的 wait() 组合......）。

Answer 1

• 更改为#define PERMS (0)（它不是八进制文件模式掩码！）
• 删除所有wait();s
• 按 sizeof 缩放大小：if((shmid=shmget(1000,sizeof (int) * BUFSIZE,IPC_CREAT | PERMS)) < 0) 和其他（大小以 semsize/pagesize 为模放大，但无论如何使用正确的大小是一个好习惯）

在这里解决了问题。

整个想法是：您不需要等待； {producer,consumer} 之一将在某处的 P() 上被阻止：

来自 P()：

sb.sem_flg = 0; /* blocking call */
    if (semop(sid, &sb, 1) == -1)
        perror("semop");

此外：wait(&status) 至少需要一个参数。 （并且您可能需要其他等待函数之一，例如 wait3() 或 waitpid() ）

除此之外：

• 我会在共享对象的声明前加上“volatile”：volatile int *buff;
• main() 应该返回 int，没有值的返回是错误的（c99 之前）
• 大多数指针操作都很笨拙：order = buffer[i]; 与order = *(buffer+i); 相同，但更具可读性。