17 #ifndef __TBB_parallel_do_H 18 #define __TBB_parallel_do_H 27 namespace interface9 {
36 template<
typename Item>
41 virtual void internal_add_copy(
const Item& item ) = 0;
42 #if __TBB_CPP11_RVALUE_REF_PRESENT 43 virtual void internal_add_move( Item&& item ) = 0;
45 template<
typename Body_,
typename Item_>
friend class internal::parallel_do_feeder_impl;
48 void add(
const Item& item ) {internal_add_copy(item);}
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>
101 my_value(value), my_feeder(feeder)
104 #if __TBB_CPP11_RVALUE_REF_PRESENT 119 template<
typename Iterator,
typename Body,
typename Item>
128 my_iter(iter), my_feeder(feeder)
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);
186 __TBB_ASSERT(my_barrier,
"root task allocation failed");
189 #if __TBB_TASK_GROUP_CONTEXT 193 __TBB_ASSERT(my_barrier,
"root task allocation failed");
199 my_barrier->destroy(*my_barrier);
208 template<
typename Iterator,
typename Body,
typename Item>
211 static const size_t max_arg_size = 4;
220 : my_feeder(feeder), my_first(first), my_size(size)
231 t =
new( allocate_child() ) iteration_type( my_first, my_feeder );
233 if( ++k==my_size )
break;
236 set_ref_count(
int(k+1));
238 spawn_and_wait_for_all(*t);
242 template<
typename Iterator_,
typename Body_,
typename _Item>
friend class do_task_iter;
245 template<
typename Body,
typename Item>
248 static const size_t max_arg_size = 4;
257 : my_feeder(feeder), my_size(0)
262 #if __TBB_CPP11_RVALUE_REF_PRESENT 263 typedef std::move_iterator<Item*> Item_iterator;
265 typedef Item* Item_iterator;
273 t =
new( allocate_child() ) iteration_type( Item_iterator(my_arg.
begin() + k), my_feeder );
274 if( ++k==my_size )
break;
277 set_ref_count(
int(k+1));
279 spawn_and_wait_for_all(*t);
284 for(
size_t k=0; k<my_size; ++k)
285 (my_arg.
begin() + k)->~Item();
288 template<
typename Iterator_,
typename Body_,
typename Item_>
friend class do_task_iter;
294 template<
typename Iterator,
typename Body,
typename Item>
301 my_first(first), my_last(last), my_feeder(feeder)
321 typedef typename std::iterator_traits<Iterator>::iterator_category iterator_tag;
322 return run( (iterator_tag*)NULL );
327 inline task*
run(
void* ) {
return run_for_input_iterator(); }
332 block_type& t = *
new( allocate_additional_child_of(*my_feeder.
my_barrier) ) block_type(my_feeder);
334 while( !(my_first == my_last) ) {
336 new (t.my_arg.begin() + k) Item(*my_first);
338 if( ++k==block_type::max_arg_size ) {
339 if ( !(my_first == my_last) )
340 recycle_to_reexecute();
353 inline task*
run( std::forward_iterator_tag* ) {
return run_for_forward_iterator(); }
358 Iterator
first = my_first;
360 while( !(my_first==my_last) ) {
362 if( ++k==block_type::max_arg_size ) {
363 if ( !(my_first==my_last) )
364 recycle_to_reexecute();
368 return k==0 ? NULL :
new( allocate_additional_child_of(*my_feeder.
my_barrier) ) block_type(first, k, my_feeder);
371 inline task*
run( std::random_access_iterator_tag* ) {
return run_for_random_access_iterator(); }
377 size_t k =
static_cast<size_t>(my_last-my_first);
378 if( k > block_type::max_arg_size ) {
379 Iterator middle = my_first + k/2;
383 recycle_as_child_of(c);
394 t =
new( allocate_child() ) iteration_type(my_first, my_feeder);
399 set_ref_count(
int(k+1));
401 spawn_and_wait_for_all(*t);
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>
494 void parallel_do( Iterator first, Iterator last,
const Body& 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 void parallel_do(Iterator first, Iterator last, const Body &body)
Parallel iteration over a range, with optional addition of more work.
task * execute() __TBB_override
Should be overridden by derived classes.
void set_ref_count(int count)
Set reference count.
parallel_do_feeder< Item > Feeder
void select_parallel_do(Iterator first, Iterator last, const Body &body, void(Body::*)(Item) const, task_group_context &context)
For internal use only.
parallel_do_feeder_impl< Body, Item > feeder_type
task * execute() __TBB_override
Should be overridden by derived classes.
virtual ~parallel_do_feeder()
task * execute() __TBB_override
Should be overridden by derived classes.
auto last(Container &c) -> decltype(begin(c))
bool_constant< false > false_type
parallel_do_feeder_impl< Body, Item > feeder_type
parallel_do_feeder_impl< Body, Item > feeder_type
static void call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2)
static internal::allocate_root_proxy allocate_root()
Returns proxy for overloaded new that allocates a root task.
aligned_space< Item, max_arg_size > my_arg
do_task_iter(Iterator first, Iterator last, feeder_type &feeder)
~parallel_do_feeder_impl()
task * run_for_input_iterator()
auto first(Container &c) -> decltype(begin(c))
void add(const Item &item)
Add a work item to a running parallel_do.
void internal_add_copy_impl(std::false_type, const Item &)
parallel_do_feeder_impl(tbb::task_group_context &context)
void push_back(task &task)
Push task onto back of list.
internal::allocate_child_proxy & allocate_child()
Returns proxy for overloaded new that allocates a child task of *this.
void internal_add_move(Item &&item) __TBB_override
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2, void(Body::*)(CvItem, parallel_do_feeder< Item > &) const)
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &, void(Body::*)(CvItem &) const)
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
do_group_task_input(feeder_type &feeder)
Class the user supplied algorithm body uses to add new tasks.
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
do_group_task_forward(Iterator first, size_t size, feeder_type &feeder)
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &, void(Body::*)(CvItem) const)
void move(tbb_thread &t1, tbb_thread &t2)
#define __TBB_TASK_GROUP_CONTEXT
task * execute() __TBB_override
Should be overridden by derived classes.
task that does nothing. Useful for synchronization.
#define __TBB_FORWARDING_REF(A)
Used to form groups of tasks.
task * run(std::forward_iterator_tag *)
T * begin() const
Pointer to beginning of array.
static void internal_call(const Body &obj, __TBB_FORWARDING_REF(A1) arg1, A2 &arg2, void(Body::*)(CvItem &, parallel_do_feeder< Item > &) const)
task * run_for_forward_iterator()
void run_parallel_do(Iterator first, Iterator last, const Body &body, task_group_context &context)
For internal use only.
Base class for types that should not be copied or assigned.
task * run_for_random_access_iterator()
Base class for user-defined tasks.
do_iteration_task(Item &&value, feeder_type &feeder)
do_iteration_task(const Item &value, feeder_type &feeder)
do_iteration_task_iter(const Iterator &iter, feeder_type &feeder)
parallel_do_feeder_impl< Body, Item > feeder_type
parallel_do_feeder_impl< Body, Item > feeder_type
task * execute() __TBB_override
Should be overridden by derived classes.
parallel_do_feeder_impl()
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
void internal_add_copy_impl(std::true_type, const Item &item)
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
task * run(std::random_access_iterator_tag *)
void internal_add_copy(const Item &item) __TBB_override
bool_constant< true > true_type