import java.util.concurrent.CyclicBarrier;
import java.lang.Thread;
import java.util.concurrent.BrokenBarrierException;

public class Barrier extends Thread{
	
	int nr;
	int tot;
	CyclicBarrier b;

	public Barrier(int nr, int tot,CyclicBarrier b){
		this.nr=nr;
		this.tot=tot;
		this.b=b;
	}

	public void run(){
		try{
			for(int i=0;i<tot;i++){
				if(i==nr) System.out.println("I am thread nr "+nr);
				b.await();
			}
		}catch(InterruptedException e){
			e.printStackTrace();
		}catch(BrokenBarrierException e){
			e.printStackTrace();
		}
	}

	public static void main(String[] args){
		if(args.length<1){
			System.out.println("You need to supply nr of threads to run as an argument");
			System.exit(1);
		}
		int nrThreads = Integer.parseInt(args[0]);
		CyclicBarrier b = new CyclicBarrier(nrThreads);
		for(int i=0;i<nrThreads;i++) new Barrier(i,nrThreads,b).start();
	}

}