Linux下生产者与消费者的线程实现

代码见《现代操作系统》 第3版。

为了显示效果，添加了printf()函数来显示运行效果

#include<stdio.h>
#include<pthread.h>
#define MAX 20
pthread_mutex_t the_mutex;
pthread_cond_t condc, condp;
int buffer = 0;

void *producer(void *ptr)
{
    int i;
    for(i = 1; i <= MAX; i++)
    {
        pthread_mutex_lock(&the_mutex);
        while(buffer != 0) pthread_cond_wait(&condp, &the_mutex);
        buffer = i;
        printf("%d ", buffer);
        pthread_cond_signal(&condc);
        pthread_mutex_unlock(&the_mutex);
    }
    pthread_exit(0);
}

void *consumer(void *ptr)
{
    int i;
    for(i = 1; i < MAX; i++)
    {
        pthread_mutex_lock(&the_mutex);
        while(buffer == 0)pthread_cond_wait(&condc, &the_mutex);
        buffer = 0;
        printf("%d ", buffer);
        pthread_cond_signal(&condp);
        pthread_mutex_unlock(&the_mutex);
    }
    pthread_exit(0);
}

int main(void)
{
    pthread_t pro, con;
    pthread_mutex_init(&the_mutex, 0);
    pthread_cond_init(&condc, 0);
    pthread_cond_init(&condp, 0);
    pthread_create(&con, 0, consumer, 0);
    pthread_create(&pro, 0, producer, 0);
    pthread_join(pro, 0);
    pthread_join(con, 0);
    pthread_cond_destroy(&condc);
    pthread_cond_destroy(&condp);
    pthread_mutex_destroy(&the_mutex);
}

编译命令

gcc -lpthread -o procro procro.c

运行后的效果如：