Delete '实验二'

实验2.1

@@ -4,30 +4,30 @@
 #include <unistd.h>
 #include <sys/types.h>
 #include <semaphore.h>
-int n=10, in=0,out=0,buffer[10];
-sem_t empty,full;
+int n=10, in=0,out=0,buffer[10];//定义变量并创建数组。
+sem_t empty,full;//定义信号量
 
 void* producer(void *arg){
-    int tag= pthread_self()%100;
+    int tag= pthread_self()%100;//线程信号
     int nextPro;
-    srand(time(NULL)+tag);
+    srand(time(NULL)+tag);//随机数种子
     while(1){
         nextPro = rand()%97;
-        sem_wait(&empty);
+        sem_wait(&empty);//empty–1
         buffer[in] = nextPro;
         printf("production:%d %d\n",nextPro,buffer[in]);
         usleep(1000*1000/20);
         in = (in+1)%n;
-        sem_post(&full);
+        sem_post(&full);//full+1
         usleep(1000*1000/2);
     }
 }
 void* consumer(void *arg)  {
     int item;
     while(1){
-        sem_wait(&full);
+        sem_wait(&full)//full–1
         item = buffer[out];
-        sem_post(&empty);
+        sem_post(&empty);//empty+1
         printf("consume:%d\n",buffer[out]);
         out = (out+1)%n;
         usleep(1000*1000/10);
@@ -35,13 +35,12 @@ void* consumer(void *arg)  {
 }
 int main() {
     pthread_t tid[7];
-    //初始有10个缓冲区 
     sem_init( &empty, 0,10);
-    sem_init( &full, 0,0);
+    sem_init( &full, 0,0);//初始化信号量
     for(int i=0;i<6;i++)
-        pthread_create(&tid[i], NULL, producer, NULL);
-    pthread_create(&tid[6], NULL, consumer, NULL);
+        pthread_create(&tid[i], NULL, producer, NULL);//创建生产者
+    pthread_create(&tid[6], NULL, consumer, NULL);//创建消费者
     for(int i = 0; i<7; i++)
-        pthread_join(tid[i], NULL);
+        pthread_join(tid[i], NULL);//等待线程结束
     printf("main is over\n");
 }   

实验2.2

@@ -25,22 +25,24 @@ void* p2(void *arg){
 } 
 void* p3(void *arg){
 	for(int i=0;i<10;i++){
-        sem_wait(&p3_C);    //这里还是等待。。。。。
+        sem_wait(&p3_C);    //p3开始等待，等p2指示完从此执行
         usleep(1000*1000/2); //等待0.5秒
 	    printf("C\n");
         sem_post(&p1_A);     //p3执行完继续跳转到p1再继续执行
 	}
-}  
+} 
 
 int main()  
 {  
 	pthread_t tid[3];  
-	sem_init(&p1_A, 0, 1);//这里第3个参数设为“1”可以理解为第一个执行
+	sem_init(&p1_A, 0, 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);  
+	pthread_create(&tid[2], NULL, p3, NULL); 
+	 
 	for(int i = 0; i < 3; i++)  
 		pthread_join(tid[i], NULL);      
 	printf("main is over\n");

实验2.3

@@ -4,29 +4,62 @@
 #include <unistd.h>   
 #include <sys/types.h>   
 #include <semaphore.h>   
+
+//定义信号量——1
+sem_t p1_A, p2_B, p3_C;
+
 void* p1(void *arg){
-	for(int i=0;i<10;i++){
-	printf("A\n");
+    int num_1 = 0;            //初始化p1的信号量
+	for(int i=0;i<30;i++){
+        sem_wait(&p1_A);
+	    printf("A\n");
+        num_1++;              //信号量自加
+        if(num_1 % 3 == 0){
+            sem_post(&p2_B);     //激活p2
+        }else{
+            sem_post(&p1_A);     //不然一直在该线程执行
+        }
 	}
 } 
 void* p2(void *arg){
-	for(int i=0;i<10;i++){
-	printf("B\n");
-	}
+    int num_2 = 0;                //初始化p2的信号量
+	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){
-	for(int i=0;i<10;i++){
-	printf("C\n");
-	}
+    int num_3 = 0;              //初始化p3的信号量
+	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);     //激活p1，进入循环
+	    }else{
+            sem_post(&p3_C);      //
+        }
+    }
 } 
 
 int main()  
 {  
 	pthread_t tid[3];  
+
+    sem_init(&p1_A, 0, 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");
-}  
+}