如何并行化 for 循环，并将每次重复的结果保存在矩阵中？

Question

我正在运行多次重复的模拟，我试图看看是否可以并行化这些重复以缩短计算时间。

目前我只是在 for 循环中多次运行模拟，但理想情况下，这些可以同时运行，然后将每次重复的结果保存到数组中进行处理。

目前我的代码类似于

public static void getAllTheData(){

   int nReps = 10;

   double[][] allResults = new double[nReps][]

   //this for loop is what I want to parallellise 

   for(int r = 0; r < nReps; r++){

       //run the simulation to completion here

       simulation.doStuffToCompletion()

       allResults[r] = simulation.getValues()

   }

//average allResults here and do further analysis

}

我的问题是，如何同时并行运行所有这些重复，并将每次并行运行的结果保存在 allResults 类型的数组中？

Answer 1

您可以尝试类似并行流的方法来执行并行性，如下行之一。Stream.of(allResults).parallel().forEach(i -> processData(i));Arrays.stream(allResults).parallel().forEach(i -> processData(i));

Answer 2

默认情况下，Java 是一种同步语言，要并行工作，您需要查看线程。我建议研究异步函数调用以及在 Java 中执行此操作的方法。这是之前就此事提出的一个问题：How to asynchronously call a method in Java通过异步调用，您可以在任意数量的线程上运行模拟，并在模拟运行完成时收集数据。