Chinaunix首页 | 论坛 | 博客
  • 博客访问: 7675740
  • 博文数量: 961
  • 博客积分: 15795
  • 博客等级: 上将
  • 技术积分: 16612
  • 用 户 组: 普通用户
  • 注册时间: 2010-08-07 14:23
文章分类

全部博文(961)

文章存档

2016年(1)

2015年(61)

2014年(41)

2013年(51)

2012年(235)

2011年(391)

2010年(181)

分类: C/C++

2010-12-13 11:23:46

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

pthread_mutex_t mutex;
pthread_cond_t cond;
int x;

void consumer(void)
{
while(1)
{
pthread_mutex_lock(&mutex);
int i;

while(x<3)
{
pthread_cond_wait(&cond,&mutex);
printf("start consumingn",x);
}

while(x>0)
{
x--;
printf("consuming x=%dn",x);
sleep(1);
}

pthread_mutex_unlock(&mutex);
}

pthread_exit(NULL);

}

void producer(void)
{
while(1)
{
pthread_mutex_lock(&mutex);
int i;

for(i=0;i<3-x;i++)
{
x++;
printf("produing x=%dn",x);
sleep(1);
}

if(x>=3)
{
pthread_cond_signal(&cond);
printf("producing completedn",x);
}

pthread_mutex_unlock(&mutex);
sleep(1);
}

pthread_exit(NULL);

}

int main(void)
{
pthread_t id1,id2;
int ret;

ret = pthread_mutex_init(&mutex,NULL);
if(ret!=0)
{
printf("pthread_mutex_init errorn");
exit(1);
}

ret = pthread_cond_init(&cond,NULL);
if(ret!=0)
{
printf("pthread_cond_init errorn");
exit(1);
}

ret = pthread_create(&id1,NULL,(void *)&producer,NULL);
if(ret!=0)
{
printf("pthread_create producer errorn");
exit(1);
}

ret = pthread_create(&id2,NULL,(void *)&consumer,NULL);
if(ret!=0)
{
printf("pthread_create consumer errorn");
exit(1);
}

pthread_join(id1,NULL);
pthread_join(id2,NULL);
return 0;
}


阅读(1813) | 评论(0) | 转发(3) |
给主人留下些什么吧!~~