最简单的TBB示例 [英] Simplest TBB example
问题描述
有人可以给我一个 TBB 示例如何:
Can someone give me a TBB example how to:
- 设置活动线程的最大计数。
- 执行彼此独立的任务,以类的形式呈现,而不是静态函数。
- set the maximum count of active threads.
- execute tasks that are independent from each others and presented in the form of class, not static functions.
推荐答案
这里有几个完整的例子,使用 parallel_for
,另一个使用 parallel_for_each
。
Here's a couple of complete examples, one using parallel_for
, the other using parallel_for_each
.
更新2014-04-12 这些显示我认为是一个漂亮的老式的方式使用TBB现在;我已使用 parallel_for $添加了单独的答案 c $ c>使用C ++ 11 lambda。
Update 2014-04-12: These show what I'd consider to be a pretty old fashioned way of using TBB now; I've added a separate answer using parallel_for
with a C++11 lambda.
#include "tbb/blocked_range.h"
#include "tbb/parallel_for.h"
#include "tbb/task_scheduler_init.h"
#include <iostream>
#include <vector>
struct mytask {
mytask(size_t n)
:_n(n)
{}
void operator()() {
for (int i=0;i<1000000;++i) {} // Deliberately run slow
std::cerr << "[" << _n << "]";
}
size_t _n;
};
struct executor
{
executor(std::vector<mytask>& t)
:_tasks(t)
{}
executor(executor& e,tbb::split)
:_tasks(e._tasks)
{}
void operator()(const tbb::blocked_range<size_t>& r) const {
for (size_t i=r.begin();i!=r.end();++i)
_tasks[i]();
}
std::vector<mytask>& _tasks;
};
int main(int,char**) {
tbb::task_scheduler_init init; // Automatic number of threads
// tbb::task_scheduler_init init(2); // Explicit number of threads
std::vector<mytask> tasks;
for (int i=0;i<1000;++i)
tasks.push_back(mytask(i));
executor exec(tasks);
tbb::parallel_for(tbb::blocked_range<size_t>(0,tasks.size()),exec);
std::cerr << std::endl;
return 0;
}
和
#include "tbb/parallel_for_each.h"
#include "tbb/task_scheduler_init.h"
#include <iostream>
#include <vector>
struct mytask {
mytask(size_t n)
:_n(n)
{}
void operator()() {
for (int i=0;i<1000000;++i) {} // Deliberately run slow
std::cerr << "[" << _n << "]";
}
size_t _n;
};
template <typename T> struct invoker {
void operator()(T& it) const {it();}
};
int main(int,char**) {
tbb::task_scheduler_init init; // Automatic number of threads
// tbb::task_scheduler_init init(4); // Explicit number of threads
std::vector<mytask> tasks;
for (int i=0;i<1000;++i)
tasks.push_back(mytask(i));
tbb::parallel_for_each(tasks.begin(),tasks.end(),invoker<mytask>());
std::cerr << std::endl;
return 0;
}
无论是在Debian / Wheezy $ c> g ++ tbb_example.cpp -ltbb (然后使用 ./ a.out
)运行
Both compile on a Debian/Wheezy (g++ 4.7) system with g++ tbb_example.cpp -ltbb
(then run with ./a.out
)
(请参阅此问题用 std :: mem_fun_ref
或替换
)。 invoker
boost :: bind
(See this question for replacing that "invoker
" thing with a std::mem_fun_ref
or boost::bind
).
这篇关于最简单的TBB示例的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!