java - 如何将矩阵的不同行传递给 threadPool。 [ JAVA ]

Question

我试图获取一个包含 n 个线程的线程池来计算矩阵每一行的值并返回一个新值。到目前为止，我得到的代码的工作是创建线程并为需要完成的任务奠定基础，但我不确定如何为每个线程传递同一矩阵的不同行。

例如，如果它是一个 3x3 矩阵，我们将有 3 个线程。第一个线程 -> 获取矩阵的第一条水平线，计算并更改值，将其添加到新矩阵

第二个线程 -> 获取矩阵的第二条水平线...

第三个线程 -> ...

ExecutorService threadPool = Executors.newFixedThreadPool(n)
    for(int i = 0; i < n; i++) {
        threadPool.submit(new Runnable() {
            public void run() {
                  //take row of matrix
                  //compute new row
                  //add to result matrix                    }
                    });
                }

    threadPool.shutdown();
    threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);

Answer 1

利用在二维数组中 int[][] array = new int[N][M] 调用 array[n] 将返回第 n 行的事实，然后您可以将该行传递给每个线程:

int[][] array = { {1,2,3}, {4,5,6}, {7,8,9}, {10,11,12,13,14,15} };

ExecutorService threadPool = Executors.newFixedThreadPool(array.length);
for(int i = 0; i < array.length; i++) {
    final int finalI = i;
    threadPool.submit(() -> {
        int[] row = array[finalI];
        System.out.println(Thread.currentThread().getName() + ": " + Arrays.toString(row));
        for(int j = 0; j < row.length; j++) {
            row[j] *= 2;
        }
    });
}

threadPool.shutdown();
while(!threadPool.isTerminated()) {
    Thread.sleep(20);
}

for(int i = 0; i < array.length; i++) {
    int[] row = array[i];
    for(int j = 0; j < row.length; j++) {
        System.out.print(row[j] + ", ");
    }
    System.out.println();
}

将打印:

pool-1-thread-4: [10, 11, 12, 13, 14, 15]
pool-1-thread-1: [1, 2, 3]
pool-1-thread-2: [4, 5, 6]
pool-1-thread-3: [7, 8, 9]
2, 4, 6, 
8, 10, 12, 
14, 16, 18, 
20, 22, 24, 26, 28, 30,