主要内容

发送

从工人到客户端发送数据使用一个数据队列

所有的页面崩溃

语法

发送(队列,数据)
发送(pollablequeue,数据)

描述

例子

发送(队列,数据)发送一条消息或数据值数据到parallel.pool.DataQueue指定的队列。调用afterEach通过每一个等待消息到指定的函数afterEach。

例子

发送(pollablequeue,数据)发送一条消息或数据值数据到parallel.pool.PollableDataQueue指定的pollablequeue。检索结果使用民意调查(pollablequeue),然后返回数据作为答案。

使用发送和民意调查函数一起使用可投票的数据队列转移和检索消息或数据从不同的工人。

例子

全部折叠

构造一个DataQueue,叫afterEach。

q = parallel.pool.DataQueue;afterEach (q, @disp);
开始一个parfor循环,发送一条消息。等待消息被传递到afterEach函数,在这个例子中@disp。

parfor我= 1:3发送(问我);结束;
1 2 3

为更多的细节在监听数据使用DataQueue,请参阅afterEach。

构造一个PollableDataQueue。

p = parallel.pool.PollableDataQueue;
开始一个parfor循环发送消息,比如数据值1。
parfor我= 1把(p, i);结束
民意调查的结果。

调查(p)
1

为检索数据使用的更多细节PollableDataQueue,请参阅民意调查。

这个例子显示了创建一个函数parfor等待吧。创建一个DataQueue,并使用afterEach指定要执行的函数每次队列接收数据。这个例子中调用子函数,更新等酒吧。

创建一个parfor循环进行MATLAB计算要求的任务®。使用发送发送一些虚拟数据在每个迭代parfor循环。当队列接收到数据,afterEach调用nUpdateWaitbarMATLAB在客户端,您可以观察等待酒吧的进步。

函数一个= parforWaitbar D = parallel.pool.DataQueue;h = waitbar (0,“请等待…”);afterEach (D, @nUpdateWaitbar);N = 200;p = 1;parfori = 1: N (i) = max (abs (eig (rand (400))));发送(D,我);结束函数nUpdateWaitbar (~) waitbar (p / N、h);p = p + 1;结束结束

输入参数

全部折叠

数据队列,指定为一个parallel.pool.DataQueue对象。

例子:q = parallel.pool.DataQueue;

从工人到一个数据队列消息或数据,指定为任何可以序列化的数据类型。

例子:发送(队列、数据);

可投票的数据队列,指定为一个parallel.pool.PollableDataQueue对象。

例子:p = parallel.pool.PollableDataQueue;

版本历史

介绍了R2017a

另请参阅

|||||