线程同步之——条件变量(生产消费模型)

1、生产消费模型：咱们能够用条件变量来实现线程之间的同步，利用一个生产消费模型具体的实现同步。生产消费模型能够简单地称为3,2,1模型（即3种关系，2个对象，1个场所），同时还需注意如下3点：

一、生产者和消费者是同步互斥关系；

二、生产者和生产者是互斥关系；

三、消费者和消费者是互斥关系。

2、条件变量的理解：线程A须要等某个条件成才能继续往下执,如今这个条件不成,线程A就阻塞等待,线程B在执过程当中使这个条件成了,就唤醒线程A继续执。 在pthread库中经过条件变量(Condition Variable)来阻塞等待个条件,或者唤醒等待这个条件的线程。

相关函数有：

一、初始化：thread_cond_init函数初始化个Condition Variable,attr参数 为NULL则表缺省属性,pthread_cond_destroy函数销毁个Condition Variable。若是ConditionVariable是静态分配的,也能够宏定义PTHEAD_COND_INITIALIZER初始化,至关于pthread_cond_init函数初始化而且attr参数为NULL。

二、阻塞等待线程：个线程能够调 pthread_cond_wait在个Condition Variable上阻塞等待,这个函数作如下三步操做:
1）. 释放Mutex
2）. 阻塞等待
3）. 当被唤醒时,从新得到Mutex并返回

个线程能够调pthread_cond_signal唤醒在某个Condition Variable上等待的另个线程,也能够调pthread_cond_broadcast唤醒在这个Condition Variable上等待的全部线程。

代码实现：

建立生产者使用的是链表，整个过程是生产者从链表表尾生产数据，消费者从表头获取数据。而且是多生产者多消费者模型。

#include<stdio.h>
#include<stdlib.h>
#include<pthread.h>

typedef struct list
{
    int _data;
    struct list* _next;
}product_list;

product_list* head=NULL;

static pthread_mutex_t lock=PTHREAD_MUTEX_INITIALIZER;
static pthread_cond_t need_product=PTHREAD_COND_INITIALIZER;

product_list* createNode(int data)
{
    product_list* tmp=malloc(sizeof(product_list));
    tmp->_data=data;
    tmp->_next=NULL;
    return tmp;
}

void InitList(product_list** phead)
{
    *phead=createNode(0);
}

int Push(product_list* phead,int data)
{
    product_list* tail=phead;
    while(tail->_next!=NULL)
    {
        tail=tail->_next;
    }
    product_list* new=createNode(data);
    tail->_next=new;
    return new->_data;
}

int Pop(product_list* phead)
{
    product_list* tmp=phead->_next;
    phead->_next=phead->_next->_next;
    phead=phead->_next;
    tmp->_next=NULL;
    int val=tmp->_data;
    free(tmp);
    tmp=NULL;
        return val;
}

void* product(void* arg)
{
    int i=0;
    for(;i<10;i++)
    {
        sleep(3);
        pthread_mutex_lock(&lock);
        int val=Push(head,i);
        pthread_mutex_unlock(&lock);
        printf("product success!the data is:%d\n",val);
        pthread_cond_signal(&need_product);
    }
}

void* consumer(void* arg)
{
    while(1)
    {
        pthread_mutex_lock(&lock);
        while(head->_next==NULL)
        {
            pthread_cond_wait(&need_product,&lock);
        }
        int val=Pop(head);
        pthread_mutex_unlock(&lock);
        printf("consumer data is:%d\n",val);
    }
    return NULL;
}

int main()
{
    InitList(&head);
    pthread_t product1;
    pthread_t product2;
    pthread_t product3;
    
    pthread_t consumer1;
    pthread_t consumer2;
    pthread_t consumer3;

    pthread_create(&product1,NULL,product,NULL);
    pthread_create(&product2,NULL,product,NULL);
    pthread_create(&product3,NULL,product,NULL);

    pthread_create(&consumer1,NULL,consumer,NULL);
    pthread_create(&consumer2,NULL,consumer,NULL);
    pthread_create(&consumer3,NULL,consumer,NULL);

    pthread_join(product1,NULL);
    pthread_join(product2,NULL);
    pthread_join(product3,NULL);

    pthread_join(consumer1,NULL);
    pthread_join(consumer2,NULL);
    pthread_join(consumer3,NULL);

    return 0;
}

运行结果以下：