#include #include #include #include #include #include //定义信号量——1 sem_t p1_A, p2_B, p3_C; void* p1(void *arg){ int num_1 = 0; //初始化p1的信号量 for(int i=0;i<30;i++){ sem_wait(&p1_A); //应题目要求,“A”第一个输出 printf("A\n"); num_1++; //信号量依次加1, if(num_1 % 3 == 0){ //直到加到3的倍数 sem_post(&p2_B); //随后跳转到p2 }else{ sem_post(&p1_A); //不然一直在该线程执行 } } } void* p2(void *arg){ int num_2 = 0; //同理 for(int i=0;i<30;i++){ sem_wait(&p2_B); //p2开始等待,等p1指示完从此执行 printf("B\n"); num_2++; if(num_2 % 3 == 0){ sem_post(&p3_C); //随后跳转到p3 }else{ sem_post(&p2_B); } } } void* p3(void *arg){ int num_3 = 0; for(int i=0;i<30;i++){ sem_wait(&p3_C); //这里还是等待。。。。。 printf("C\n"); num_3++; if(num_3 % 3 == 0){ sem_post(&p1_A); //p3执行完继续跳转到p1再继续执行 }else{ sem_post(&p3_C); } } } int main() { pthread_t tid[3]; //初始化信号量——1 sem_init(&p1_A, 0, 1);//这里第3个参数设为“1”可以理解为第一个执行 sem_init(&p2_B, 0, 0); sem_init(&p3_C, 0, 0); pthread_create(&tid[0], NULL, p1, NULL); pthread_create(&tid[1], NULL, p2, NULL); pthread_create(&tid[2], NULL, p3, NULL); for(int i = 0; i < 3; i++) pthread_join(tid[i], NULL); printf("main is over\n"); }