17 #ifndef __TBB_parallel_do_H 18 #define __TBB_parallel_do_H 27 namespace interface9 {
36 template<
typename Item>
42 #if __TBB_CPP11_RVALUE_REF_PRESENT 49 #if __TBB_CPP11_RVALUE_REF_PRESENT 61 template<
class Body,
typename Item>
65 template<
typename A1,
typename A2,
typename CvItem >
67 obj(tbb::internal::forward<A1>(arg1));
69 template<
typename A1,
typename A2,
typename CvItem >
71 obj(tbb::internal::forward<A1>(arg1), arg2);
73 template<
typename A1,
typename A2,
typename CvItem >
77 template<
typename A1,
typename A2,
typename CvItem >
82 template<
typename A1,
typename A2>
85 internal_call( obj, tbb::internal::forward<A1>(arg1), arg2, &Body::operator() );
92 template<
typename Body,
typename Item>
104 #if __TBB_CPP11_RVALUE_REF_PRESENT 119 template<
typename Iterator,
typename Body,
typename Item>
139 template<
typename Iterator_,
typename Body_,
typename Item_>
friend class do_task_iter;
145 template<
class Body,
typename Item>
148 #if __TBB_CPP11_RVALUE_REF_PRESENT 152 iteration_type& t = *
new (task::allocate_additional_child_of(*
my_barrier)) iteration_type(item, *
this);
156 __TBB_ASSERT(
false,
"Overloading for r-value reference doesn't work or it's not movable and not copyable object");
160 #if __TBB_CPP11_IS_COPY_CONSTRUCTIBLE_PRESENT 169 iteration_type& t = *
new (task::allocate_additional_child_of(*
my_barrier)) iteration_type(
std::move(item), *
this);
175 iteration_type& t = *
new (task::allocate_additional_child_of(*
my_barrier)) iteration_type(item, *
this);
189 #if __TBB_TASK_GROUP_CONTEXT 208 template<
typename Iterator,
typename Body,
typename Item>
242 template<
typename Iterator_,
typename Body_,
typename _Item>
friend class do_task_iter;
245 template<
typename Body,
typename Item>
262 #if __TBB_CPP11_RVALUE_REF_PRESENT 263 typedef std::move_iterator<Item*> Item_iterator;
265 typedef Item* Item_iterator;
284 for(
size_t k=0; k<
my_size; ++k)
288 template<
typename Iterator_,
typename Body_,
typename Item_>
friend class do_task_iter;
294 template<
typename Iterator,
typename Body,
typename Item>
321 typedef typename std::iterator_traits<Iterator>::iterator_category iterator_tag;
322 return run( (iterator_tag*)NULL );
336 new (t.my_arg.begin() + k) Item(*
my_first);
338 if( ++k==block_type::max_arg_size ) {
362 if( ++k==block_type::max_arg_size ) {
378 if( k > block_type::max_arg_size ) {
410 template<
typename Iterator,
typename Body,
typename Item>
418 #if __TBB_TASK_GROUP_CONTEXT 425 root_iteration_task &t = *
new( feeder.
my_barrier->allocate_child() ) root_iteration_task(
first,
last, feeder);
434 template<
typename Iterator,
typename Body,
typename Item>
442 #if __TBB_TASK_GROUP_CONTEXT 451 template<
typename Iterator,
typename Body,
typename Item,
typename _Item>
459 #if __TBB_TASK_GROUP_CONTEXT 493 template<
typename Iterator,
typename Body>
498 #if __TBB_TASK_GROUP_CONTEXT 508 template<
typename Range,
typename Body>
513 template<
typename Range,
typename Body>
518 #if __TBB_TASK_GROUP_CONTEXT 521 template<
typename Iterator,
typename Body>
529 template<
typename Range,
typename Body>
534 template<
typename Range,
typename Body>
539 #endif // __TBB_TASK_GROUP_CONTEXT 543 using interface9::parallel_do_feeder;
void run_parallel_do(Iterator first, Iterator last, const Body &body, task_group_context &context)
For internal use only.
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
virtual void internal_add_move(Item &&item)=0
task * run_for_forward_iterator()
Class the user supplied algorithm body uses to add new tasks.
task * execute() __TBB_override
Should be overridden by derived classes.
static void call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2)
void move(tbb_thread &t1, tbb_thread &t2)
static const size_t max_arg_size
internal::allocate_continuation_proxy & allocate_continuation()
Returns proxy for overloaded new that allocates a continuation task of *this.
task * execute() __TBB_override
Should be overridden by derived classes.
do_task_iter(Iterator first, Iterator last, feeder_type &feeder)
void select_parallel_do(Iterator first, Iterator last, const Body &body, void(Body::*)(Item) const, task_group_context &context)
For internal use only.
task that does nothing. Useful for synchronization.
void recycle_to_reexecute()
Schedule this for reexecution after current execute() returns.
Used to form groups of tasks.
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &, void(Body::*)(CvItem) const)
friend class internal::parallel_do_feeder_impl
task * execute() __TBB_override
Should be overridden by derived classes.
#define __TBB_FORWARDING_REF(A)
Base class for types that should not be copied or assigned.
void parallel_do(Iterator first, Iterator last, const Body &body)
Parallel iteration over a range, with optional addition of more work.
void add(const Item &item)
Add a work item to a running parallel_do.
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
Base class for user-defined tasks.
task * execute() __TBB_override
Should be overridden by derived classes.
task * run_for_input_iterator()
aligned_space< Item, max_arg_size > my_arg
parallel_do_feeder_impl< Body, Item > feeder_type
void internal_add_move(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 size
void internal_add_copy_impl(std::false_type, const Item &)
~parallel_do_feeder_impl()
virtual ~parallel_do_feeder()
do_group_task_input(feeder_type &feeder)
task * run(std::forward_iterator_tag *)
parallel_do_feeder_impl< Body, Item > feeder_type
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2, void(Body::*)(CvItem &, parallel_do_feeder< Item > &) const)
do_iteration_task(const Item &value, feeder_type &feeder)
do_group_task_forward(Iterator first, size_t size, feeder_type &feeder)
auto first(Container &c) -> decltype(begin(c))
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2, void(Body::*)(CvItem, parallel_do_feeder< Item > &) const)
parallel_do_feeder_impl< Body, Item > feeder_type
virtual void internal_add_copy(const Item &item)=0
void push_back(task &task)
Push task onto back of list.
parallel_do_feeder_impl(tbb::task_group_context &context)
T * begin() const
Pointer to beginning of array.
auto last(Container &c) -> decltype(begin(c))
bool_constant< false > false_type
parallel_do_feeder_impl< Body, Item > feeder_type
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &, void(Body::*)(CvItem &) const)
static const size_t max_arg_size
parallel_do_feeder_impl()
bool_constant< true > true_type
void recycle_as_child_of(task &new_parent)
Change this to be a child of new_parent.
task * execute() __TBB_override
Should be overridden by derived classes.
void internal_add_copy(const Item &item) __TBB_override
#define __TBB_TASK_GROUP_CONTEXT
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
do_iteration_task_iter(const Iterator &iter, feeder_type &feeder)
void internal_add_copy_impl(std::true_type, const Item &item)
void spawn_and_wait_for_all(task &child)
Similar to spawn followed by wait_for_all, but more efficient.
internal::allocate_child_proxy & allocate_child()
Returns proxy for overloaded new that allocates a child task of *this.
do_iteration_task(Item &&value, feeder_type &feeder)
void set_ref_count(int count)
Set reference count.
parallel_do_feeder_impl< Body, Item > feeder_type
task * run(std::random_access_iterator_tag *)
task * run_for_random_access_iterator()
static internal::allocate_root_proxy allocate_root()
Returns proxy for overloaded new that allocates a root task.
parallel_do_feeder< Item > Feeder