C/Visual C - primos mediante espera activa con hebras

#include <pthread.h>

#include <stdio.h>

#define M 10

#define tr 0

#define co 1

int array[M];

int num;

int fin=0;

int haynum=0;

int turnoTR=0;

int turnoTR_C=0;

int fTR[2]={0,0};

int fTR_C[2]={0,0};

int esprimo(int p){

	int i,cnt=0;

	for(i=1;i<=p;i++){

		if(p%i==0){

			cnt++;

		}

	}

	if(cnt==2)

	return 1;

	else

	return 0;

}

void *primo(void *argg){

	 int i=0,cnt=0;

	 int id=*(int *)argg;

	 int otro=(id+1)%2;

	 while(!fin){

		 // peterson entre trabajadoras

		 fTR[id]=1;

		 turnoTR=otro;

		 while(fTR[otro] && turnoTR==otro);

		 //peterson entre la trabajadora y la coordinadora

		 fTR_C[tr]=1;

		 turnoTR_C=co;

		 while(fTR_C[co] && turnoTR_C==co);

		 // seccion critica

		 if(esprimo(num)){

			array[i]=num;

			i++;

			cnt++;

		 }

		 if(cnt==M){

		    fin=1;

		 }

		 haynum=0;

		 fTR_C[tr]=0;

		 fTR[id]=0;

	 }

	 pthread_exit(NULL);

}

void *gen(void *argg){

	int i=2;

	while(!fin)){

		fTR_C[co]=1;

		turnoTR_C=tr;

		while(fTR_C[tr] && turnoTR_C==tr);

		if(!haynum){

		num=i;

		i++;

		haynum=1;

	    }

        fTR_C[co]=0;

	}

	pthread_exit(NULL);

}

int main(){

	int i,id[2];

	pthread_t tra[2],coor;

	for(i=0;i<2;i++){

		id[i]=i;

	  pthread_create(&tra[i],NULL,primo,&id[i]);

    }

	pthread_create(&coor,NULL,gen,NULL);

	for(i=0;i<2;i++){

	  pthread_join(tra[i],NULL);

    }

	  pthread_join(coor,NULL);

	for(i=0;i<M;i++){

		printf(" %d ",array[i]);

	}

}

#include <stdlib.h>

#include <unistd.h>

#include <stdio.h>

#include <pthread.h>

#define TARGET_COUNT 10

int numbers[TARGET_COUNT] = {-1};

pthread_mutex_t numbers_lock = PTHREAD_MUTEX_INITIALIZER;

int pfd[2] = {-1, -1};

/* */

static void insert_number(int v) {

	if(v >= 0 && v < TARGET_COUNT) {

		pthread_mutex_lock(&numbers_lock);

		numbers[v] = v;

		printf(" Inserted value %d\n", v);

		pthread_mutex_unlock(&numbers_lock);

	}

}

/* */

static void* t_start(void *data) {

	int id = (int)data;

	int val;

	while(read(pfd[0], &val, sizeof(val)) > 0) {

		printf("Thr %d reads %d\n", id, val);

		insert_number(val);

	}

	pthread_exit(0);

}

/* */

int main(int argc, char *argv[]) {

	if(pipe(pfd) < 0) {

		perror("pipe");

		exit(1);

	}

	pthread_t thrs[2];

	pthread_attr_t attrs;

	pthread_attr_init(&attrs);

	for(int i = 0; i < 2; i++) {

		pthread_create(&thrs[i], &attrs, t_start, (void*)i);

	}

	for(int i = 0; i < TARGET_COUNT; i++) {

		write(pfd[1], &i, sizeof(i));

	}

	close(pfd[1]);

	pthread_join(thrs[0], NULL);

	pthread_join(thrs[1], NULL);

}

/* */

