final

.vscode/settings.json

@@ -5,6 +5,7 @@
         "NUCLEO.C": "cpp",
         "ESCALA.C": "cpp",
         "EXEMPLO_NUCLEO.C": "cpp",
-        "EXEMPLO1.C": "cpp"
+        "EXEMPLO1.C": "cpp",
+        "EXEMPLO2.C": "cpp"
     }
 }

EXEMPLO2.PRJ

@@ -0,0 +1,5 @@
+exemplo2.c (nucleo.h nucleo.obj)
+nucleo.obj
+
+(system.h system.obj)
+system.obj

NUCLEO.C

@@ -126,7 +126,6 @@ void far cria_processo (char nome_p[], void far (*end_proc)()) {
                 p_aux->prox = prim->prox;
         }
         prim->prox = p_aux;
-
 }
 
 

exemplo2.c

@@ -0,0 +1,94 @@
+#include<nucleo.h>
+#include<stdio.h>
+
+FILE *arq;
+
+int buffer[6], mensagem = 0, pont_prod = 0, pont_consum = 0, max = 6;
+
+semaforo mutex, cheio, vazio;
+
+void far deposita(int msg, int prod){
+	if((&vazio)->s < 0){
+		fprintf(arq, "Produtor %d nao conseguiu inserir mensagem %d.\n", prod, msg);
+		printf("Produtor %d nao conseguiu inserir mensagem %d.\n", prod, msg);
+	} else {
+		fprintf(arq, "Produtor %d conseguiu inserir mensagem %d.\n", prod, msg);
+		printf("Produtor %d conseguiu inserir mensagem %d.\n", prod, msg);
+		mensagem++;
+		buffer[pont_prod++] = msg;
+		if(pont_prod > max)
+			pont_prod = 0;
+	}
+}
+void far retira(int prod){
+	if((&cheio)->s > max){
+		fprintf(arq, "Produtor %d conseguiu retirar mensagem .\n", prod);
+		printf("Produtor %d conseguiu retirar mensagem .\n", prod);
+	} else {
+		fprintf(arq, "Produtor %d conseguiu retirar mensagem %d.\n", prod, buffer[pont_consum]);
+		printf("Produtor %d conseguiu retirar mensagem %d.\n", prod, buffer[pont_consum]);
+		pont_consum++;
+		if(pont_consum > max)
+			pont_consum = 0;
+	}
+}
+void far produtor1(){
+	int i = 0;
+	while(i < 10){
+		p(&vazio);
+		p(&mutex);
+		deposita(mensagem, 1);
+		v(&mutex);
+		v(&cheio);
+		i++;
+	}
+	termina_processo();
+}
+void far produtor2(){
+	int i = 0;
+	while(i < 10){
+		p(&vazio);
+		p(&mutex);
+		deposita(mensagem, 2);
+		v(&mutex);
+		v(&cheio);
+		i++;
+	}
+	termina_processo();
+}
+void far consumidor1(){
+	int i = 0;
+	while(i < 10){
+		p(&cheio);
+		p(&mutex);
+		retira(1);
+		v(&mutex);
+		v(&vazio);
+		i++;
+	}
+	termina_processo();
+}
+void far consumidor2(){
+	int i = 0;
+	while(i < 10){
+		p(&cheio);
+		p(&mutex);
+		retira(2);
+		v(&mutex);
+		v(&vazio);
+		i++;
+	}
+	termina_processo();
+}
+main(){
+	arq = fopen("RESUL.txt","w");
+	cria_processo("p1", produtor1);
+	cria_processo("p2", produtor2);
+	cria_processo("c1", consumidor1);
+	cria_processo("c2", consumidor2);
+	inicia_semaforo(&cheio, 0);
+	inicia_semaforo(&vazio, max);
+	inicia_semaforo(&mutex, 1);
+	dispara_sistema();
+	fclose(arq);
+}