建议的解决方案
我终于能够破解它以获得真正的矢量化解决方案,该解决方案使用logical indexing 从输入矩阵中选择要求和的元素。这个魔法是通过bsxfun 及其可选的功能句柄@mod 实现的。代码如下-
[m,n] = size(M);
mask = bsxfun(@mod,1:n,(1:m)')==1; %//'# all of magic happens here as it creates
%// a logical mask of 1's at places in input matrix
%// whose elements are to be summed and 0's elsewhere.
mask(1,:) = 1; %// set the first row as all ones as we need to sum all of those
sumvals = sum(mask.*M,2); %// finally get the sum values
基准测试
在这个基准测试部分中,我包括了四种方法——本文前面列出的一种方法及其 GPU 移植版本,
arrayfun 和 sparse 中列出的基于 the other solution 的方法。
三组输入数据用于基准测试 -
-
Set 1:相对于问题中使用的输入矩阵中的行数,列数保持在 10 的倍数。
-
Set 2:行数已扩展,因此行数现在为10x 列数。这将真正测试出循环代码,因为
在这种情况下,迭代次数会更多。
-
Set 3:这个集合是set2 的扩展,进一步增加行数,因此将是真正矢量化方法之间的另一个很好的测试
反对他人。
下面列出了用于基准测试的功能代码-
function sumvals = sumrows_stepped_bsxfun(M)
//... same as the code posted earlier
return
function sumvals = sumrows_stepped_bsxfun_gpu(M)
gM = gpuArray(M);
[m,n] = size(gM);
mask = bsxfun(@mod,gpuArray.colon(1,n),gpuArray.colon(1,m)')==1; %//'
sumvals = gather(sum(mask.*gM,2));
sumvals(1) = sum(M(1,:));
return
function S = sumrows_stepped_arrayfun(M)
[m,n] = size(M);
S = arrayfun(@(x) sum(M(x,1:x:n)), 1:m);
return
function B = sumrows_stepped_sparse(M)
sz = size(M);
A=sparse(sz(1),sz(2));
for n=1:sz(1),
A(n, 1:n:end)=1;
end
B=full(sum(M.*A,2));
return
请注意timeit 用于计时CPU based 代码,gputimeit 用于GPU based 代码。
用于测试的系统配置 -
MATLAB Version: 8.3.0.532 (R2014a)
Operating System: Windows 7
RAM: 3GB
CPU Model: Intel® Pentium® Processor E5400 (2M Cache, 2.70 GHz)
GPU Model: GTX 750Ti 2GB
由此获得的基准测试结果 -
结论
对于行数小于列数的数据大小,迭代次数很少,循环代码似乎占上风。
随着行数的增加,真正矢量化方法的好处变得显而易见。您还会注意到,基于bsxfun on CPU 的方法对于第 3 组效果很好,直到 12000 x 300 标记针对非矢量化方法,其背后的原因是,bsxfun 创建了这个巨大的逻辑掩码,此时内存带宽需求变为太高了,无法应付bsxfun 的计算能力。这是有道理的,因为根据定义,向量化操作意味着一次性对许多元素执行操作,因此内存带宽是必不可少的。所以,如果你有一台更好的机器和更多的内存,12000 x 300 标记应该会进一步扩展。
如果您可以进一步扩展行数,那么只要控制内存带宽,矢量化解决方案的优势就会变得更加明显。
基准代码
如果有人想在他们的系统上测试它,最后这里是基准测试代码 -
clear all; clc; close all
outputfile = 'results.xlsx';
delete(outputfile); %// remove file, so that new results could be written into
base_datasize_array = 40:60:400;
methods = {'BSXFUN on GPU','BSXFUN on CPU','ARRAYFUN','SPARSE'};
num_approaches = numel(methods);
num_sets = 3;
timeall_all = zeros(num_approaches,numel(base_datasize_array),num_sets);
datasize_lbs = cell(numel(base_datasize_array),num_sets);
for set_id = 1:num_sets
switch set_id
case 1
N1_arr = base_datasize_array*2;
N2_arr = N1_arr*10;
case 2
N2_arr = base_datasize_array*2;
N1_arr = N2_arr*10;
case 3
N2_arr = base_datasize_array;
N1_arr = N2_arr*40;
end
timeall = zeros(num_approaches,numel(N1_arr));
for iter = 1:numel(N1_arr)
M = rand(N1_arr(iter),N2_arr(iter));
f = @() sumrows_stepped_bsxfun_gpu(M);
timeall(1,iter) = gputimeit(f); clear f
f = @() sumrows_stepped_bsxfun(M);
timeall(2,iter) = timeit(f); clear f
f = @() sumrows_stepped_arrayfun(M);
timeall(3,iter) = timeit(f); clear f
f = @() sumrows_stepped_sparse(M);
timeall(4,iter) = timeit(f); clear f
end
timeall_all(:,:,set_id) = timeall;
wp = repmat({' '},numel(N1_arr),1);
datasize_lbs(:,set_id) = strcat(cellstr(num2str(N1_arr.')),' x ',...
wp,cellstr(num2str(N2_arr.')));
end
for set_id=1:num_sets
out_cellarr = cell(numel(methods)+1,numel(N1_arr)+1);
out_cellarr(1,1) = {'Methods'};
out_cellarr(2:end,1) = methods;
out_cellarr(1,2:end) = datasize_lbs(:,set_id);
out_cellarr(2:end,2:end) = cellfun(@(x) num2str(x),...
num2cell(timeall_all(:,:,set_id)),'Uni',0);
xlswrite(outputfile, out_cellarr,set_id);
end