Deling af data til processer

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.Reader;
import java.util.ArrayList;
import java.util.List;
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 LoadMTRun {
    private static List<Data> load(Reader rdr) throws IOException {
        List<Data> res = new ArrayList<Data>();
        BufferedReader br = new BufferedReader(rdr, 1000000);
        String line;
        while((line = br.readLine()) != null) {
            String[] parts = line.split(",");
            int a = Integer.parseInt(parts[0]);
            int b = Integer.parseInt(parts[1]);
            int c = Integer.parseInt(parts[2]);
            res.add(new Data(a, b, c));
        }
        br.close();
        return res;
    }
    private static void analyze(List<Data> lst) throws InterruptedException, ExecutionException {
        //long t1 = System.currentTimeMillis();
        //ExecutorService es = Executors.newFixedThreadPool(1);
        ExecutorService es = Executors.newFixedThreadPool(3);
        Future<ParamAndResult> avga = es.submit(new WorkUnitSumA(new ParamAndResult(lst)));
        Future<ParamAndResult> avgb = es.submit(new WorkUnitSumB(new ParamAndResult(lst)));
        Future<ParamAndResult> avgc = es.submit(new WorkUnitSumC(new ParamAndResult(lst)));
        System.out.printf("Averages = %.1f %.1f %.1f\n", avga.get().getResult(), avgb.get().getResult(), avgc.get().getResult());
        //long t2 = System.currentTimeMillis();
        //System.out.printf("Time = %d ms\n",  t2 - t1);
       
    }
    private static void process(String fnm) throws IOException, InterruptedException, ExecutionException {
        List<Data> lst = load(new FileReader(fnm));
        analyze(lst);
    }
    private static void setup(String fnm, int n) throws IOException {
        Random rng = new Random();
        try(PrintWriter pw = new PrintWriter(new BufferedWriter(new FileWriter(fnm), 1000000)))
        {
            for(int i = 0; i < n; i++) {
                int a = rng.nextInt(1000);
                int b = rng.nextInt(1000000);
                int c = rng.nextInt(1000000000);
                pw.printf("%d,%d,%d\n", a, b, c);
            }
        }
    }
    private static final String FNM = "/work/test.txt";
    private static final int NNUM = 10000000;
    public static void main(String[] args) throws Exception {
        setup(FNM, NNUM);
        process(FNM);
    }
}

class WorkUnitSumA implements Callable<ParamAndResult> {
    private ParamAndResult par;
    public WorkUnitSumA(ParamAndResult par) {
        this.par = par;
    }
    public ParamAndResult call() throws Exception {
        List<Data> lst = par.getParam();
        double res = 0;
        for(Data o : lst) {
            res += o.getA();
        }
        res /= par.getParam().size();
        par.setResult(res);
        return par;
    }
}

class WorkUnitSumB implements Callable<ParamAndResult> {
    private ParamAndResult par;
    public WorkUnitSumB(ParamAndResult par) {
        this.par = par;
    }
    public ParamAndResult call() throws Exception {
        List<Data> lst = par.getParam();
        double res = 0;
        for(Data o : lst) {
            res += o.getB();
        }
        res /= par.getParam().size();
        par.setResult(res);
        return par;
    }
}

class WorkUnitSumC implements Callable<ParamAndResult> {
    private ParamAndResult par;
    public WorkUnitSumC(ParamAndResult par) {
        this.par = par;
    }
    public ParamAndResult call() throws Exception {
        List<Data> lst = par.getParam();
        double res = 0;
        for(Data o : lst) {
            res += o.getC();
        }
        res /= par.getParam().size();
        par.setResult(res);
        return par;
    }
}

class ParamAndResult {
    private List<Data> param;
    private double result;
    public ParamAndResult(List<Data> param) {
        this.param = param;
        this.result = 0;
    }
    public List<Data> getParam() {
        return param;
    }
    public double getResult() {
        return result;
    }
    public void setResult(double result) {
        this.result = result;
    }
}

class Data {
    private int a;
    private int b;
    private int c;
    public Data(int a, int b, int c) {
        this.a = a;
        this.b = b;
        this.c = c;
    }
    public int getA() {
        return a;
    }
    public void setA(int a) {
        this.a = a;
    }
    public int getB() {
        return b;
    }
    public void setB(int b) {
        this.b = b;
    }
    public int getC() {
        return c;
    }
    public void setC(int c) {
        this.c = c;
    }
}