c中的生產者 - 消費者沒有使用信號量/條件變量

Question

我想爲單個生產者和單個消費者實現一個程序。在我的代碼下面，消費者不能消費第一件商品。我無法確定錯誤，並且這裏的項目是以同步的方式生成和使用的。我想實現它，以便生產者生成任意數量的項目，然後消費者將使用這些項目，但不是以同步方式。

void *consumer() 
{ 
    while (1) 
    { 
     pthread_mutex_lock(&m); 

     pthread_cond_signal(&pd); 

     pthread_cond_wait(&cn, &m); 

     printf("Consumed item is : %d\n", count); 

     pthread_mutex_unlock(&m); 
     if (count == SIZE) 
     { 
     printf("Consumer can not consume.. Buffer empty..\n"); 
     break;  
     } 
    } 
} 

void *producer() 
{ 
    while (1) 
    { 
     if (count == SIZE) 
     { 
     printf("Producer can not produce.. Buffer full !!\n"); 
     break; 
     } 
     pthread_mutex_lock(&m); 
     printf("Produced item is : %d\n", ++count); 
     pthread_cond_signal(&cn); 

     if (count != SIZE) 
     pthread_cond_wait(&pd, &m); 

     pthread_mutex_unlock(&m); 

    } 
} 

Answer 1

我改變了代碼來簡化它。這個簡單的方法不需要條件變量。在你的代碼中，你忘記了實際消耗，所以它不起作用。
我會用停止條件替換生產者和消費者無限循環 - 例如產生X項並停止，否則，此代碼的結果將是隨機的。生產者可以在消費者有機會運行之前填充緩衝區，或者消費者可以看到空的緩衝區並停止。

void *consumer() 
{ 
    int consumed; 
    while (1) 
    { 
     pthread_mutex_lock(&m); 
     consumed = count; 
     count = 0; // consume all 
     printf("Consumed item is : %d\n", consumed); 
     pthread_mutex_unlock(&m); 
     if (consumed == 0) 
     { 
      printf("Consumer can not consume.. Buffer empty..\n"); 
      break;  
     } 
    } 
} 

void *producer() 
{ 
    while (1) 
    { 
     pthread_mutex_lock(&m); 
     if (count == SIZE) 
     { 
      printf("Producer can not produce.. Buffer full !!\n"); 
      pthread_mutex_unlock(&m); 
      break; 
     } 
     else 
     { 
      printf("Produced item is : %d\n", ++count); 
     } 

     pthread_mutex_unlock(&m); 
    } 
}