/*
 * Tentativa de implementar o algoritmo de Dekker para N theads.
 */
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

#define N 5

volatile int s = 0; /* Variável compartilhada */
volatile int vez = 0; /* Indica de qual thread tem prioridade
                         entrar na região crítica */
volatile int interesse[N] = {0, 0, 0, 0, 0}; /* Indica quais threads estão
                                       interessadas em entrar na região crítica */

int existe_outra_interessada(int thr_id) {
  int i;
  for (i = 0; i < N; i++) 
    if (i != thr_id && interesse[i])
      return 1;
  return 0;
}

void* f_thread(void *v) {
  int thr_id = *(int*)v;
  int i;

  for (i = 0; i < 5; i++) {
    interesse[thr_id] = 1; /* Marca que esta thread está interessada */
    while (existe_outra_interessada(thr_id)) /* Enquanto outra thread puder estar na região crítica */  
      if (vez != thr_id) {  
	interesse[thr_id] = 0;
	while (vez != thr_id);  /* Aguarda ser a vez desta thread */ 
	interesse[thr_id] = 1;
      }
  
    s = thr_id;
    printf("Thread %d, s = %d.\n", thr_id, s); 
  
    vez = (thr_id+1) % N; /* Passa a vez para a outra thread */
    interesse[thr_id] = 0;  /* Marca que saiu da região crítica */
  }
  return NULL;
}

int main() {

  pthread_t thr[N];
  int id[N], i;

  for (i = 0; i < N; i++) {
    id[i] = i;
    pthread_create(&thr[i], NULL, f_thread, &id[i]);
  }

  for (i = 0; i < N; i++) 
    pthread_join(thr[i], NULL); 

  return 0;
}