Java MPI

import java.util.ArrayList;
 
import mpi.MPI;
 
public class Prog {
 
    public static void main(String[] args) {
 
        int N = 20;
        int[] sendBuf = { 0, 0, 1, 3, 4, 5, 5, 7, 7, 7, 8, 8, 9, 9, 9, 11, 16, 16, 23, 43 };        
        int[] recvBuf = new int[N];
        int[] result =  new int[N];         
        int[] recvcount, displs, tempBuf;
 
        MPI.Init(args);
 
        int rank = MPI.COMM_WORLD.Rank();
        int size = MPI.COMM_WORLD.Size();                       
        recvcount = new int[size];
        displs = new int[size];
 
        if (rank == 0) {
            System.out.println("Исходный массив: ");
            System.out.println();
            for (int i = 0; i < sendBuf.length; i++) {
                System.out.print(sendBuf[i] + " ");
            }
        }
 
        MPI.COMM_WORLD.Scatter(sendBuf, 0, sendBuf.length/size, MPI.INT, recvBuf, 0, recvBuf.length, MPI.INT, 0);
 
        ArrayList<Integer> uniqList = new ArrayList<Integer>();
        for (int i = 0; i < recvBuf.length; i++) {
            if (!uniqList.contains(recvBuf[i]))
                uniqList.add(recvBuf[i]);
        }
 
        tempBuf = new int[uniqList.size()];
        for (int i = 0; i < uniqList.size(); i++) {
            tempBuf[i] = uniqList.get(i);
        }
 
        if (rank == 0) {
            recvcount[rank] = uniqList.size();
            displs[rank] = 0;
        } else {
            recvcount[rank] = uniqList.size();
            displs[rank] = recvcount[rank - 1];
        }
 
        MPI.COMM_WORLD.Barrier();
        
        MPI.COMM_WORLD.Gatherv(tempBuf, 0, tempBuf.length, MPI.INT, result, 0,recvcount, displs, MPI.INT, 0);
 
        if (rank == 0) {
            for (int i = 0; i < result.length; i++) {
                System.out.print("Результат: " + result[i]);
            }
        }
 
        MPI.Finalize();
    }
}