간단한 TBB 예

Question

누군가가 나에게 방법에 TBB 예를 줄 수 :

1. 활성 스레드의 최대 수를 설정합니다.
2. 은 서로 독립적이며 정적 함수가 아닌 클래스 형식으로 표시된 작업을 실행합니다.

Answer 1

두 개의 완전한 예가 있습니다. 하나는 parallel_for이고 다른 하나는 parallel_for_each입니다.

업데이트 2014-04-12 : 이것들은 TBB를 사용하는 꽤 오래된 방식이라고 생각합니다. 나는 separate answer을 parallel_for과 C++ 11 람다를 사용하여 추가했습니다.

#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; 
} 

두

(와 그 "invoker"일을 교체하기위한 this question을 참조하십시오 (다음 ./a.out으로 실행) g++ tbb_example.cpp -ltbb와 데비안/위지 (g ++ 4.7) 시스템에 컴파일

a std::mem_fun_ref 또는 boost::bind).

Answer 2

람다가있는 parallel_for의 최신 용도가 있습니다. 컴파일하고 g++ -std=c++11 tbb_example.cpp -ltbb && ./a.out와 데비안/위지에서 실행

#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; 
}; 

int main(int,char**) { 

    //tbb::task_scheduler_init init; // Automatic number of threads 
    tbb::task_scheduler_init init(tbb::task_scheduler_init::default_num_threads()); // Explicit number of threads 

    std::vector<mytask> tasks; 
    for (int i=0;i<1000;++i) 
    tasks.push_back(mytask(i)); 

    tbb::parallel_for(
    tbb::blocked_range<size_t>(0,tasks.size()), 
    [&tasks](const tbb::blocked_range<size_t>& r) { 
     for (size_t i=r.begin();i<r.end();++i) tasks[i](); 
    } 
); 

    std::cerr << std::endl; 

    return 0; 
} 

Answer 3

1

//! 
//! Get the default number of threads 
//! 
int nDefThreads = tbb::task_scheduler_init::default_num_threads(); 

//! 
//! Init the task scheduler with the wanted number of threads 
//! 
tbb::task_scheduler_init init(nDefThreads); 

이

2

어쩌면 당신의 코드를 허용하는 경우, TBB와 독립적 인 작업을 실행하는 가장 좋은 방법은 parallel_invoke입니다 . intel developers zone의 블로그에는 parallel_invoke가 얼마나 도움이되는지 몇 가지 사례를 설명하는 게시물이 있습니다. 체크 아웃 this

Answer 4

단지 몇 가지 작업을 동시에 실행하려면 tbb::task_group을 사용하는 것이 더 쉽습니다. 예 tbb에서 촬영 : 작업 생성 직렬 병목 현상 때문에

#include "tbb/task_group.h" 

using namespace tbb; 

int Fib(int n) { 
    if(n<2) { 
     return n; 
    } else { 
     int x, y; 
     task_group g; 
     g.run([&]{x=Fib(n-1);}); // spawn a task 
     g.run([&]{y=Fib(n-2);}); // spawn another task 
     g.wait();    // wait for both tasks to complete 
     return x+y; 
    } 
} 

참고 그러나

는 하나의 task_group에 대한 작업의 큰 숫자를 생성하는 것이, 확장 성이 아니다.

이러한 경우 parallel_for 또는 이와 유사한 timday의 예를 사용하십시오.