#include char buffer[128];

int has_data=0;

pthread_mutex_t mutex;

pthread_cond_t cond;

pthread_cond_t cond2;

void read_buf(void)

{

do

{

pthread_mutex_lock(&mutex);//鎖定互斥鎖

if(has_data==0)

{

/*阻塞線程,等待另外一個線程發送信號，同時為公共數據區解鎖*/

pthread_cond_wait(&cond,&mutex);

}

else if(has_data==1)

{

printf("the data : %s\n",buffer);

has_data=0;

pthread_cond_signal(&cond2);

}

pthread_mutex_unlock(&mutex);//打開互斥鎖

}while(strcmp(buffer,"#")!=0);

pthread_exit(NULL);

}

void write_buf(void)

{

char input[128];

do

{

pthread_mutex_lock(&mutex);

if(has_data==0)

{

memset(input,'\0',128);

printf("input data:\t");

scanf("%s",input);

sprintf(buffer,"%s",input);

has_data=1;

pthread_cond_signal(&cond);//條件改變，喚醒阻塞的線程

}

else if(has_data==1)

{

pthread_cond_wait(&cond2,&mutex);

}

pthread_mutex_unlock(&mutex);

}while(strcmp(input,"#")!=0);

pthread_exit(NULL);

}

int main(int argc,char **argv)

{

pthread_t id,id2;

pthread_cond_init(&cond,NULL);

pthread_cond_init(&cond2,NULL);

pthread_mutex_init(&mutex,NULL);

pthread_create(&id,NULL,(void *)read_buf,NULL);//返回值為0，創建成功

pthread_create(&id2,NULL,(void *)write_buf,NULL);

pthread_join(id,NULL);

pthread_join(id2,NULL);

pthread_mutex_destroy(&mutex);

pthread_cond_destroy(&cond);

return 0;

}