SPMD to process different iteration on different worker

Question

Yi Xien Yap 2022-7-29

0
链接

此问题的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/1770470-spmd-to-process-different-iteration-on-different-worker

评论： Walter Roberson 2022-8-3

I'm trying to use the spmd to process different iteration. The current problem I have is the spmd function is repeating the same processing on different worker. I have tried to use parfor but the parfor cannot guarantee the iteration is process in order. What I am looking for is to have the iteration process in order. For example, from 0>1>2>3>4,.... Below is the sample code.

clear
clc
iCellNum = 1;
activeUeNums = 1;
tic
ticBytes(gcp)
for ttiNum = 1 : 20
   spmd
        if true
            fprintf('%s processing subframe: %d\n', getTimeNow, ttiNum-1);
        end    
   end
end
toc
tocBytes(gcp)

0 个评论
显示 -2更早的评论隐藏 -2更早的评论

请先登录，再进行评论。

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

Answer 1

Edric Ellis 2022-8-2

0
链接

此回答的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/1770470-spmd-to-process-different-iteration-on-different-worker#answer_1019635

It's not entirely clear to me quite what you're after. You might want for (drange) which spreads the iterations of a for loop over different workers in spmd.

parpool("local");
Starting parallel pool (parpool) using the 'local' profile ...
Connected to the parallel pool (number of workers: 2).
spmd
    for ii = drange(1:20)
        fprintf('Worker %d processing iteration %d\n', labindex, ii);
    end
end
Worker 1: 
  Worker 1 processing iteration 1
  Worker 1 processing iteration 2
  Worker 1 processing iteration 3
  Worker 1 processing iteration 4
  Worker 1 processing iteration 5
  Worker 1 processing iteration 6
  Worker 1 processing iteration 7
  Worker 1 processing iteration 8
  Worker 1 processing iteration 9
  Worker 1 processing iteration 10
Worker 2: 
  Worker 2 processing iteration 11
  Worker 2 processing iteration 12
  Worker 2 processing iteration 13
  Worker 2 processing iteration 14
  Worker 2 processing iteration 15
  Worker 2 processing iteration 16
  Worker 2 processing iteration 17
  Worker 2 processing iteration 18
  Worker 2 processing iteration 19
  Worker 2 processing iteration 20