tbb::parallel_for 实例

Posted 2022-01-06 软件工程小施同学

void testParallel_for() 

    // 一般普通的vector，无法保证线程安全，因此需要用tbb自带的
    std::vector<int> vec100, 200, 300, 400;
    tbb::concurrent_vector<int> vec_tbb;
    vec_tbb.assign(vec.begin(), vec.end());
    //初始化得到0,1,2,3, 最后一个默认参数是分割的粒度，一般默认是1
    tbb::blocked_range<int> range(0, vec_tbb.size());

    // parallel_for的第一个参数必须是可以disvisible的，所以需要使用tbb自带的range
    tbb::parallel_for(range, [&](const tbb::blocked_range<int> &range) 

        // 遍历range就是遍历range中的元素本身，而这里的范围for是需要解引用的，所以如果要使用范围for，range中必须是迭代器类型
        // for(auto& data:range)
        for (int i = range.begin(); i != range.end(); i++) 
            vec_tbb[i] += 100;
        

    );

    for (auto &data:vec_tbb) 
        std::cout << data << " ";
    

    std::cout << std::endl;
    // 可以利用blocked_range产生迭代器类型访问元素
    tbb::blocked_range<tbb::concurrent_vector<int>::iterator> range1(vec_tbb.begin(), vec_tbb.end());
    tbb::parallel_for(range1, [&](const tbb::blocked_range<tbb::concurrent_vector<int>::iterator> &range1) 

        for (auto &data:range1)
            data += 100;
    );

    vector<int> result;
    result.insert(result.begin(), vec_tbb.begin(), vec_tbb.end());
    for (auto &data:result) 
        std::cout << data << " ";
    
    std::cout << std::endl;

2. parallel_for_each测试

3. thread下的tbb线程安全容器测试

TBB并行计算测试 - 知乎