#include 
     
      #include 
      
       #include 
       
        #include 
        
         #include 
         
          using namespace std;pthread_mutex_t mutex;queue
          
            product;void* produce(void* ptr){ for(int i = 0; i < 10; ++i) { pthread_mutex_lock(&mutex); product.push(i); pthread_mutex_unlock(&mutex); }}void* consume(void* ptr){ for(int i = 0; i < 10;) { pthread_mutex_lock(&mutex); if(product.empty()) { pthread_mutex_unlock(&mutex); continue; } ++i; cout << "consume" << product.front() << endl; product.pop(); pthread_mutex_unlock(&mutex); }}int main(){ pthread_mutex_init(&mutex, NULL); pthread_t tid1, tid2; pthread_create(&tid1, NULL, consume, NULL); pthread_create(&tid2, NULL, produce, NULL); void* retVal; pthread_join(tid1, &retVal); pthread_join(tid2, &retVal); return 0;}
          
         
        
       
      
     

这种效率不高，因为消费者需要不停的去询问队列中是否不为空。