在matlab中使用parfor时出错

Question

我正在使用 parfor 来并行化 matlab 中的循环。代码如下

   parfor i = 1:15

   tmp{i,1} = theta(i) * Fw{i,1}' * var1 * Wi{i,1} * var2 * Fw{i,1} ;

   end 

FW, Wi 是包含矩阵的单元格。 var1, var2 是矩阵。 Theta 是一个向量。

当我执行此代码时，matlab 永远挂起，当我终止代码很长时间后，它显示以下错误。

警告：评估侦听器回调时出错。

主要是 58 使用 main 时出错（第 58 行）

原因： 使用 distcomp.remoteparfor/getCompleteIntervals 时出错

当我在没有 parfor 的情况下执行代码时，它工作正常。

完整代码如下

Fw = cell(15,1);

Wi = cell(15,1);

tmp = cell(15,1);

for i  = 1 : 15
  Fw{i,1} = randn(25344);
  Wi{i,1} = randn(12672);
  theta(i) = 10;
end

var1 = randn(25344,12672);
var2 = randn(12672,25344);
parfor i = 1:15

   tmp{i,1} = theta(i) * Fw{i,1}' * var1 * Wi{i,1} * var2 * Fw{i,1} ;

end 

Answer 1

PARFOR 被设计为既可以在单台机器上运行，也可以跨机器集群运行，并且工作进程不共享地址空间。因此，所有数据都必须复制给工人。在您的情况下，您正在制作大量数据以复制到 12 个工作人员中的每个人。我强烈怀疑您观察到的问题是由于数据传输的开销以及每个工作人员需要存储自己的var1 和var2 副本的事实。

我会尝试：从小得多的数组开始，然后检查一切是否正常。随着您逐渐增加大小，您可能会发现由于机器内存不足而开始出现问题。

将var1 和var2 存储在sharedmatrix 中可能会有所帮助。