#include <stdio.h> #include <unistd.h> #include <stdlib.h> #include <string.h> #include <pthread.h> #include <time.h> typedef struct node // 定義生產(chǎn)者消費者的東西 {int data;struct node* next; }Node; Node* phead = NULL; //定義頭結(jié)點 // 定義互斥鎖和條件變量 pthread_mutex_t mutex; pthread_cond_t cond; //生產(chǎn)者回調(diào) void* func_1() {while(1) // 一直在生產(chǎn){Node* pnew = (Node*)malloc(sizeof(Node));pthread_mutex_lock(&mutex); // 加鎖pnew->data = rand() % 1000;pnew->next = phead; // 頭插法phead = pnew; // 更新頭結(jié)點printf("生產(chǎn)的數(shù)值：%d\n", phead->data);pthread_mutex_unlock(&mutex); // 解鎖pthread_cond_signal(&cond); // 喚醒線程sleep(rand() % 3);}return NULL; } //消費者回調(diào) void* func_2() {while(1){pthread_mutex_lock(&mutex); // 加鎖if(phead == NULL){// 添加條件變量pthread_cond_wait(&cond, &mutex);} 79 韓笑 記于：2018.01 - 2018.03printf("消費數(shù)值：%d\n",phead->data);// 刪除頭結(jié)點 // 目的是造成沒產(chǎn)品的現(xiàn)象Node *ptemp = phead;phead = phead->next;free(ptemp);pthread_mutex_unlock(&mutex); // 解鎖}return NULL; } int main() {srand((unsigned)time(NULL)); // 生成隨機(jī)數(shù)// 初始化互斥鎖和條件變量pthread_mutex_init(&mutex, NULL);pthread_cond_init(&cond, NULL);// 設(shè)計：生產(chǎn)者和消費者都是子線程，主線程回收子線程資源，同時銷毀互斥鎖和條件變量pthread_t p1, p2;// 創(chuàng)建子線程pthread_create(&p1, NULL, func_1, NULL);pthread_create(&p2, NULL, func_2, NULL);// 回收子線程pthread_join(p1, NULL);pthread_join(p2, NULL);// 銷毀互斥鎖條件變量pthread_mutex_destroy(&mutex);pthread_cond_destroy(&cond);return 0; }

這里我們烤爐什么時候加鎖，什么時候加條件變量，什么時候喚醒線程呢？
（1）無論消費者還是生產(chǎn)者，在訪問或生產(chǎn)公共資源的時候，都要“之前加鎖，之后解鎖”。
（2）對于消費者，條件變量在“臨界區(qū)”內(nèi)，視情況而定。
（3）對于生產(chǎn)者，當(dāng)生產(chǎn)完畢，解鎖完畢后，需要喚醒線程。
效果：生產(chǎn)者先生產(chǎn)數(shù)，然后消費者讀取，當(dāng)消費者讀完后，睡 1~2 秒，生產(chǎn)者再生產(chǎn)，消費者再讀。

總結(jié)

以上是生活随笔為你收集整理的Linux学习之系统编程篇：使用条件变量实现“生产者和消费者模型”的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。