Tråde og datadeling

import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class MegaJob {
    private static final int NJOB = 1000000;
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        ExecutorService es = Executors.newFixedThreadPool(16);
        @SuppressWarnings("unchecked")
        Future<ParamAndResult>[] workres = new Future[NJOB];
        for(int i = 0; i < workres.length; i++) {
            workres[i] = es.submit(new WorkUnit(new ParamAndResult(i)));
        }
        int maxix = 0;
        int maxres = workres[0].get().getResult();
        for(int i = 1; i < workres.length; i++) {
            if(workres[i].get().getResult() > maxres) {
                maxix = i;
                maxres = workres[i].get().getResult();
            }
        }
        es.shutdown();
        System.out.printf("Max result is %d for param %d\n", workres[maxix].get().getResult(), workres[maxix].get().getParam());
    }
}

class WorkUnit implements Callable<ParamAndResult> {
    private ParamAndResult par;
    public WorkUnit(ParamAndResult par) {
        this.par = par;
    }
    public ParamAndResult call() throws Exception {
        int param = par.getParam();
        // Simulate a lot of work
        Random rng = new Random();
        int res = rng.nextInt(1000000 + param);
        //
        par.setResult(res);
        return par;
    }
}

class ParamAndResult {
    private int param;
    private int result;
    public ParamAndResult(int param) {
        this.param = param;
        this.result = 0;
    }
    public int getParam() {
        return param;
    }
    public int getResult() {
        return result;
    }
    public void setResult(int result) {
        this.result = result;
    }
}