[semafori] Check-in in aeroporto

Scopo del progetto è utilizzare i semafori POSIX per sincronizzare, in un aeroporto, N viaggiatori in coda per il check-in da effettuarsi in una delle CIN postazioni presenti.

I viaggiatori devono attendere nel caso tutte le postazioni siano occupate. Altrimenti si recano alla prima postazione libera, effettuano il check-in e vanno all’imbarco.

Gli schemi del main e del viaggiatore sono:

void * viaggiatore(void * i) {

	< entra in aeroporto >

	j = attendi_postazione();
	
	< usa la postazione di check in >
	
	libera_postazione(j);
		
	< va all'imbarco >				
}

main() {
	pthread_t th[N];

	// inizializza le strutture dati e i semafori
	inizializza();

	// crea i thread viaggiatori	
	crea_thread(th);
	
	// attende la terminazione dei thread viaggiatori
	attendi_thread(th); 
	
	// distrugge i semafori	
	chiudi();
}

Viene richiesto di implementare le quattro funzioni

1. void inizializza() che inizializza le strutture dati e i semafori;

2. void chiudi() che ‘distrugge’ i semafori;

3. int attendi_postazione() attende finché non c’è almeno uno sportello libero. Cerca il numero del primo sportello libero e lo restituisce. (Suggerimento: utilizzare un array di booleani per mantenere lo stato degli sportelli. Attenzione a porteggere le eventuali sezioni critiche!)

4. libera_postazione(int i) libera la postazione i-esima

Ecco il programma di test:

#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <sys/types.h>
#include <semaphore.h>
#include <stdint.h>

#define N 100	// Numero di viaggiatori
#define CIN 10	// Numero postazioni di check-int

/*********** variabili per il testing ************/
	int check_postazione[CIN];
	sem_t check_mutuo;
/*************************************************/

void * viaggiatore(void * i);

void die(char * s, int i) {
	printf("--> %s numero %i\n",s,i);
	exit(1);
	}


/*********** parte da consegnare ****************/

// dichiarazione di variabili globali

// funzioni del main
inizializza() {

}


chiudi() {

}

// funzioni del viaggiatore
int attendi_postazione() {

}

int libera_postazione(int j) {

}
/*********fine parte da consegnare **************/


void * viaggiatore(void * i) {
	int j;
	intptr_t id = (intptr_t)i;

	printf("[Viaggiatore %d] Entro in aeroporto\n", (int) id);

	j = attendi_postazione();
	
	/************** testing ***************/
		sem_wait(&check_mutuo);
		if (check_postazione[j]==1) 
			die("postazione gia' occupata",j);
		check_postazione[j]=1;
		sem_post(&check_mutuo);
	/**************************************/
	
	printf("[Viaggiatore %d] Sto usando lo sportello %d \n", (int) id, j);
	
	/*************** testing **************/
		sleep(1);
		check_postazione[j]=-1;
	/**************************************/

	libera_postazione(j);
		
	
	printf("[Viaggiatore %d] Vado al gate! \n", (int) id);
					
}

crea_thread(pthread_t *th) {
	intptr_t i;
	int ret;

	for (i=0;i<N;i++)
		if(ret=pthread_create(&th[i],NULL,viaggiatore,(void *) i)) 
			die("errore create",ret);
}

attendi_thread(pthread_t *th) {
	intptr_t i;
	int ret;

	for (i=0;i<N;i++)
		if(ret=pthread_join(th[i], NULL))
			 die("errore join",ret);
}


main() {
	pthread_t th[N];
	int i;

	sem_init(&check_mutuo,0,1);
		
	for (i=0; i<CIN; i++)
		check_postazione[i] = 0;
		
	// inizializza le strutture dati e i semafori
	inizializza();

	// crea i thread viaggiatori	
	crea_thread(th);
	
	printf("Creati %i viaggiatori \n", N);

	// attende la terminazione dei thread viaggiatori
	attendi_thread(th); 
	
	// distrugge i semafori	
	chiudi();
	
	/********************* testing *******************/
		for (i=0; i<CIN; i++) {
			if (check_postazione[i] == 0)
				die("postazione mai utilizzata",i);
		}
	/*************************************************/
}