メインスレッドの最後の仕上げ方法

Question

Javaマルチスレッドプログラミングを調べます。私の仕事は、行列積を計算するマルチスレッドプログラムを実装することです。各スレッドは、結果として得られる行列の異なる行を担当します。タスクには、「メインプログラムでjoin()を使用すると、すべてのスレッドが終了して結果のマトリックスを印刷するのを待つ」というメッセージが表示されます。

MatrixProduct.java結果の行列の行が独立して計算され

package multythreading; 

import java.util.Arrays; 

public class MatrixProduct { 

    public static Matrix a; 
    public static Matrix b; 

    static { 
     a = new Matrix(new int[][]{{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}, 
            {4, 5, 64, 5, 6, 7, 8, 9, 10, 11}, 
            {7, 8, 94, 5, 6, 7, 8, 9, 10, 12}, 
            {7, 8, 94, 5, 6, 7, 8, 9, 10, 13}, 
            {4, 5, 64, 5, 6, 7, 8, 9, 10, 14}, 
     }); 
     b = new Matrix(new int[][]{{2, 1, 3}, 
            {4, 2, 1}, 
            {6, 4, 5}, 
            {6, 4, 5}, 
            {4, 2, 1}, 
            {2, 1, 3}, 
            {4, 2, 1}, 
            {6, 4, 5}, 
            {6, 4, 5}, 
            {4, 2, 1}}); 
    } 

    public static void main(String [] args) { 
     Thread[] threads = new Thread[a.getRowNum()]; 
     for (int i = 0; i < threads.length; i++) { 
      threads[i] = new Thread(new ResultMatrixLine(i), "Line number " + i + " computation thread"); 
      threads[i].start(); 
     } 

     for (Thread t: threads) { 
      if (t.isAlive()) { 
       try { 
        System.out.println(t.getName() + " : " + t.getState() + " still alive"); 
        t.join(); 
       } catch (InterruptedException e) { 
        e.printStackTrace(); 
       } 
      } 
     } 
     System.out.println("All computation threads terminated and the resulting matrix is ready"); 
    } 
} 

class ResultMatrixLine implements Runnable { 

    private int lineNumber; 

    public ResultMatrixLine(int lineNumber) { 
     this.lineNumber = lineNumber; 
    } 

    @Override 
    public void run() { 
     System.out.println("Line number = " + lineNumber + ": " + Arrays.toString(getResultLine())); 
    } 

    private int[] getResultLine() { 
     int[] result = new int[MatrixProduct.b.getColumnNum()]; 
     for (int i = 0; i < MatrixProduct.b.getColumnNum(); i++) 
      for (int j = 0; j < MatrixProduct.a.getColumnNum(); j++) 
       result[i] += MatrixProduct.a.getMatrixElement(lineNumber, j)*MatrixProduct.b.getMatrixElement(j, i); 
     return result; 
    } 
} 

class Matrix { 
    private final int columnNum; 
    private final int rowNum; 
    private final int[][] matrix; 

    public Matrix(int[][] matrix) { 
     this.columnNum = matrix[0].length; 
     this.rowNum = matrix.length; 
     this.matrix = matrix; 
    } 

    public int getColumnNum() { 
     return columnNum; 
    } 

    public int getRowNum() { 
     return rowNum; 
    } 

    public int getMatrixElement(int columnIndx, int rowIndx) { 
     return matrix[columnIndx][rowIndx]; 
    } 
} 

ので、私は気に唯一のことは、適切join()でmain()メソッドを使用している：

は、だからここに私のコードです。私は、メインスレッドの終わりに、他のすべてのスレッドを終了して、結果として得られるマトリックスが準備できることを意味します。最初の一見で私の決定はうまくいきますが、私はそれについてのコメントを見たいと思います。ここで

Answer 1

は、私はあなたのコードを修正するから作成したソリューションです：

は公共のスコープでそれからスレッドを削除するには行列積と機能にArrayListのを追加しました：

private static ArrayList<ResultMatrixLine> threads = new ArrayList<>(); 


public static void main(String [] args) { 
    for (int i = 0; i < a.getRowNum(); i++) { 
     // Create a new ResultMatrixLine thread 
     ResultMatrixLine thread = new ResultMatrixLine(i); 
     // Keep the thread handy for manipulation later 
     threads.add(thread); 
     // Create a new thread 
     thread.start(); 
    } 

    threads.stream().forEach((thread) -> { 
     if(thread.isAlive()) { 
      try { 
       thread.join(1000); 
      } catch(InterruptedException ex) { 
       ex.printStackTrace(System.out); 
      } 
     } 
    }); 

    System.out.println("All computation threads terminated and the resulting matrix is ready"); 

} 

出力

Line number = 1: [670, 423, 503] 
Line number = 3: [876, 556, 667] 
Line number = 0: [254, 151, 165] 
Line number = 4: [682, 429, 506] 
Line number = 2: [872, 554, 666] 
All computation threads terminated and the resulting matrix is ready 

スレッドのjoin（）メソッドの使用すべてのスレッドは、ArrayListをループして、スレッドが存続しているかどうかをチェックします。その場合は、join（）してください。