我编写了一个程序,用于使用 c++0x 线程搜索数组中的最大值(用于学习目的)。为了实现,我使用了标准线程和未来类。但是,并行化函数始终显示与非并行化函数相同或更差的运行时间。
代码如下。我尝试将数据存储在一维数组、多维数组中,最终得到了几个数组。然而,没有任何选择能产生好的结果。我尝试从 Eclipse 和命令行编译和运行我的代码,但仍然没有成功。我也尝试过没有使用数组的类似测试。并行化只提供了 20% 的速度。从我的角度来看,我运行非常简单的并行程序,没有锁,几乎没有资源共享(每个线程都在自己的数组上运行)。什么是瓶颈?
我的机器有 Intel Core i7 处理器 2.2 GHz 和 8 GB RAM,运行 Ubuntu 12.04。
const int n = 100000000;
int a[n], b[n], c[n], d[n];
int find_max_usual() {
int res = 0;
for (int i = 0; i < n; ++i) {
res = max(res, a[i]);
res = max(res, b[i]);
res = max(res, c[i]);
res = max(res, d[i]);
}
return res;
}
int find_max(int *a) {
int res = 0;
for (int i = 0; i < n; ++i)
res = max(res, a[i]);
return res;
}
int find_max_parallel() {
future<int> res_a = async(launch::async, find_max, a);
future<int> res_b = async(launch::async, find_max, b);
future<int> res_c = async(launch::async, find_max, c);
future<int> res_d = async(launch::async, find_max, d);
int res = max(max(res_a.get(), res_b.get()), max(res_c.get(), res_d.get()));
return res;
}
double get_time() {
timeval tim;
gettimeofday(&tim, NULL);
double t = tim.tv_sec + (tim.tv_usec / 1000000.0);
return t;
}
int main() {
for (int i = 0; i < n; ++i) {
a[i] = rand();
b[i] = rand();
c[i] = rand();
d[i] = rand();
}
double start = get_time();
int x = find_max_usual();
cerr << x << " " << get_time() - start << endl;
start = get_time();
x = find_max_parallel();
cerr << x << " " << get_time() - start << endl;
return 0;
}
时序表明 find_max_parralel 中几乎所有的时间都被
int res = max(max(res_a.get(), res_b.get()), max(res_c.get(), res_d.get()));
编译命令行
g++ -O3 -std=c++0x -pthread x.cpp
更新。问题解决了。我通过相同的测试得到了想要的结果。4 个线程提供大约 3.3 的加速,3 个线程提供大约 2.5 的加速,2 个线程在 1.9 的加速下表现几乎理想。我刚刚用一些新的更新重新启动了系统。我没有看到 cpu 负载和运行 porgrams 有任何显着差异。
感谢大家的帮助。