Here is an example that demonstrates how you can use PollableDataQueue to send the command across to the function running a while loop on a worker via parfeval
%open parallel pool or grab handle to existing pool
p=gcp;
%create data queue to send data to display from worker to client
queueDisp=parallel.pool.DataQueue;
afterEach(queueDisp,@disp);
%create data queue to send the worker's data queue back to the client
queue1 = parallel.pool.PollableDataQueue;
%call the function
f = parfeval(@test, 0, queue1,queueDisp);
%receieve the data queue created on the worker back to the client
ok=false;
while ~ok
[queue2,ok] = poll(queue1,1)
end
disp("queue acquired")
%wait 10 seconds then send stop command. This send command could also be
%run directly from the command window
pause(10)
send(queue2,"stop")
function test(queue1,queueDisp)
%create queue on worker to send data to client
queue2 = parallel.pool.PollableDataQueue;
%use queue1 to send reference to queue2 back to the client
send(queue1,queue2);
a="ready";
while ~strcmp(a,"stop")
send(queueDisp,a);%send data created on worker back to client
[a,ok]=poll(queue2,1);%check to see if stop command sent from client;
end
end
If you need similar functionality on a batch job instead of an interactive pool here is an example of how you can use ValueStore to send a stop command to function running a while loop on a worker via batch
%get cluster object
c=parcluster("Processes");
%call the function
j = batch(c,@test, 2);
%get ValueStore object
store=j.ValueStore;
store("stop_command")="go";
%wait 6 seconds then send stop command. This could also be done from the
%command window.
pause(6)
store("stop_command")="stop";
wait(j);
outputs=fetchOutputs(j);
function [a,b] = test()
%get handle to valuestore
store=getCurrentValueStore;
a=0;
while ~strcmp(store("stop_command"),"stop")
pause(1)
a=a+1;
end
b="complete"
end
