Execute functions and read input simultaneously in Matlab

Question

Star 2018-11-3

0
链接

此问题的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/427698-execute-functions-and-read-input-simultaneously-in-matlab

评论： Star Rats 2019-4-10

I have an mp3 file which needs to go through different functions (blocks) in series. The input of each block is taken from the output of the previous block. Block C needs the longest time to process (eg. 10s). The problem is, instead of waiting the 10s, I wish to read another frame of mp3 while waiting the block C to finish its process. Any idea on the solution?

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

请先登录，再进行评论。

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

Answer 1

Walter Roberson 2018-11-3

0
链接

此回答的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/427698-execute-functions-and-read-input-simultaneously-in-matlab#answer_344911

编辑：Walter Roberson 2018-11-25

在 MATLAB Online 中打开

If you have the parallel computing toolbox then you can use spmd.

framesize = 4096;
P = parpool(4);
spmd 
  if labindex == 1
    end 
  end
spmd 
  if labindex == 1 
    afr = dsp.AudioFileReader(Filename, 'SamplesPerFrame', framesize);
    while ~isDone(afr) 
      frame = step(afr);
      labSend(frame, 2);
    end
    labSend([], 2)
    release(afr) 
    elseif labindex == 2
      while true
        frame = labReceive(1);
        if isempty(frame) 
          labSend([], 3)
          break
        end
        Bres = BlockB(frame);
        labSend(Bres, 3);
      end
    elseif labindex == 3
       while true
         Bres = labReceive(2);
         if isempty(Bres) 
           labSend([], 4)
           break
         end
         Cres = BlockC(Bres) ;
         labSend(Cres, 4) 
      end
    else
      while true 
        Cres = labReceive(3);
        if isempty(Cres) 
           break 
        end 
        Dres = BlockD(Cres) ;
      end
    end

11 个评论
显示 9更早的评论隐藏 9更早的评论

Star 2018-12-5

在 MATLAB Online 中打开

Hi Walter, this is part of my coding:

function [PCM, output] = mp3(song)
table_select(1:4,1:3) = uint8(0);
spmd
if labindex == 1
    while true
        row_index = 1;
        if ( blocksplit_flag(row_index))
            for region=1:2
                table_select(row_index,region) = uint8( reformbit (y(remd:remd+4))); 
            end
        else
            for region=1:3
                table_select(row_index,region) = uint8( reformbit (y(remd:remd+4)));
            end
           
            labSend(table_select(row_index,:), 2);
			
        end
		
else labindex == 2
    while true	
        row_index = 1;
            table_select(1:4,1:3) = labReceive(1);
            if (blocksplit_flag(row_index,1) == 1 && block_type(row_index) == 2)
                [a0 lin0 max0] = huffman(table_select(row_index,1));
		  [a1 lin1 max1] = huffman(table_select(row_index,2));                                    
				
	      else
		  [a0 lin0 max0] = huffman(table_select(row_index,1));
		  [a1 lin1 max1] = huffman(table_select(row_index,2));
		  [a2 lin2 max2] = huffman(table_select(row_index,3));
				
	      end
	end
end
end
end

Thank you.

Walter Roberson 2019-2-21

No. Job scheduler is only needed if you are using the Distributed Computing Toolbox, which would be for running computing on a cluster. Job schedulers are not required for running only on the resources of the local computer.

Star Rats 2019-4-10

Hi Walter, is your answer above considered as Task parallel (Embarrassingly Parallel) or Data parallel (Fine Grained Parallel) ?

请先登录，再进行评论。

Answer 2

Star 2018-12-5

0
链接

此回答的直接链接

https://ww2.mathworks.cn/matlabcentral/answers/427698-execute-functions-and-read-input-simultaneously-in-matlab#answer_350684

在 MATLAB Online 中打开

I want to send 4 rows and receive 4 rows. A more detailed coding is shown below:

