21 #ifndef __TBB_parallel_do_H 22 #define __TBB_parallel_do_H 31 namespace interface9 {
40 template<
typename Item>
46 #if __TBB_CPP11_RVALUE_REF_PRESENT 53 #if __TBB_CPP11_RVALUE_REF_PRESENT 65 template<
class Body,
typename Item>
69 template<
typename A1,
typename A2,
typename CvItem >
71 obj(tbb::internal::forward<A1>(arg1));
73 template<
typename A1,
typename A2,
typename CvItem >
75 obj(tbb::internal::forward<A1>(arg1), arg2);
77 template<
typename A1,
typename A2,
typename CvItem >
81 template<
typename A1,
typename A2,
typename CvItem >
86 template<
typename A1,
typename A2>
89 internal_call( obj, tbb::internal::forward<A1>(arg1), arg2, &Body::operator() );
96 template<
typename Body,
typename Item>
108 #if __TBB_CPP11_RVALUE_REF_PRESENT 123 template<
typename Iterator,
typename Body,
typename Item>
143 template<
typename Iterator_,
typename Body_,
typename Item_>
friend class do_task_iter;
149 template<
class Body,
typename Item>
152 #if __TBB_CPP11_RVALUE_REF_PRESENT 156 iteration_type& t = *
new (task::allocate_additional_child_of(*
my_barrier)) iteration_type(item, *
this);
160 __TBB_ASSERT(
false,
"Overloading for r-value reference doesn't work or it's not movable and not copyable object");
164 #if __TBB_CPP11_IS_COPY_CONSTRUCTIBLE_PRESENT 173 iteration_type& t = *
new (task::allocate_additional_child_of(*
my_barrier)) iteration_type(
std::move(item), *
this);
179 iteration_type& t = *
new (task::allocate_additional_child_of(*
my_barrier)) iteration_type(item, *
this);
193 #if __TBB_TASK_GROUP_CONTEXT 212 template<
typename Iterator,
typename Body,
typename Item>
246 template<
typename Iterator_,
typename Body_,
typename _Item>
friend class do_task_iter;
249 template<
typename Body,
typename Item>
266 #if __TBB_CPP11_RVALUE_REF_PRESENT 267 typedef std::move_iterator<Item*> Item_iterator;
269 typedef Item* Item_iterator;
288 for(
size_t k=0; k<
my_size; ++k)
292 template<
typename Iterator_,
typename Body_,
typename Item_>
friend class do_task_iter;
298 template<
typename Iterator,
typename Body,
typename Item>
325 typedef typename std::iterator_traits<Iterator>::iterator_category iterator_tag;
326 return run( (iterator_tag*)NULL );
340 new (t.my_arg.begin() + k) Item(*
my_first);
342 if( ++k==block_type::max_arg_size ) {
366 if( ++k==block_type::max_arg_size ) {
382 if( k > block_type::max_arg_size ) {
414 template<
typename Iterator,
typename Body,
typename Item>
422 #if __TBB_TASK_GROUP_CONTEXT 429 root_iteration_task &t = *
new( feeder.
my_barrier->allocate_child() ) root_iteration_task(
first,
last, feeder);
438 template<
typename Iterator,
typename Body,
typename Item>
446 #if __TBB_TASK_GROUP_CONTEXT 455 template<
typename Iterator,
typename Body,
typename Item,
typename _Item>
463 #if __TBB_TASK_GROUP_CONTEXT 497 template<
typename Iterator,
typename Body>
502 #if __TBB_TASK_GROUP_CONTEXT 512 template<
typename Range,
typename Body>
517 template<
typename Range,
typename Body>
522 #if __TBB_TASK_GROUP_CONTEXT 525 template<
typename Iterator,
typename Body>
533 template<
typename Range,
typename Body>
538 template<
typename Range,
typename Body>
543 #endif // __TBB_TASK_GROUP_CONTEXT 547 using interface9::parallel_do_feeder;
do_iteration_task(Item &&value, feeder_type &feeder)
internal::allocate_child_proxy & allocate_child()
Returns proxy for overloaded new that allocates a child task of *this.
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &, void(Body::*)(CvItem &) const)
do_iteration_task(const Item &value, feeder_type &feeder)
parallel_do_feeder_impl(tbb::task_group_context &context)
T * begin() const
Pointer to beginning of array.
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
task * run_for_forward_iterator()
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2, void(Body::*)(CvItem &, parallel_do_feeder< Item > &) const)
void add(const Item &item)
Add a work item to a running parallel_do.
task that does nothing. Useful for synchronization.
auto first(Container &c) -> decltype(begin(c))
Used to form groups of tasks.
bool_constant< true > true_type
parallel_do_feeder_impl< Body, Item > feeder_type
task * execute() __TBB_override
Should be overridden by derived classes.
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain __itt_id ITT_FORMAT p const __itt_domain __itt_id __itt_timestamp __itt_timestamp ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain ITT_FORMAT p const __itt_domain __itt_string_handle unsigned long long ITT_FORMAT lu const __itt_domain __itt_id __itt_string_handle __itt_metadata_type type
Base class for types that should not be copied or assigned.
virtual void internal_add_copy(const Item &item)=0
task * run_for_random_access_iterator()
void recycle_as_child_of(task &new_parent)
Change this to be a child of new_parent.
task * run(std::forward_iterator_tag *)
Base class for user-defined tasks.
task * run(std::random_access_iterator_tag *)
parallel_do_feeder_impl< Body, Item > feeder_type
parallel_do_feeder_impl< Body, Item > feeder_type
static const size_t max_arg_size
virtual ~parallel_do_feeder()
void spawn_and_wait_for_all(task &child)
Similar to spawn followed by wait_for_all, but more efficient.
auto last(Container &c) -> decltype(begin(c))
internal::allocate_continuation_proxy & allocate_continuation()
Returns proxy for overloaded new that allocates a continuation task of *this.
do_group_task_input(feeder_type &feeder)
void run_parallel_do(Iterator first, Iterator last, const Body &body, task_group_context &context)
For internal use only.
do_iteration_task_iter(const Iterator &iter, feeder_type &feeder)
~parallel_do_feeder_impl()
#define __TBB_FORWARDING_REF(A)
task * execute() __TBB_override
Should be overridden by derived classes.
void internal_add_copy_impl(std::true_type, const Item &item)
task * execute() __TBB_override
Should be overridden by derived classes.
Class the user supplied algorithm body uses to add new tasks.
void internal_add_copy(const Item &item) __TBB_override
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain __itt_id ITT_FORMAT p const __itt_domain __itt_id __itt_timestamp __itt_timestamp ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain ITT_FORMAT p const __itt_domain __itt_string_handle unsigned long long value
static void call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2)
static const size_t max_arg_size
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &, void(Body::*)(CvItem) const)
void push_back(task &task)
Push task onto back of list.
task * execute() __TBB_override
Should be overridden by derived classes.
parallel_do_feeder_impl()
void recycle_to_reexecute()
Schedule this for reexecution after current execute() returns.
void move(tbb_thread &t1, tbb_thread &t2)
task * execute() __TBB_override
Should be overridden by derived classes.
void select_parallel_do(Iterator first, Iterator last, const Body &body, void(Body::*)(Item) const, task_group_context &context)
For internal use only.
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2, void(Body::*)(CvItem, parallel_do_feeder< Item > &) const)
friend class internal::parallel_do_feeder_impl
parallel_do_feeder_impl< Body, Item > feeder_type
void internal_add_move(Item &&item) __TBB_override
void set_ref_count(int count)
Set reference count.
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t size
bool_constant< false > false_type
void parallel_do(Iterator first, Iterator last, const Body &body)
Parallel iteration over a range, with optional addition of more work.
static internal::allocate_root_proxy allocate_root()
Returns proxy for overloaded new that allocates a root task.
do_task_iter(Iterator first, Iterator last, feeder_type &feeder)
do_group_task_forward(Iterator first, size_t size, feeder_type &feeder)
virtual void internal_add_move(Item &&item)=0
aligned_space< Item, max_arg_size > my_arg
task * run_for_input_iterator()
parallel_do_feeder< Item > Feeder
#define __TBB_TASK_GROUP_CONTEXT
void internal_add_copy_impl(std::false_type, const Item &)
parallel_do_feeder_impl< Body, Item > feeder_type