17 #ifndef __TBB_pipeline_H 18 #define __TBB_pipeline_H 20 #define __TBB_pipeline_H_include_area 28 #if __TBB_CPP11_TYPE_PROPERTIES_PRESENT 29 #include <type_traits> 41 #define __TBB_PIPELINE_VERSION(x) ((unsigned char)(x-2)<<1) 52 namespace interface6 {
53 template<
typename T,
typename U>
class filter_t;
70 static const unsigned char filter_is_serial = 0x1;
75 static const unsigned char filter_is_out_of_order = 0x1<<4;
78 static const unsigned char filter_is_bound = 0x1<<5;
81 static const unsigned char filter_may_emit_null = 0x1<<6;
84 static const unsigned char exact_exception_propagation =
85 #if TBB_USE_CAPTURED_EXCEPTION 92 static const unsigned char version_mask = 0x7<<1;
96 parallel = current_version | filter_is_out_of_order,
98 serial_in_order = current_version | filter_is_serial,
100 serial_out_of_order = current_version | filter_is_serial | filter_is_out_of_order,
106 next_filter_in_pipeline(not_in_pipeline()),
107 my_input_buffer(NULL),
108 my_filter_mode(static_cast<unsigned char>((is_serial_ ?
serial : parallel) | exact_exception_propagation)),
109 prev_filter_in_pipeline(not_in_pipeline()),
115 next_filter_in_pipeline(not_in_pipeline()),
116 my_input_buffer(NULL),
117 my_filter_mode(static_cast<unsigned char>(filter_mode | exact_exception_propagation)),
118 prev_filter_in_pipeline(not_in_pipeline()),
129 return bool( my_filter_mode & filter_is_serial );
134 return (my_filter_mode & (filter_is_out_of_order|filter_is_serial))==filter_is_serial;
139 return ( my_filter_mode & filter_is_bound )==filter_is_bound;
144 return ( my_filter_mode & filter_may_emit_null ) == filter_may_emit_null;
149 virtual void* operator()(
void* item ) = 0;
155 #if __TBB_TASK_GROUP_CONTEXT 169 bool has_more_work();
177 friend class pipeline;
230 result_type internal_process_item(
bool is_blocking);
250 #if __TBB_TASK_GROUP_CONTEXT 276 atomic<internal::Token> input_tokens;
279 atomic<internal::Token> token_counter;
285 bool has_thread_bound_filters;
288 void remove_filter(
filter& filter_ );
293 #if __TBB_TASK_GROUP_CONTEXT 294 void clear_filters();
303 namespace interface6 {
315 void stop() { is_pipeline_stopped =
true; }
322 #if __TBB_CPP11_TYPE_PROPERTIES_PRESENT 342 #if !_MSC_VER || defined(_NATIVE_WCHAR_T_DEFINED) 345 #endif // tbb_trivially_copyable 363 #if __TBB_CPP11_RVALUE_REF_PRESENT 366 static pointer create_token(
const value_type & source)
369 pointer output_t = allocator().allocate(1);
372 static value_type &
token(pointer & t) {
return *t; }
376 allocator().destroy(token);
377 allocator().deallocate(token,1);
387 static pointer
create_token(
const value_type & source) {
return source; }
388 static value_type &
token(pointer & t) {
return t; }
400 } type_to_void_ptr_map;
404 static pointer
create_token(
const value_type & source) {
return source; }
405 static value_type &
token(pointer & t) {
return t; }
407 type_to_void_ptr_map mymap;
408 mymap.void_overlay = NULL;
409 mymap.actual_value = ref;
410 return mymap.void_overlay;
413 type_to_void_ptr_map mymap;
414 mymap.void_overlay = ref;
415 return mymap.actual_value;
421 template<
typename T,
typename U,
typename Body>
430 t_pointer temp_input = t_helper::cast_from_void_ptr(input);
431 u_pointer output_u = u_helper::create_token(my_body(
tbb::internal::move(t_helper::token(temp_input))));
432 t_helper::destroy_token(temp_input);
433 return u_helper::cast_to_void_ptr(output_u);
437 t_pointer temp_input = t_helper::cast_from_void_ptr(input);
438 t_helper::destroy_token(temp_input);
446 template<
typename U,
typename Body>
454 u_pointer output_u = u_helper::create_token(my_body(control));
456 u_helper::destroy_token(output_u);
460 return u_helper::cast_to_void_ptr(output_u);
471 template<
typename T,
typename Body>
478 t_pointer temp_input = t_helper::cast_from_void_ptr(input);
480 t_helper::destroy_token(temp_input);
484 t_pointer temp_input = t_helper::cast_from_void_ptr(input);
485 t_helper::destroy_token(temp_input);
492 template<
typename Body>
513 while(
filter* f = my_pipe.filter_list )
527 #ifdef __TBB_TEST_FILTER_NODE_COUNT 528 ++(__TBB_TEST_FILTER_NODE_COUNT);
533 virtual void add_to( pipeline& ) = 0;
543 #ifdef __TBB_TEST_FILTER_NODE_COUNT 544 --(__TBB_TEST_FILTER_NODE_COUNT);
550 template<
typename T,
typename U,
typename Body>
586 template<
typename T,
typename U,
typename Body>
591 template<
typename T,
typename V,
typename U>
593 __TBB_ASSERT(left.
root,
"cannot use default-constructed filter_t as left argument of '&'");
594 __TBB_ASSERT(right.
root,
"cannot use default-constructed filter_t as right argument of '&'");
599 template<
typename T,
typename U>
607 template<
typename T_,
typename U_,
typename Body>
609 template<
typename T_,
typename V_,
typename U_>
617 template<
typename Body>
619 root( new
internal::filter_node_leaf<T,U,Body>(mode, body) ) {
626 filter_node* old = root;
637 filter_node* old = root;
645 __TBB_ASSERT( filter_chain.
root,
"cannot apply parallel_pipeline to default-constructed filter_t" );
656 pipe->run(max_number_of_live_tokens
657 #
if __TBB_TASK_GROUP_CONTEXT
663 #if __TBB_TASK_GROUP_CONTEXT 668 #endif // __TBB_TASK_GROUP_CONTEXT 680 #undef __TBB_pipeline_H_include_area static pointer cast_from_void_ptr(void *ref)
static pointer cast_from_void_ptr(void *ref)
static value_type & token(pointer &t)
Node in parse tree representing join of two filters.
void add_ref()
Increment reference count.
The class that represents an object of the pipeline for parallel_pipeline().
static pointer create_token(value_type &&source)
tbb::atomic< intptr_t > ref_count
#define __TBB_TASK_GROUP_CONTEXT
void * operator()(void *) __TBB_override
Operate on an item from the input stream, and return item for output stream.
filter_node_leaf(tbb::filter::mode m, const Body &b)
internal::filter_node filter_node
filter_t(tbb::filter::mode mode, const Body &body)
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 size_t void ITT_FORMAT p const __itt_domain __itt_id __itt_string_handle const wchar_t size_t ITT_FORMAT lu const __itt_domain __itt_id __itt_relation __itt_id ITT_FORMAT p const wchar_t int ITT_FORMAT __itt_group_mark d int
concrete_filter(tbb::filter::mode filter_mode, const Body &body)
void add_to(pipeline &p) __TBB_override
Add concrete_filter to pipeline.
bool is_ordered() const
True if filter must receive stream in order.
void parallel_pipeline(size_t max_number_of_live_tokens, const filter_t< void, void > &filter_chain)
#define __TBB_PIPELINE_VERSION(x)
filter_t(filter_node *root_)
virtual void finalize(void *)
Destroys item if pipeline was cancelled.
tbb::pipeline * operator->()
Base class for types that should not be copied or assigned.
filter_t< T, U > make_filter(tbb::filter::mode mode, const Body &body)
Create a filter to participate in parallel_pipeline.
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 mode
void parallel_pipeline(size_t max_number_of_live_tokens, const filter_t< void, void > &filter_chain, tbb::task_group_context &context)
filter_node_join(filter_node &x, filter_node &y)
static value_type & token(pointer &t)
filter_t(const filter_t< T, U > &rhs)
static void * cast_to_void_ptr(pointer ref)
token_helper< U, use_allocator< U >::value > u_helper
void add_to(pipeline &p) __TBB_override
Add concrete_filter to pipeline.
class __TBB_DEPRECATED_MSG("tbb::tbb_hash is deprecated, use std::hash") tbb_hash
bool is_serial() const
True if filter is serial.
void finalize(void *input) __TBB_override
Destroys item if pipeline was cancelled.
static pointer create_token(const value_type &source)
token_helper< T, use_allocator< T >::value > t_helper
void operator=(const filter_t< T, U > &rhs)
bool object_may_be_null()
true if an input filter can emit null
internal::input_buffer * my_input_buffer
Buffer for incoming tokens, or NULL if not required.
filter * prev_filter_in_pipeline
Pointer to previous filter in the pipeline.
concrete_filter(tbb::filter::mode filter_mode, const Body &body)
static void * cast_to_void_ptr(pointer ref)
static filter * not_in_pipeline()
Value used to mark "not in pipeline".
static void destroy_token(pointer)
void move(tbb_thread &t1, tbb_thread &t2)
bool is_bound() const
True if filter is thread-bound.
t_helper::pointer t_pointer
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
input_filter control to signal end-of-input for parallel_pipeline
token_helper< U, use_allocator< U >::value > u_helper
const tbb::filter::mode mode
static void * cast_to_void_ptr(pointer ref)
tbb::tbb_allocator< T > allocator
token_helper< T, use_allocator< T >::value > t_helper
t_helper::pointer t_pointer
static void destroy_token(pointer token)
static pointer cast_from_void_ptr(void *ref)
static pointer create_token(const value_type &source)
Node in parse tree representing result of make_filter.
concrete_filter(tbb::filter::mode filter_mode, const Body &body)
filter * next_filter_in_pipeline
Pointer to next filter in the pipeline.
A buffer of input items for a filter.
filter * next_segment
Pointer to the next "segment" of filters, or NULL if not required.
void finalize(void *input) __TBB_override
Destroys item if pipeline was cancelled.
#define __TBB_EXPORTED_METHOD
Used to form groups of tasks.
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
u_helper::pointer u_pointer
Meets "allocator" requirements of ISO C++ Standard, Section 20.1.5.
pipeline * my_pipeline
Pointer to the pipeline.
Class representing a chain of type-safe pipeline filters.
virtual void add_to(pipeline &)=0
Add concrete_filter to pipeline.
const unsigned char my_filter_mode
Storage for filter mode and dynamically checked implementation version.
filter_t< T, U > operator &(const filter_t< T, V > &left, const filter_t< V, U > &right)
static value_type & token(pointer &t)
u_helper::pointer u_pointer
void const char const char int ITT_FORMAT __itt_group_sync p
void * operator()(void *input) __TBB_override
Operate on an item from the input stream, and return item for output stream.
thread_bound_filter(mode filter_mode)
void * operator()(void *input) __TBB_override
Operate on an item from the input stream, and return item for output stream.
concrete_filter(filter::mode filter_mode, const Body &body)
Base class for user-defined tasks.
Abstract base class that represents a node in a parse tree underlying a filter_t. ...
static const unsigned char filter_is_serial
The lowest bit 0 is for parallel vs. serial.
void * operator()(void *) __TBB_override
Operate on an item from the input stream, and return item for output stream.
static void destroy_token(pointer)
A stage in a pipeline served by a user thread.
void remove_ref()
Decrement reference count and delete if it becomes zero.