#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

#define N 51

pthread_mutex_t flasaLock;
pthread_cond_t condRegular;
pthread_cond_t condSpecial;

int brojFlasa = 1;

void *regularWork(void *t)
{
	long time = (long)t;
	int obrada;

	while (1)
	{
		pthread_mutex_lock(&flasaLock);
		while ((brojFlasa % 5 == 0) && (brojFlasa <= N))
			pthread_cond_wait(&condRegular, &flasaLock);
		if (brojFlasa > N)
		{
			pthread_cond_signal(&condSpecial);
			pthread_mutex_unlock(&flasaLock);
			break;
		}
		obrada = brojFlasa++;
		if (brojFlasa % 5 == 0)
			pthread_cond_signal(&condSpecial);
		pthread_mutex_unlock(&flasaLock);
		sleep(time + 1);
		printf("Nit %ld je obradila flasu %d\n", (long)t, obrada);
	}

	pthread_exit(NULL);
}

void *specialWork(void *t)
{

	while(1)
	{
		pthread_mutex_lock(&flasaLock);
		while ((brojFlasa % 5 != 0) && (brojFlasa <= N))
			pthread_cond_wait(&condSpecial, &flasaLock);
		if (brojFlasa > N)
		{
			pthread_cond_broadcast(&condRegular);
			pthread_mutex_unlock(&flasaLock);
			break;
		}
		sleep(1);
		printf("Kontrolna nit je obradila flasu %d\n", brojFlasa++);
		pthread_cond_broadcast(&condRegular);
		pthread_mutex_unlock(&flasaLock);
	}

	pthread_exit(NULL);
}


int main (int argc, char *argv[])
 {
   long i;
   pthread_t threads[3];
   pthread_attr_t attr;

   /* Initialize mutex and condition variable objects */
   pthread_mutex_init(&flasaLock, NULL);
   pthread_cond_init (&condRegular, NULL);
   pthread_cond_init (&condSpecial, NULL);

   /* For portability, explicitly create threads in a joinable state */
   pthread_attr_init(&attr);
   pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);

   for (i = 0; i < 2; i++)
   		pthread_create(&threads[i], &attr, regularWork, (void *)i);

   pthread_create(&threads[i], &attr, specialWork, NULL);

   /* Wait for all threads to complete */
   for (i=0; i < 3; i++)
     pthread_join(threads[i], NULL);


   printf ("Main(): Waited on %ld  threads. Done.\n", i);

   /* Clean up and exit */
   pthread_attr_destroy(&attr);
   pthread_mutex_destroy(&flasaLock);
   pthread_cond_destroy(&condSpecial);
   pthread_cond_destroy(&condRegular);
   pthread_exit(NULL);

 }