Example Does Not Work

22 次查看（过去 30 天）

William 2025-11-26

0
链接

此问题的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/2181521-example-does-not-work

评论： Walter Roberson 2025-11-28，20:22

I try to run the example. The second line of code workerToClient = parallel.pool.PollableDataQueue(Destination="any") gives me this error:

Error using parallel.pool.PollableDataQueue (line 28)

Too many input arguments.

I remove the Destination = "any" argument and that seems to get things working. But then I get to the for-loop in the example:

for idx = 1:5
    send(clientToWorker, [idx rand]);
    status = poll(workerToClient, inf)
end

and the computer locks up with no output. I force-quite (CTRL-C) and type

future.State

The result is 'finished'. It seems the process stopped and I never sent the stop message. Seems nothing I can do will keep the process running.

6 个评论
显示 4更早的评论隐藏 4更早的评论

William 2025-11-26，23:25

移动：Walter Roberson 2025-11-26，23:40

在 MATLAB Online 中打开

I see the matlab provided example did not attach to this question. My appoligies. I'll copy it here:

Typed into the matlab command window:

pool = parpool("Threads",1);
workerToClient = parallel.pool.PollableDataQueue(Destination="any"); % Except that I had to remove the Destination="any"
clientToWorker = parallel.pool.PollableDataQueue(Destination="any"); % to get the error messages to go away.

In a seperate (processData.m) file:

function out = processData(workerToClient,clientToWorker)
out = 0;
send(workerToClient,"Ready to receive data.");
while true
    % Wait for a message
    data = poll(clientToWorker,Inf);
    if strcmp(data,"stop")
        send(workerToClient,"Stopped processing data on worker.")
        return
    else
        response = sprintf("Data %d received.",data(1));
        send(workerToClient,response);
        out = out+data(2);
        pause(1);
    end
end
end

Back to the command window:

future = parfeval(@processData,1,workerToClient,clientToWorker);
status = poll(workerToClient,inf)
for idx = 1:5
    send(clientToWorker,[idx rand]);
    status = poll(workerToClient,inf)
end

There's more code (to be typed at the command prompt) after this but matlab hangs at this point.

The full example code and instructions from Matlab is here www.mathworks.com/help/parallel-computing/send-messages-to-workers-using-pollable-data-queues.html

William 2025-11-28，16:35

Is there no way to do block a parallel process while it waits for data pre-2025a?

Walter Roberson 2025-11-28，20:22

Sure, you can use poll() with an infinite timeout. https://www.mathworks.com/help/releases/R2024b/matlab/ref/parallel.pool.pollabledataqueue.poll.html

You have to be careful about what you are polling, as there is no Destination="any"

请先登录，再进行评论。

请先登录，再回答此问题。

回答（0 个）

请先登录，再回答此问题。

类别

MATLAB Environment and Settings Startup and Shutdown

在 Help Center 和 File Exchange 中查找有关 Startup and Shutdown 的更多信息

产品

版本

R2024b

Community Treasure Hunt

Find the treasures in MATLAB Central and discover how the community can help you!

Start Hunting!

Translated by

Example Does Not Work

6 个评论
显示 4更早的评论隐藏 4更早的评论

回答（0 个）

另请参阅

类别

标签

产品

版本

Community Treasure Hunt

Example Does Not Work

6 个评论 显示 4更早的评论隐藏 4更早的评论

回答（0 个）

另请参阅

类别

标签

产品

版本

Community Treasure Hunt

6 个评论
显示 4更早的评论隐藏 4更早的评论