0

我有两个线程。从队列中读取的一个。我不希望它在 while(1) 上运行以读取，所以我正在考虑在每次循环时给它一个条件变量：

while(1){
    while queue is not empty
        wait(cond)
        pop() 
}

代替：

while(1){
  while queue is not empty
      pop
}

和一个推送到队列的线程。如果我使用等待和信号方法，那么该线程需要通过每次推送弹出线程来通知（！）它推送问题是什么更好用？如果队列大部分不是空的，那么发送信号是没有价值的（或者不是？）因为弹出线程没有等待，我担心它会降低性能。但是，如果队列有一半时间是空的，那么像第二种 pop 方法那样循环它可能是一个忙碌的等待。

我希望这里的某个人会通过取消向没有等待它的线程发送信号仍然可以的事实来消除我的恐惧

谢谢

4

1 回答 1

0

首先只是为了确定，pthread_cond_signal不发送一个意义上signal的。signal(2)它只是标记条件变量并释放任何等待它的变量。因此，如果您pthread_cond_signal在消费进程调用良好之前调用，那将被忽略。

其次，pthread_cond_wait 是快还是慢？这得看情况。你可以用得不好，也可以用得很好。如果你用得不好，我相信它会表现得很糟糕。如果你只在真正需要的时候等待，我认为它会表现得很好。

所以，既然你需要持有一个互斥量来使用条件变量，那么你不妨检查一下此时是否有数据（并将这个互斥量用作同步点）。

队列数据结构的一个想法：

struct q {
    struct qe *h;
    struct qe *t;

    pthread_mutex_t m;
    pthread_cond_t c;
    int len;
};

消费者（假设您只有一个消费者，如果您有多个需要锁定头部检查）：

void *consumer(void*arg) {
    struct q *q = arg;

    while(1) {
        pthread_mutex_lock(&q->m);
        if(q->h == NULL) 
            pthread_cond_wait(&q->c, &q->m);
        /* We hold the mutex when we exit pthread_cond_wait */
        pthread_mutex_unlock(&q->m); /* we can make the check without the mutex */
        while(q->h != NULL) {
            pthread_mutex_lock(&q->m);  /* but we need it to modify */
            pop(); 
            pthread_mutex_unlock(&q->m);
            /* Process data */
        }
    }
}

制作人：

void *producer(void*arg) {
    int i;
    struct q *q = arg;
    while(1) {
        pthread_mutex_lock(&q->m);
        push(q, some_data);
        if(q->h == q->t) /* only one element */
            pthread_cond_signal(&q->c);
        pthread_mutex_unlock(&q->m);
    }    
    return NULL;
}
于 2012-12-04T18:19:52.560 回答