/************************************************************
编写一个程序,开启3个线程,这3个线程的ID分别为A、B、C,
每个线程将自己的ID在屏幕上打印10遍,
要求输出结果必须按ABC的顺序显示;如:ABCABC….依次递推。
************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <unistd.h>
#include <string.h>
#define CYC 3
int n=0;
pthread_mutex_t mylock=PTHREAD_MUTEX_INITIALIZER;//互斥量
pthread_cond_t qready=PTHREAD_COND_INITIALIZER;//条件变量
void *thread_func(void *arg)
{
int param=(intptr_t)arg;
char cha='A'+param;//隐式转换
int ret;
int i;
for(i=0;i<10;i++)
{
pthread_mutex_lock(&mylock);
//判断线程
while(param != n)
//1、刚运行时,n=0,param=0,条件不成立
{
ret=pthread_cond_wait(&qready,&mylock);//、等待broadcast
}
printf("%c",cha);//2、首先打印A
n=(n+1)%CYC;//3、n+1=1,对3取余等于1
pthread_mutex_unlock(&mylock);//4、解锁
pthread_cond_broadcast(&qready);//5、发送信号,唤醒其他线程
}
return NULL;
}
int main(int argc,char **argv)
{
long i;//循环次数
int ret;//返回值
pthread_t tid[CYC];//线程id
void *tret;
for(i=0;i<CYC;i++)//循环三次,创建三个线程
{
ret=pthread_create(&tid[i],NULL,thread_func,(void *)i);
if(ret !=0)
{
printf("线程创建失败!\n");
exit(-1);
}
}
for(i=0;i<CYC;i++)
{
ret=pthread_join(tid[i],&tret);
if(ret != 0)
{
printf("can not join with thread %ld:%s\n",i,strerror(ret));
exit(-1);
}
}
printf("\n");
return 0;
}