2

我必须创建一个模拟并发矩阵加法和乘法的程序。我意识到如果我有 3 个矩阵：A、B 和 C，并且我想计算 A+B = C 或 A*B = C，那么我可以创建的最大线程数是（C 中的行）*（ C) 中的列，因为矩阵 C 中的每个最终位置都可以独立于其他位置计算。

我真正的问题是：如果我有一个MatrixMath具有方法的接口，multiply(), add(), print()我如何确保当add()ormultiply()方法终止时，所有更改都已写入 product 或 sum 矩阵？

例子：

class MatrixMathImplementation implements MatrixMath {

  public void multiply(int[][]A, int[][]B, int[][]C) {
    //multiply the two matrices, spawning m*n threads
    //haven't coded this yet
  }

  public void add(int[][]A, int[][]B, int[][]C) {
      //add the two matricies, spawning m*n threads
      //First: Check that A, B, and C are all the same size
      if (A.length == B.length && A.length == C.length &&
        A[0].length == B[0].length && A[0].length == C[0].length) {

        for (int row=0; row < A.length; row++) {
          for (int col=0; col < A[0].length; col++) {
              new MatrixSumThread(A,B,C,row,col);
          }
        }    
      } else {
        System.out.println("ERROR: Arrays are not the same size.");
      }
    }
  }

  public void print() {
    //print the given matrix
    //doesn't need to be concurrent, haven't coded this yet either.
  }
}

在代码中，MatrixSumThread创建一个可运行对象，它将计算特定行和列所需的总和，并将其放入矩阵 C 中的行和列中。我将为MatrixProductThread.

如果我有任何关于如何确保的想法：

someMatrixMathObject.add(A,B,C);
someMatrixMathObject.multiply(A,B,C);

我可以确保在add之前完成multiply，反之亦然？感谢您的任何帮助。

4

1 回答 1

2

一般来说，以下是使用原始线程的方式：

Thread t = new Thread(); // or subclass thereof
t.start();  // make sure to not start threads in the constructor; start explicitly
t.join();   // waits for the thread to finish

在你的情况下：

// create a list to hold all your threads, above the for loops
List<MatrixSumThread> threads = new ArrayList<MatrixSumThread>();
// for() { ...
// make sure MatrixSumThread doesn't call start() in its constructor
MatrixSumThread t = new MatrixSumThread(A,B,C,row,col);
threads.add(t);
t.start();

然后，在你完成 for 循环之后，加入所有线程：

for (MatrixSumThread t in threads) {
  t.join();
}
于 2013-10-23T21:29:08.597 回答