Composite

此示例显示如何创建一个没有定义元素的 Composite 对象，然后使用客户端上的 for 循环分配值。

启动一个有四个工作单元的并行池，并为每个工作单元创建一个包含一个元素的 Composite 对象。

p = parpool("Processes",4);

Starting parallel pool (parpool) using the 'Processes' profile ...
Connected to parallel pool with 4 workers.

c = Composite

 
c =
 
   Worker 1: No data
   Worker 2: No data
   Worker 3: No data
   Worker 4: No data
 

在客户端上使用 for 循环来定义 Composite 对象元素的值。您分配给每个元素的值都存储在工作单元身上。显示 Composite 对象。

for w = 1:length(c)
    c{w} = rand;
end
c{:}

ans = 0.8147

ans = 0.9058

ans = 0.1270

ans = 0.9134

此示例显示如何指定工作单元的数量，从而指定 Composite 对象中的元素数量。

使用名为 my_Profile 的配置文件启动一个由 10 个工作单元组成的并行池。

parpool("my_Profile",10);

Starting parallel pool (parpool) using the 'my_Profile' profile ...
Connected to parallel pool with 10 workers.

从当前并行池中创建一个仅具有四个工作单元的 Composite 对象，并将值分配给 Composite 代码块中的 spmd 元素。显示 Composite 对象。

c = Composite(4);
spmd
    c = spmdIndex;
end
c{:}

ans = 1

ans = 2

ans = 3

ans = 4

此示例显示如何使用 spmd 代码块和分布式数组在客户端上创建 Composite 对象。

启动一个有四个工作单元的并行池，并将四个整数的数组分配给工作单元。每个工作单元都会得到一个整数。

p = parpool("Processes",4);
d = distributed([3 1 4 2]);

使用每个工作单元上的分布式数组的各个部分来设置 Composite 对象 c 的值。

spmd
c = getLocalPart(d);
end

显示并查看有关 c 的信息。

c{:}

ans = 3

ans = 1

ans = 4

ans = 2

whos c

  Name      Size            Bytes  Class        Attributes

  c         1x4               489  Composite              

使用远程集群配置文件 myMJSCluster 启动并行池。

myClusterPool = parpool(myMJSCluster,15);

Starting parallel pool (parpool) using the 'myMJSCluster' profile ...
Connected to parallel pool with 15 workers.

将 myClusterPool 分区，以准备运行 spmd 语句。使用 partition 函数创建一个新池 spmdPool，其中每个主机最多限制一个工作单元。此设置有助于在主机之间均匀分配任务。

[spmdPool,otherPool] = partition(myClusterPool,"MaxNumWorkersPerHost",1);

创建一个 Composite 对象，其中 spmdPool 中的每个工作单元都有一个元素。

j = Composite(spmdPool);

在客户端使用 for 循环来定义 Composite 对象的元素值。

m = 1000000;
for w = 1:length(j)
    j{w} = rand(m,2);
end

使用 Composite 对象对 pi 进行蒙特卡罗近似。

spmd
   for p = drange(1:spmdSize)
      z = j(:,1) + 1i*j(:,2);
      c = sum(abs(z) < 1); 
   end
   k = spmdPlus(c);
   p = 4*k/(m*spmdSize);
end
approxPi = p{1}

approxPi = 
3.1418