function [PCM, output] = mp3(song)
table_select(1:4,1:3) = uint8(0);
spmd
	if labindex == 1
        while true
            row_index = 1;
                for granule = 1:2
                    for channel=1:2
                        if ( blocksplit_flag(row_index))
                            for region=1:2
                                table_select(row_index,region) = uint8( reformbit (y(remd:remd+4))); 
                            end	
                        else
                            for region=1:3
                                table_select(row_index,region) = uint8( reformbit (y(remd:remd+4)));
                            end
                        end
                        row_index = row_index + 1;		
                    end
                end
                labSend(table_select(row_index,:), 2);
        end	
      else labindex == 2
        while true		
            table_select(1:4,1:3) = labReceive(1);
			
                 row_index = 1;
                     for granule = 1:2
			    for channel=1:2
				if (blocksplit_flag(row_index,1) == 1 && block_type(row_index) == 2)
					[a0 lin0 max0] = huffman(table_select(row_index,1));
					[a1 lin1 max1] = huffman(table_select(row_index,2));                                    
				else
					[a0 lin0 max0] = huffman(table_select(row_index,1));
					[a1 lin1 max1] = huffman(table_select(row_index,2));
					[a2 lin2 max2] = huffman(table_select(row_index,3));
				
				end
				row_index = row_index + 1;	
			    end
		        end
	    end
       end
end

2 个评论
显示无隐藏无

Walter Roberson 2018-12-5

What you labSend is indexed by row so you only send one row .

Star 2018-12-6

在 MATLAB Online 中打开

Thanks Walter.

I have face some problem in labSend. The coding is as below:

function [PCM, output] = mp3(song)
table_select(1:4,1:3) = uint8(0);
spmd
	if labindex == 1
	   while true
		%Var b went through several equation
		labSend (b1,2);
			
		row_index = 1;
		for granule = 1:2
		   labSend (granule,2);
		   for channel=1:2
		        labSend (channel,2);
			if ( blocksplit_flag(row_index))
					
			   %Went through several equation
			   for region=1:2
				table_select(row_index,region) = uint8( reformbit (y(remd:remd+4))); 
				labSend(table_select(row_index,:), 2);
			   end	
			else
			   %Went through several equation
			   for region=1:3
			        table_select(row_index,region) = uint8( reformbit (y(remd:remd+4)));
				labSend(table_select(row_index,:), 2);
				remd = remd + 3;
		           end
			end
			row_index = row_index + 1;		
		   end %End of channel
		end %End of granule
			
		   if ( maindata == 0)
			b2 = remd;
			labSend(b2,2);
			labSend(remd,2);	
		   else
			b2 = current_bit - (maindata*8);
			labSend(b2,2);
			labSend(remd,2);
			end
		end
			
	else labindex == 2
		while true	
			b1 = labReceive(1);
			b2 = labReceive(1);
			remd = labReceive(1);
			
			if isempty(frameNumber)
			   labSend(3, []);
			break
			end
			
			row_index = 1;
			for granule = 1:2
				for channel=1:2
					table_select(1:4,1:3) = labReceive(1);
					if (blocksplit_flag(row_index,1) == 1 && block_type(row_index) == 2)
						[a0 lin0 max0] = huffman(table_select(row_index,1));
						[a1 lin1 max1] = huffman(table_select(row_index,2));                                    
					else
						[a0 lin0 max0] = huffman(table_select(row_index,1));
						[a1 lin1 max1] = huffman(table_select(row_index,2));
						[a2 lin2 max2] = huffman(table_select(row_index,3));
					end
					row_index = row_index + 1;	
				end %End of channel
			end %End of granule
		end
	end
end

My Questions are:

1. I manage to labReceive b1 but not b2 and remd. The value for b2 and remd is always zero.

Is it because of the for loop that cause b2 and remd cannot be received?

2. labindex 2 always come first before labindex 1.

I think it is because of the preset value of granule and channel.

How to make labindex 1 run first so that the data needed can be received by labindex 2?

I have tried to run the coding below but it could not work.

Again, the value of granule and channel are always zero.

	row_index = labReceive(1);
	row_index = row_index + 0; 
								
	granule = labReceive(1);
	for ( 0 < granule < 3)
		disp(sprintf('This is granule %d', granule));
							
		channel = labReceive(1);
		for ( 0 < channel < 3)
		disp(sprintf('This is channel %d', channel));	
		%Content
		
		end
	end

Thank you.

请先登录，再进行评论。

Execute functions and read input simultaneously in Matlab

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

回答（2 个）

11 个评论
显示 9更早的评论隐藏 9更早的评论

2 个评论
显示无隐藏无

另请参阅

类别

标签

产品

Community Treasure Hunt

Execute functions and read input simultaneously in Matlab

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

回答（2 个）

11 个评论 显示 9更早的评论隐藏 9更早的评论

2 个评论 显示 无隐藏 无

另请参阅

类别

标签

产品

Community Treasure Hunt

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

11 个评论
显示 9更早的评论隐藏 9更早的评论

2 个评论
显示无隐藏无