一个消费者和一个两个生产者

sem_t ProducedItems;  // counts total # of unconsumed items in Q's A and B
sem_t Q_A;            // mutex on Q A
sem_t Q_B;            // mutex on Q B

void *consumer(void *arg)
{
  int bias = 0;  // NOTE: could use to not always favor reading from Q A over Q B

  while (1)
  {
    // wait for an item to be produced
    sem_wait(&ProducedItems);

    // find an item to consume
    do 
    {
      sem_wait(&Q_A);
      {
        if (Q A not empty) 
        {
          remove an item from Q A;
          bias = 1;
        }
      }
      sem_post(&Q_A);

      if (got item from A)
        break;

      sem_wait(&Q_B);
      {
        remove an item from Q B;
        bias = 0;
      }
      sem_post(&Q_B);
    } 
    while (0);

    // consume item
  }

  return NULL;
}

如果消费者还需要向生产者发出信号,例如确保他们的Q不会变得太大,那么你也可以为每个生产者提供信号量,表明他们的Q中还剩下多少空间.生产者会等待其信号量,消费者会在他们从各自的Q中删除项目时发布信息.

如果你想将它概括为N个生产Q,那么你可能想要保留一个由互斥锁保护的掩码,它指示哪个Q上有未消耗的项目.

一旦消费者获得了ProducedItems信号量,那么它将锁定掩码以查看哪些Q在其上具有未消耗的项目并对它们进行循环进展以决定下一个应该从哪个Q读取.然后它将从该Q锁定一个项目,如果该Q变空则更新位掩码,释放互斥锁并最终使用该项目.

生产者会将项目放入他们的Q中,如果它已经是空的,那么他们也会锁定全局位掩码并在其中设置其Q位,释放互斥锁然后发布ProducedItems信号量.

或者不是有点掩码,你可以有一个Q的大小数组,虽然这需要生产者每次产生时锁定互斥锁,等等.