Intel® oneAPI Threading Building Blocks Developer Guide and API Reference
A newer version of this document is available. Customers should click here to go to the newest version.
Visible to Intel only — GUID: GUID-725908C9-CA33-4363-ACAD-A852743AC0AF
Visible to Intel only — GUID: GUID-725908C9-CA33-4363-ACAD-A852743AC0AF
Parallel Reduction for rvalues
Description
oneAPI Threading Building Blocks (oneTBB) implementation extends the ParallelReduceFunc and ParallelReduceReduction to optimize operating with rvalues using functional form of tbb::parallel_reduce and tbb::parallel_deterministic_reduce algorithms.
API
Header
#include <oneapi/tbb/parallel_reduce.h>
ParallelReduceFunc Requirements: Pseudo-Signature, Semantics
ValueFunc::operator()(constRange&range, Value&&x)const
or
ValueFunc::operator()(constRange&range, constValue&x)const
Accumulates the result for a subrange, starting with initial value x. The Range type must meet the Range requirements. The Value type must be the same as a corresponding template parameter for the parallel_reduce algorithm.
If both rvalue and lvalue forms are provided, the rvalue is preferred.
ParallelReduceReduction Requirements: Pseudo-Signature, Semantics
ValueReduction::operator()(Value&&x, Value&&y)const
or
ValueReduction::operator()(constValue&x, constValue&y)const
Combines the x and y results. The Value type must be the same as a corresponding template parameter for the parallel_reduce algorithm.
If both rvalue and lvalue forms are provided, the rvalue is preferred.
Example
// C++17 #include <oneapi/tbb/parallel_reduce.h> #include <oneapi/tbb/blocked_range.h> #include <vector> #include <set> int main() { std::vector<std::set<int>> sets = ...; oneapi::tbb::parallel_reduce(oneapi::tbb::blocked_range<size_t>(0, sets.size()), std::set<int>{}, // identity element - empty set [&](const oneapi::tbb::blocked_range<size_t>& range, std::set<int>&& value) { for (size_t i = range.begin(); i < range.end(); ++i) { // Having value as a non-const rvalue reference allows to efficiently // transfer nodes from sets[i] without copying/moving the data value.merge(std::move(sets[i])); } return value; }, [&](std::set<int>&& x, std::set<int>&& y) { x.merge(std::move(y)); return x; } ); }
See also