【问题标题】:one array and multiple workers work and change on that array on matlab一个数组和多个工作人员在 matlab 上对该数组进行工作和更改
【发布时间】:2023-03-10 01:01:01
【问题描述】:

我有一个包含 1xN 元素的数组,我想使用 4 个或更多工作线程(内核)在这个数组上并行工作。每个工作人员从该数组中获取一些元素并对其进行操作。例如,worker1 将采用 3 个元素,worker2 将采用接下来的 2 个,依此类推。 这些工人将并行工作。

这些工作人员如何同步才能正常工作? 这似乎需要多个 CPU 之间的共享内存。

我需要每个工作人员同时从该数组中读取不同大小的数据:例如:


arr=1:100; % the common array 
serv1 = 3; % random numbers 
serv2 = 2; % random numbers 
serv3 = 1; % random numbers 
serv4 = 1; % random numbers 
我需要同时worker1读取array(1:serv1),worker 2读取array(serv1+1:serv1+serv2),worker3读取array(serv1+serv2+1:serv1+serv2+serv3)等等,然后对它们进行函数操作

【问题讨论】:

  • 你有并行计算工具箱吗?
  • 如果每个工作人员处理数组的不同元素,这究竟是如何实现共享内存的?
  • 这将实现 M/M/n 队列系统,意味着一个缓冲区和多个服务器,每个服务器将从队列中获取不同的元素并为其提供服务。

标签: matlab parallel-processing


【解决方案1】:

如果我的问题没问题,我会提出这样的建议

n = numel(array); % this would be the common array
nw = 5; % number of workers, assuming you have at least that many workers up and running
start_i = floor(linspace(1,n,nw+1)); % each worker will start working from start_i 
start_i( end ) = [];
end_i = [start_i(2:end)+1 n]; % each worker will work till end_i
parfor ( ii = 1:nw, nw )
     processArray( array( start_i(ii):end_i(ii) ) ); % do your magic here
end

【讨论】:

  • 感谢您的回复...我需要每个工作人员同时从该数组中读取不同大小的数据:敌人示例:arr=1:100; % 公共数组 serv1=3;服务2=2;服务3=1;服务4=1; % 我需要在
  • 感谢您的回复...我需要每个工作人员同时从该数组中读取不同大小的数据:敌人示例:arr=1:100; % 普通数组 serv1=3;%random numbers serv2=2;%random numbers serv3=1;%random numbers serv4=1;%random numbers % 我需要同时吃 worker1 读取数组(1:serv1)和 worker 2读取array(serv1+1:serv1+serv2),worker3读取array(serv1+serv2+1:serv1+serv2+serv3)等,然后对它们进行函数操作
  • @AbeerAwad - 您的 cmets 非常重要。请相应地编辑您的问题 - 这样您将获得更好的答案。
  • @AbeerAwad - 恐怕我对并行工具箱的了解不够。尝试查看mathworks.com/help/distcomp/labbroadcast.html 我认为这将帮助您解决问题。如果你想出了一个方法 - 不要忘记在这里发布它作为答案!
  • 谁能帮帮我?
猜你喜欢
  • 2013-11-05
  • 2017-11-28
  • 2014-05-29
  • 2013-02-28
  • 1970-01-01
  • 1970-01-01
  • 2020-07-04
  • 2022-01-02
  • 1970-01-01
相关资源
最近更新 更多