我正在運行多次重復的模擬,我試圖看看是否可以并行化這些重復以縮短計算時間。目前我只是在 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 類型的數組中?
2 回答

慕的地6264312
TA貢獻1817條經驗 獲得超6個贊
您可以嘗試類似并行流的方法來執行并行性,如下行之一。
Stream.of(allResults).parallel().forEach(i -> processData(i));
Arrays.stream(allResults).parallel().forEach(i -> processData(i));

眼眸繁星
TA貢獻1873條經驗 獲得超9個贊
默認情況下,Java 是一種同步語言,要并行工作,您需要查看線程。我建議研究異步函數調用以及在 Java 中執行此操作的方法。
這是之前就此事提出的一個問題:How to asynchronously call a method in Java
通過異步調用,您可以在任意數量的線程上運行模擬,并在模擬運行完成時收集數據。
添加回答
舉報
0/150
提交
取消