1

假设集群中安装了 octave 的并行包，任何人都可以提供一个示例 octave 代码以提交到集群吗？我在说什么，我只是像在 Matlab 并行计算工具箱中那样使用 parfor，还是使用类似下面的代码？

n = 100000000;
s = 0;
% Initialize MPI
MPI_Init;
% Create MPI communicator
comm= MPI_COMM_WORLD;
% Get size and rank
size = MPI_Comm_size(comm);
rank= MPI_Comm_rank(comm);
master = 0;
% Split the for loop into size partitions
m = n / size;
r = mod(n, m);
if ( rank == size-1 )
    se = (rank + 1)*m + r;
else
  se = (rank + 1)*m;
end
% Each process works on a partition of the loop independently
s1 = s;
for i=(rank * m)+1:se
    s1 = s1 + i;
end
% print the partial summation on each process
disp(['Partial summation: ', num2str(s1), ' on process ', num2str(rank)]);

此代码来自链接
http://faculty.cs.tamu.edu/wuxf/talks/IAMCS-ParallelProgramming-2013-3.pdf中的教程

用于带有 mpi 的 matlab。

非常感谢！

4

0 回答 0