package com.ibm.user.examples;
import com.ibm.dthreads.DThreadExecutionContext;
import com.ibm.dthreads.DistributedExecutionManager;
import com.ibm.dthreads.SPMDDistributedExecutionManager;


public class ArrayPartTest {
	
	public static void main(String[] args) { 
				long start,end;
				start=System.currentTimeMillis();
		if(args.length<2)
		{
			System.out.println("Command Usage : ");
			System.out.println("java ArrayPartTest no_of_threads row_size");
			System.out.println("Please Refer README.htm");
			System.exit(0); 
		}

				int totalthreads=Integer.parseInt(args[0]);
				int noofrows=Integer.parseInt(args[1]);
				ArrayAddPartition arraydthread = new ArrayAddPartition(noofrows);
				DistributedExecutionManager dmanager = new SPMDDistributedExecutionManager(0);
				DThreadExecutionContext context = new DThreadExecutionContext(totalthreads);
				dmanager.execute(arraydthread,context);
				end=System.currentTimeMillis();
				System.out.println("THE TIME TAKEN IS "+(end-start));

	}
}