/* Coded By Karthik Ananthapadmanaban
   10:44 PM 9/27/2007 */

#include <iostream>
#include <pthread.h>

using namespace std;

pthread_mutex_t mut;
pthread_cond_t cnd;

int global=0;
int flag=1;

void *thd_func(void *g)
{
	int *a=(int *)g;
	pthread_mutex_lock(&mut);
	if((flag==1)&&(*a==3))
	{
		cout<<endl<<"We are blocked! My id is "<<*a<<endl;
		pthread_cond_wait(&cnd,&mut);
	}
	global++;
	pthread_mutex_unlock(&mut);
	cout<<endl<<"I am a thread! My id is"<<*a<<endl;
}

int main()
{
	int i,j=0;
	pthread_t pth[5];
	int a[5]={1,2,3,4,5};

	cout<<"Example of a threaded program"<<endl;

	cout<<"Value of global is "<<global<<endl;

	pthread_mutex_init(&mut,NULL);
	pthread_cond_init(&cnd,NULL);

	for(i=0;i<5;i++)
	{
		pthread_create(&pth[i],NULL,thd_func,(void *)&a[i]);
	}

	sleep(10);

	pthread_mutex_lock(&mut);

	flag=0;
	pthread_cond_broadcast(&cnd);

	pthread_mutex_unlock(&mut);

	for(i=0;i<5;i++)
	{
		pthread_join(pth[i],NULL);
	}
	cout<<"Joined with the parent!"<<endl;

	cout<<"Value of global is "<<global<<endl;

	pthread_mutex_destroy(&mut);
	pthread_cond_destroy(&cnd);

	return 0;
}