package mpi;

import java.io.Serializable;
import java.util.List;
import java.util.Random;
import java.util.Vector;

public class IndependentDataParallelism<I, O> {
	
	/* */
	interface Task<In, Out> extends Serializable{
		Out execute(In input);
	}
	
	/* */
	public Vector<O> doSequential(List<I> data, Task<I, O> task){
		Vector<O> result = new Vector<O>(data.size());
		for(I element: data)
			result.add(task.execute(element));
		return result;
	}
	/* compares both lists and returns number of differences */
	public int compare(List<Object> l1, List<Object> l2){
		if (l1.size() != l2.size())
			throw new IllegalArgumentException("Both lists should have equal length");
		int diff=0;
		for(int i=0;i<l1.size();i++)
			if (l1.get(i).equals(l2.get(i)))
				diff++;
		return diff;
	}
	
	/*
	 * USER PROGRAM
	 */
	public static void main(String[] args){
		final int NBR = 30, MAX_VALUE=10000;
		
		Vector<Integer> v = new Vector<Integer>();
		Random r = new Random();
		for(int i=0;i<NBR;i++)
			v.add(r.nextInt(MAX_VALUE));
		
		IndependentDataParallelism<Integer, Boolean> ind = new IndependentDataParallelism<Integer, Boolean>();
		Vector<Boolean> result = ind.doSequential(v, new Task<Integer, Boolean>(){
			private static final long serialVersionUID = 1L;
			public Boolean execute(Integer value){
				for (int j=2 ; j<value ; j++){
					if ((value % j) == 0)
						return false;
				}
				return true;
			}
		});
		System.out.println("Result: ");
		for(int i=0;i<NBR;i++){
			System.out.print(v.get(i)+(result.get(i)? " prime": " no prime")+"; ");
			if (i%5 == 4)
				System.out.println();
		}
		System.out.println();
	}
}