parfeval

使用 parfeval 请求在工作进程上异步执行某个函数。

向并行池提交单个请求。使用 fetchOutputs 函数检索输出。

f = parfeval(@magic,1,10);

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

value = fetchOutputs(f);
value(1)

ans = 92

在 for 循环中指定多个未来请求，并在结果可用时将其收集到向量中。为了提高效率，请在开始循环之前预先分配一个未来对象数组。

f(1:10) = parallel.FevalFuture;
for idx = 1:10
    f(idx) = parfeval(@magic,1,idx);
end

使用 fetchNext 检索可用的各个未来输出。如果在调用 fetchNext 时 FevalFuture 对象数组中没有可用的元素，则 MATLAB 将等待，直到有元素可用。

magicResults = cell(1,10);
for idx = 1:10
    [completedIdx,value] = fetchNext(f);
    magicResults{completedIdx} = value;
    fprintf("Got result with index: %d.\n",completedIdx)
end

Got result with index: 1.
Got result with index: 2.
Got result with index: 3.
Got result with index: 7.
Got result with index: 8.
Got result with index: 9.
Got result with index: 10.
Got result with index: 4.
Got result with index: 5.
Got result with index: 6.

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

myClusterPool = parpool(myMJSCluster,15);

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

使用 parfeval 计算池 myClusterPool 上 1000×1000 矩阵中每列元素的总和。检索结果。

f = parfeval(myClusterPool,@sum,1,rand(1000));
results = fetchOutputs(f)'

results = 1000×1

  509.8296
  483.2762
  505.1542
  479.3408
  489.2463
  512.2336
  495.8580
  499.5442
  487.5374
  491.4364
      ⋮

此示例显示如何在计算完成时更新用户界面。当您使用 parfeval 将计算卸载给工作进程时，工作进程执行计算时所有用户界面都会做出响应。您可以使用 waitbar 来创建一个简单的用户界面。

使用 waitbar 创建图形手柄，h。当您使用 afterEach 或 afterAll 时，waitbar 函数会更新图形句柄。有关句柄对象的更多信息，请参阅 句柄对象行为。

h = waitbar(0,'Waiting...');

使用 parfeval 计算随机矩阵特征值的实部。使用默认首选项，如果尚未创建并行池，parfeval 会自动创建一个。为了提高效率，预先分配一个 Future 对象数组。

f(1:100) = parallel.FevalFuture;
for idx = 1:100
    f(idx) = parfeval(@(n) real(eig(randn(n))),1,5e2); 
end

您可以使用 afterEach 自动对 parfeval 计算的每个结果调用函数。使用 afterEach 来安排另一组未来对象，以在 f 中的每个未来完成后计算每个输出数组中的最大值。

maxFuture = afterEach(f,@max,1);

您可以使用 State 属性来获取期货的状态。定义一个匿名函数，将 h 的分数等待条长度更新为已完成执行的 Future 对象的比例。如果 f 中对应 Future 对象的 State 属性为 "finished"，则 updateWaitbar 匿名函数计算元素为 true 的逻辑数组的平均值。

updateWaitbar = @(~) waitbar(mean({f.State} == "finished"),h);

使用 afterEach 和 updateWaitbar 在 maxFuture 中的每个未来完成后更新分数等待条长度。所有计算完成后，使用 afterAll 和 delete 关闭等待栏。

updateWaitbarFutures = afterEach(f,updateWaitbar,0);
afterAll(updateWaitbarFutures,@(~) delete(h),0)

使用 afterAll 和 histogram 来显示所有期货完成后 maxFuture 中结果的直方图。

showsHistogramFuture = afterAll(maxFuture,@histogram,0);