Em resumo: Como posso dividir as operações de matrizes e fazer uma pool de threads com uma quantidade fixa de threads utilizando a quantidade de núcleos do usuário? Eu to quebrando a cabeça, procurando no SOF gringo, mas nada que clareie minha mente. Adicionei as bibliotecas java.util.concurrent.ExecutorService
e java.util.concurrent.Executors
. Isso foi o que fiz até agora. Classe principal:
public static void main(String[] args) throws IOException, InterruptedException
{
MatrixesManipulations matrixes = new MatrixesManipulations();
Scanner in = new Scanner(System.in);
System.out.print("De o valor para dimensão das duas matrizes quadradas: ");
int n = in.nextInt();
int[][] matrix1 = matrixes.matrixConstructor(n);
int[][] matrix2 = matrixes.matrixConstructor(n);
//Processadores do usuario para fazer a pool
int cores = Runtime.getRuntime().availableProcessors();
//Ainda não utilizado
ExecutorService pool = Executors.newFixedThreadPool(cores);
Thread matrix3 = new Thread(new MatrixMultiplicationThread(matrix1, matrix2, n));
matrix3.start();
matrix3.join();
////Outputs das matrizes
matrixes.printConsole(matrix1, n, 1);
matrixes.printConsole(matrix2, n, 2);
matrixes.matrixesToFile(matrix1, matrix2, matrix3, n);
}
Classe MatrixManipulations
:
public class MatrixesManipulations{
public int[][] matrixConstructor(int n)
{
int[][] matrix = new int[n][n];
Random rand = new Random();
for (int i = 0 ; i < n ; i++)
{
for (int j = 0 ; j < n ; j++)
{
Integer r = rand.nextInt()% 1000;
matrix[i][j] = Math.abs(r);
}
}
return matrix;
}
public void printConsole(int[][] matrix, int n, int x)
{
synchronized (this)
{
if(x == 1)
{
System.out.println("A primeira matriz gerada de tamanho " + n + " foi:");
for (int i = 0; i < n; i++)
{
System.out.print("[");
for (int j = 0; j < n; j++)
{
System.out.print(matrix[i][j] + " ");
}
System.out.println("]");
}
System.out.println();
}
if(x == 2)
{
System.out.println("A segunda matriz gerada de tamanho " + n + " foi:");
for (int i = 0; i < n; i++)
{
System.out.print("[");
for (int j = 0; j < n; j++)
{
System.out.print(matrix[i][j] + " ");
}
System.out.println("]");
}
System.out.print("\n");
}
if(x == 3)
{
System.out.println("A matriz resultante gerada da multiplicação das 2 matrizes quadradas foi:");
for (int i = 0; i < n; i++)
{
System.out.print("[");
for (int j = 0; j < n; j++)
{
System.out.print(matrix[i][j] + " ");
}
System.out.println("]");
}
System.out.print("\n");
}
}
}
public void matrixesToFile(int[][] matrix1, int[][] matrix2, int[][] matrix3, int n) throws IOException
{
synchronized(this)
{
FileWriter arqMatrix = new FileWriter("Matrizes.txt");
PrintWriter gravarArq = new PrintWriter(arqMatrix);
gravarArq.println("Primeira matriz gerada:");
for (int i = 0; i < n; i++)
{
gravarArq.print("[");
for (int j = 0; j < n; j++)
{
gravarArq.print(matrix1[i][j] + " ");
}
gravarArq.print("]\n");
}
gravarArq.println();
gravarArq.println("Segunda matriz gerada:");
for (int i = 0; i < n; i++)
{
gravarArq.print("[");
for (int j = 0; j < n; j++)
{
gravarArq.print(matrix2[i][j] + " ");
}
gravarArq.print("]\n");
}
gravarArq.println();
//int[][] matrix3 = matrixMultiplication(matrix1, matrix2, n);
gravarArq.println("Matriz resultante da multiplicação:");
for (int i = 0; i < n; i++)
{
gravarArq.print("[");
for (int j = 0; j < n; j++)
{
gravarArq.print(matrix3[i][j] + " ");
}
gravarArq.print("]\n");
}
gravarArq.println();
arqMatrix.close();
System.out.println("Foi gerado um arquivo 'Matrizes.txt' no mesmo local do projeto.\n");
}
}
public int[][] matrixMultiplication(int[][] matrix1, int[][] matrix2, int n)
{
synchronized(this)
{
int[][] matrix3 = new int[n][n];
for(int i = 0 ; i < n ; i++)
{
for(int j = 0 ; j < n ; j++)
{
for(int k = 0 ; k < n ; k++)
{
matrix3[i][j] += matrix1[i][k] * matrix2[k][j];
}
}
}
return matrix3;
}
}
}
E por final, a thread:
public class MatrixMultiplicationThread implements Runnable {
MatrixesManipulations matrixThread = new MatrixesManipulations();
int[][] matrix1;
int[][] matrix2;
int n;
public MatrixMultiplicationThread(int[][] matrix1, int[][] matrix2, int n)
{
this.matrix1 = matrix1;
this.matrix2 = matrix2;
this.n = n;
}
@Override
public void run()
{
int[][] matrix3 = matrixThread.matrixMultiplication(matrix1, matrix2, n);
matrixThread.printConsole(matrix3, n, 3);
}
}
A intenção é que a thread, a principio, faça a operação da matriz. Mas além disso, quero que ela se divida pra cada thread ir gerando a linha do usuário das saídas. Ou pelo menos (que acredito que seja mais fácil) que elas se dividam e façam operação de soma e multiplicação, não precisa nem ser necessariamente a pool. Outro problema que estou tendo (que possivelmente vou fazer também é gerar uma thread) é pra gerar o arquivo. Tendo em vista que a thread não dá um "retorno" e sim gera a matriz, gostaria de saber uma forma de passar no método public void matrixesToFile(int[][] matrix1, int[][] matrix2, int[][] matrix3, int n) throws IOException
na main
(que é quando eu utilizo esse método pra unificar todas as saídas e gravar num .txt
.