package codejam;

import fixjava.Pair;

public class Utils {

	public static long minLong(long firstVal, long... otherVals) {
		long minVal = firstVal;
		for (int i = 0; i < otherVals.length; i++)
			minVal = Math.min(firstVal, otherVals[i]);
		return minVal;
	}

	public static int minInt(int firstVal, int... otherVals) {
		int minVal = firstVal;
		for (int i = 0; i < otherVals.length; i++)
			minVal = Math.min(firstVal, otherVals[i]);
		return minVal;
	}

	public static float minFloat(float firstVal, float... otherVals) {
		float minVal = firstVal;
		for (int i = 0; i < otherVals.length; i++)
			minVal = Math.min(firstVal, otherVals[i]);
		return minVal;
	}

	/**
	 * ArgMin returned as a Pair<Integer, Integer>(index, value). Array must
	 * have at least one value.
	 */
	public static Pair<Integer, Integer> argMin(int[] arr) {
		int min = arr[0];
		int argMin = 0;
		for (int i = 1; i < arr.length; i++) {
			if (arr[i] < min) {
				min = arr[i];
				argMin = i;
			}
		}
		return new Pair<Integer, Integer>(argMin, min);
	}

	/**
	 * ArgMax returned as a Pair<Integer, Integer>(index, value). Array must
	 * have at least one value.
	 */
	public static Pair<Integer, Integer> argMax(int[] arr) {
		int max = arr[0];
		int argMax = 0;
		for (int i = 1; i < arr.length; i++) {
			if (arr[i] > max) {
				max = arr[i];
				argMax = i;
			}
		}
		return new Pair<Integer, Integer>(argMax, max);
	}

}

package fixjava;

import java.util.ArrayList;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

import fixjava.ParallelWorkQueue.CallableFactory;



public class ParallelWorkQueueTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		ArrayList<Integer> inputs = new ArrayList<Integer>();
		for (int i = 100; i < 120; i++)
			inputs.add(i);

		ParallelWorkQueue.CallableFactory<Integer, String> callableFactory = new CallableFactory<Integer, String>() {
			@Override
			public Callable<String> newInstance(final Integer input) {
				return new Callable<String>() {
					@Override
					public String call() throws Exception {
						Thread.sleep((int) (Math.random() * 4000));
						System.out.println("  Input: " + input);
						return "***" + (input + 1);
					}
				};
			}
		};

		try {
			for (Future<String> result : new ParallelWorkQueue<Integer, String>(4, inputs, callableFactory))
				System.out.println("Got : " + result.get());
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (ExecutionException e) {
			e.printStackTrace();
		}
	}
}
