C 线程互斥代码错误？

Question

这是代码：

....
typedef struct {
  int buf[10];
  long head, tail;
  int full, empty;
  pthread_mutex_t *mut;
  pthread_cond_t *notFull, *notEmpty;
} queue;

int main(){
  queue *que;
  pthread_t sup, cut;
  que = queueInit();
  if(que == NULL){
    fprintf(stderr, "Queue Init failed");
    exit(1);
  }
  pthread_create(&sup, NULL, insertQueue, (void*) que);
  pthread_create(&cut, NULL, insertQueue, (void*) que);
  pthread_join(sup,NULL);
  pthread_join(cut,NULL);
  queueDelete(que);
  return 0;
}

void *insertQueue(void *q)
{
  queue *que;
  int i;
  que = (queue *)q;
  for(i=0; i<20;i++){
    // Get mutex lock on the queue
    pthread_mutex_lock(&mut); // Question (i) I guess this line is wrong
    while(que>full){
      printf("Its full");
      // pthread wait condition for queue not full
      pthread_cond_wait(&notFull, &mut); // Question (ii)
    }
    queueAdd(que,i);
    // Unlock the queue
    pthread_mutex_unlock(&mut); // Question (iii)
    // Send signal saying there is data to be read
    pthread_cond_signal(&notEmpty); // Question (iv)
    usleeep(100000);)
    return(NULL);
  }
}

queue *queueInit(void){
  queue *q;
  q = (queue *)malloc(sizeof(queue));
  if(q==NULL) return (NULL);
  q->empty = 1;
  q->full = 0;
  q->head = 0;
  q->tail = 0;
  q->mut=(pthread_mutex_t *)malloc(sizeof(pthread_mutex_t));
  // Set default condition
  pthread_mutex_init(&mut,NULL); // Question v
  // Condition for not null
  pthread_mutex_init(&notNull,NULL); // Question vi
  // Condition for not empty
  pthread_mutex_init(&notEmpty,NULL); // Question vi
  return (q);
}
....

我已将我的问题放入代码中，即问题 i - vi

我的感觉告诉我，我的论点是错误的，例如问题 vi：

pthread_cond_init(notEmpty,NULL);

它应该是其他东西，而不是“(¬Empty,Null) ”。

请帮忙。

Answer 1

notNull 在两个地方被写成 notFull。
notNull 和 notEmpty 是条件变量而不是互斥体，应该这样初始化。
没有为 notNull 和 notEmpty 分配内存。

最好将 queue 声明为：

typedef struct {
  int buf[10];
  long head, tail;
  int full, empty;
  pthread_mutex_t mut;
  pthread_cond_t notFull;
  pthread_cond_t notEmpty;
} queue;

然后保留所有 & 字符。这意味着您可以通过一次调用来分配全部内存。

最后，我认为您的意思是 while(que->full) 而不是 while(que>full)。

Answer 2

当你已经有一个指针时，你不应该使用 & 。把这个：改成

// Set default condition
  pthread_mutex_init(&mut,NULL); // Question v
  // Condition for not null
  pthread_mutex_init(¬Null,NULL); // Question vi
  // Condition for not empty
  pthread_mutex_init(¬Empty,NULL); // Question vi

这个：

// Set default condition
  pthread_mutex_init(mut,NULL); // Question v
  // Condition for not null
  pthread_mutex_init(notNull,NULL); // Question vi
  // Condition for not empty
  pthread_mutex_init(notEmpty,NULL); // Question vi

注意&我已经收起来了。 mut 已经是一个指针，并且创建 &mut 是尝试获取指向 pthread_mutex_t 的指针