package be.ac.vub.ir.multithreading;

import flanagan.math.Fmath;

public class BarrierWithReduction {
	final int NBR_ELEMENTS, NBR_RUNS;
	int[] data;
	
	public BarrierWithReduction(int nbrElements, int nbrRuns){
		this.NBR_ELEMENTS = nbrElements;
		NBR_RUNS = nbrRuns;
		data = new int[nbrElements];
	}
	
	// ** Main **
	public static void main(String[] args) {
		new BarrierWithReduction(10, 10).runSeq();
		System.out.println("PARALLEL RUN:");
		new BarrierWithReduction(10, 10).runParallel();
	}
	
	// ** sequential run **
	void runSeq(){
		for(int r=0;r<NBR_RUNS;r++){
			for(int i=0;i<NBR_ELEMENTS;i++)
				data[i] = i*r;
			float avg = average(data); // after each run, the average is calculated
			System.out.println("Average at run "+r+": "+Fmath.truncate(avg, 3));
		}
	}
	
	// ** data manipulation **
	void print(){
		for(int i=0;i<data.length;i++)
			System.out.print(" "+data[i]);
		System.out.println();
	}
	float average(int[] data){
		long sum = 0;
		for(int i=0;i<data.length;i++)
			sum += data[i];
		return ((float)sum/data.length);
	}
	
	// ** parallel run **
	void runParallel(){
		// TODO
	}
}