TestAllReduce.java

package com.mathpar.NAUKMA.examples;

import java.util.Arrays;
import mpi.MPI;
import mpi.MPIException;

public class TestAllReduce {
  public static void main(String[] args) throws MPIException {
    // ініціалізація MPI
    MPI.Init(args);
    // визначення номера процесора
    int myrank = MPI.COMM_WORLD.getRank();
    // визначення числа процесорів в групі
    int np = MPI.COMM_WORLD.getSize();
    int n = 5;
    int[] a = new int[n];
    for (int i = 0; i < n; i++) {
      a[i] = myrank * 10 + i;
    }
    System.out.println("myrank = " + myrank + ": a = " + Arrays.toString(a));
    int[] q = new int[n];
    MPI.COMM_WORLD.allReduce(a, q, n, MPI.INT, MPI.PROD);
    for (int j = 0; j < np; j++) {
      if (myrank == j) {
        System.out.println("myrank = " + myrank + ": q = " + Arrays.toString(q));
      }
    }
    // &#1079;&#1072;&#1074;&#1077;&#1088;&#1096;&#1077;&#1085;&#1085;&#1103; &#1087;&#1072;&#1088;&#1072;&#1072;&#1083;&#1077;&#1083;&#1100;&#1085;&#1086;&#1111; &#1095;&#1072;&#1089;&#1090;&#1080;&#1085;&#1080;
    MPI.Finalize();
  }
}