这个例子计算A * B /四个工人用当地的调度器。注意,在这个简单的示例沟通超过实际的计算,所以它不是一个有用的基准速度。
任务的代码如下
函数= multtrans (x, y)
% Codistribute输入矩阵
一个= codistributed (x,“转换”);
B = codistributed (y,“转换”);
%乘当地部分
C = A * B;
%收集实验结果1
=收集(C, 1);
结束
在客户机上运行的代码
%在客户端声明两个矩阵。矩阵必须保持酒店产品约定:“m x n”矩阵乘以只有' n x p '
X = (1 2 3 4; 5 6);
Y = [7 8 9; 10 11 12];
%将部分传递给工人
jm = findresource (“调度”,“类型”,“本地”);
pjob = createParallelJob (jm);
啧啧= createTask (pjob @multtrans 1, {X, Y});
pjob.MaximumNumberOfWorkers = 4;
pjob.MinimumNumberOfWorkers = 4;
集(pjob,“FileDependencies”,{“multtrans.m”});
提交(pjob);
waitForState (pjob);
结果= getAllOutputArguments (pjob);
破坏(pjob);
访问的结果,在客户机上执行以下
结果{1}