static void insert_number(int v) {

	if(v >= 0 && v < TARGET_COUNT) {

		while(pthread_mutex_trylock(&numbers_lock) != 0);

		numbers[v] = v;

		printf(" Inserted value %d\n", v);

		pthread_mutex_unlock(&numbers_lock);

	}

}

#include <stdlib.h>

#include <unistd.h>

#include <pthread.h>

#include <stdbool.h>

#include <stdio.h>

#define THR_COUNT 2

#define MAX_VALUES 20

struct PDATA {

	pthread_t thr;

	int id;

	int value;

	bool produced, requested;

} threads[THR_COUNT] = {0};

bool finish = false;

/* */

void* t_start(void *user) {

	struct PDATA *data = (struct PDATA*)user;

	while(!finish) {

		data->requested = true;

		while(!data->produced);

		printf("Thr %d gets %d\n", data->id, data->value);

		data->produced = false;

	}

	pthread_exit(0);

}

/* */

int main(int argc, char *argv[]) {

	int cur_val = 0;

	pthread_attr_t attrs;

	pthread_attr_init(&attrs);

	for(int i = 0; i < THR_COUNT; i++) {

		threads[i].id = i;

		threads[i].value = -1;

		threads[i].requested = false;

		threads[i].produced = false;

		pthread_create(&threads[i].thr, &attrs, t_start, &threads[i]);

	}

	while(!finish) {

		for(int i = 0; i < THR_COUNT; i++) {

			if(threads[i].requested && !threads[i].produced) {

				threads[i].produced = true;

				threads[i].value = cur_val++;

				threads[i].requested = false;

				if(cur_val == MAX_VALUES) {

					finish = true;

					break;

				}

			}

		}

	}

	for(int i = 0; i < THR_COUNT; i++) {

		pthread_join(threads[i].thr, NULL);

	}

}

#include <pthread.h>

#include <stdio.h>

#define M 10

#define tr 0

#define co 1

int array[M];

int num=-1;

int fin=0;

int cnt=0;

int turnoTR=0;

int turnoTR_C=0;

int fTR[2]={0,0};

int fTR_C[2]={0,0};

int esprimo(int p){

	int i,cont=0;

	for(i=1;i<=p;i++){

		if(p%i==0){

			cont++;

		}

	}

	if(cont==2)

	return 1;

	else

	return 0;

}

void *primo(void *argg){

	 int id=*(int *)argg;

	 int otro=(id+1)%2;

	 while(!fin){

		 // peterson entre trabajadoras

		 fTR[id]=1;

		 turnoTR=otro;

		 while(fTR[otro] && turnoTR==otro);

		 //peterson entre la trabajadora y la coordinadora

		 fTR_C[tr]=1;

		 turnoTR_C=co;

		 while(fTR_C[co] && turnoTR_C==co);

		 // seccion critica

		 if(num>0){

		   if( esprimo(num)){

			//printf("numero %d ",num);

			array[cnt]=num;

			cnt++;

		   }

		   num=-1;

		 }

		 fTR_C[tr]=0;

		 fTR[id]=0;

	 }

	 pthread_exit(NULL);

}

void *gen(void *argg){

	int j=2;

	while(!fin){

		fTR_C[co]=1;

		turnoTR_C=tr;

		while(fTR_C[tr] && turnoTR_C==tr);

		if(num==-1){

			num=j;

		    j++;

		}

	    if(cnt==M){

		fin=1;

		}

        fTR_C[co]=0;

	}

	pthread_exit(NULL);

}

int main(){

	int i,id[2];

	pthread_t tra[2],coor;

	for(i=0;i<2;i++){

		id[i]=i;

	  pthread_create(&tra[i],NULL,primo,&id[i]);

    }

	pthread_create(&coor,NULL,gen,NULL);

	for(i=0;i<2;i++){

	  pthread_join(tra[i],NULL);

    }

	  pthread_join(coor,NULL);

	for(i=0;i<M;i++){

		printf(" %d ",array[i]);

	}

}