/* Programma di esempio di due thread ....
 * Ora aggiungiamo un semaforo di mutua esclusione!!!!
 */

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <signal.h>
#include <sys/types.h>
#include "myutils.h"

/* Numero di cicli di scrittura/lettura nel buffer */
#define CICLI 10
/* Lunghezza del buffer */
#define LUN 50
/* Numero di cicli a vuoto di attesa */
#define DELAY 10000000

/* Memoria Condivisa fra i threads ...
 */
struct {
  pthread_mutex_t mutex;
  /* Stringa stampata a video */
  char scritta[LUN+1];
  /* Numero dei caratteri inseriti */
  int numLetture;
  int numScritture;
} shared = {PTHREAD_MUTEX_INITIALIZER};

/* Forward declaration */ 
void *scrittore1(void *);
void *scrittore2(void *);
void *lettore(void *);

int main(void)
{
  pthread_t scrit1, scrit2, let;
  int res, i;
	
  /* Inizializzo la stringa scritta */
  for(i=0; i<LUN; i++) {
    shared.scritta[i] = 'x';
  }
  /* Ogni stringa C deve terminare con 0!!!!! */
  shared.scritta[LUN] = 0;
  shared.numLetture = 0;
  shared.numScritture = 0;

  /* Setto il concurrency level a 3 */
  pthread_setconcurrency(3);

  /* A questo punto posso creare i thread .... */
  res = pthread_create(&scrit1, NULL, scrittore1, NULL);
  if (res != 0) sys_err("Errore nella creazione del primo thread\n");

  res = pthread_create(&scrit2, NULL, scrittore2, NULL);
  if (res != 0) {
    printf("Errore nella creazione del secondo thread\n");
    pthread_kill(scrit1, SIGKILL);
    return -1;
  }

  res = pthread_create(&let, NULL, lettore, NULL);
  if (res != 0) {
    printf("Errore nella creazione del secondo thread\n");
    pthread_kill(scrit1, SIGKILL);
    pthread_kill(scrit2, SIGKILL);
    return -1;
  }
  /* Fine della fase di creazione dei thread */
	
  /* A questo punto aspetto che i due thread finiscano ... */
  pthread_join(scrit1, NULL);
  pthread_join(scrit2, NULL);
  pthread_join(let, NULL);

  printf("E' finito l'esperimento ....\n");
  return (0);
}

void *scrittore1(void *in)
{
  int i, j, k;

  for (i=0; i<CICLI; i++) {
    while(1) {
      pthread_mutex_lock(&shared.mutex);
      if (shared.numLetture == shared.numScritture) {
	break;
      }
      pthread_mutex_unlock(&shared.mutex);
    }
    for(k=0; k<LUN; k++) {
      shared.scritta[k] = '+';
    }
    shared.numScritture++;
    pthread_mutex_unlock(&shared.mutex);
    for(j=0; j<DELAY; j++);	
  }
  return NULL;
}

void *scrittore2(void *in)
{
  int i, j, k;

  for (i=0; i<CICLI; i++) {
    while(1) {
      pthread_mutex_lock(&shared.mutex);
      if (shared.numLetture == shared.numScritture) {
	break;
      }
      pthread_mutex_unlock(&shared.mutex);
    }
    for(k=0; k<LUN; k++) {
      shared.scritta[k] = '-';
    }
    shared.numScritture++;
    pthread_mutex_unlock(&shared.mutex);
    for(j=0; j<DELAY; j++);	
  }
  return NULL;
}

void *lettore(void *in)
{
  int i;

  for (i=0; i<2*CICLI; i++) {
    while(1) {
      pthread_mutex_lock(&shared.mutex);
      if (shared.numLetture != shared.numScritture) {
	break;
      }
      pthread_mutex_unlock(&shared.mutex);
    }
    printf("Lettore -- scritta = %s\n", shared.scritta);
    shared.numLetture++;
    pthread_mutex_unlock(&shared.mutex);
  }
  return NULL;
}