Intel(R) Threading Building Blocks Doxygen Documentation
version 4.2.3
|
Implements methods for a function node that takes a type Input as input and sends. More...
#include <_flow_graph_node_impl.h>
Public Types | |
typedef Input | input_type |
typedef Output | output_type |
typedef function_body< input_type, output_type > | function_body_type |
typedef function_input< Input, Output, Policy, A > | my_class |
typedef function_input_base< Input, Policy, A, my_class > | base_type |
typedef function_input_queue< input_type, A > | input_queue_type |
![]() | |
typedef Input | input_type |
The input type of this receiver. More... | |
typedef receiver< input_type >::predecessor_type | predecessor_type |
typedef predecessor_cache< input_type, null_mutex > | predecessor_cache_type |
typedef function_input_queue< input_type, A > | input_queue_type |
typedef tbb::internal::allocator_rebind< A, input_queue_type >::type | queue_allocator_type |
Protected Member Functions | |
void | reset_function_input (reset_flags f) |
virtual broadcast_cache< output_type > & | successors ()=0 |
![]() | |
void | reset_function_input_base (reset_flags f) |
void | reset_receiver (reset_flags f) __TBB_override |
graph & | graph_reference () const __TBB_override |
task * | try_get_postponed_task (const input_type &i) |
Protected Attributes | |
function_body_type * | my_body |
function_body_type * | my_init_body |
![]() | |
graph & | my_graph_ref |
const size_t | my_max_concurrency |
size_t | my_concurrency |
input_queue_type * | my_queue |
predecessor_cache< input_type, null_mutex > | my_predecessors |
Implements methods for a function node that takes a type Input as input and sends.
Definition at line 421 of file _flow_graph_node_impl.h.
typedef function_input_base<Input, Policy, A, my_class> internal::function_input< Input, Output, Policy, A >::base_type |
Definition at line 427 of file _flow_graph_node_impl.h.
typedef function_body<input_type, output_type> internal::function_input< Input, Output, Policy, A >::function_body_type |
Definition at line 425 of file _flow_graph_node_impl.h.
typedef function_input_queue<input_type, A> internal::function_input< Input, Output, Policy, A >::input_queue_type |
Definition at line 428 of file _flow_graph_node_impl.h.
typedef Input internal::function_input< Input, Output, Policy, A >::input_type |
Definition at line 423 of file _flow_graph_node_impl.h.
typedef function_input<Input, Output, Policy,A> internal::function_input< Input, Output, Policy, A >::my_class |
Definition at line 426 of file _flow_graph_node_impl.h.
typedef Output internal::function_input< Input, Output, Policy, A >::output_type |
Definition at line 424 of file _flow_graph_node_impl.h.
|
inline |
Definition at line 432 of file _flow_graph_node_impl.h.
|
inline |
|
inline |
Definition at line 447 of file _flow_graph_node_impl.h.
References internal::function_input< Input, Output, Policy, A >::my_body, and internal::function_input< Input, Output, Policy, A >::my_init_body.
|
inline |
Definition at line 458 of file _flow_graph_node_impl.h.
References tbb::internal::fgt_begin_body(), tbb::internal::fgt_end_body(), and internal::function_input< Input, Output, Policy, A >::my_body.
Referenced by internal::function_input< Input, Output, Policy, A >::apply_body_impl_bypass().
|
inline |
Definition at line 468 of file _flow_graph_node_impl.h.
References __TBB_ASSERT, internal::function_input< Input, Output, Policy, A >::apply_body_impl(), tbb::flow::interface11::combine_tasks(), internal::function_input_base< Input, Policy, A, ImplType >::graph_reference(), internal::function_input_base< Input, Policy, A, ImplType >::my_graph_ref, internal::function_input_base< Input, Policy, A, ImplType >::my_max_concurrency, tbb::flow::interface11::internal::spawn_in_graph_arena(), tbb::flow::internal::SUCCESSFULLY_ENQUEUED, internal::function_input< Input, Output, Policy, A >::successors(), task, internal::function_input_base< Input, Policy, A, ImplType >::try_get_postponed_task(), and internal::broadcast_cache< T, M >::try_put_task().
|
inline |
Definition at line 453 of file _flow_graph_node_impl.h.
References internal::function_input< Input, Output, Policy, A >::my_body.
|
inlineprotected |
Definition at line 508 of file _flow_graph_node_impl.h.
References internal::function_body< Input, Output >::clone(), internal::function_input< Input, Output, Policy, A >::my_body, internal::function_input< Input, Output, Policy, A >::my_init_body, internal::function_input_base< Input, Policy, A, ImplType >::reset_function_input_base(), and tbb::flow::interface11::rf_reset_bodies.
Referenced by tbb::flow::interface11::function_node< Input, Output, Policy, Allocator >::reset_node().
|
protectedpure virtual |
Implemented in tbb::flow::interface11::function_node< Input, Output, Policy, Allocator >.
Referenced by internal::function_input< Input, Output, Policy, A >::apply_body_impl_bypass().
|
protected |
Definition at line 517 of file _flow_graph_node_impl.h.
Referenced by internal::function_input< Input, Output, Policy, A >::apply_body_impl(), internal::function_input< Input, Output, Policy, A >::copy_function_object(), internal::function_input< Input, Output, Policy, A >::reset_function_input(), and internal::function_input< Input, Output, Policy, A >::~function_input().
|
protected |
Definition at line 518 of file _flow_graph_node_impl.h.
Referenced by internal::function_input< Input, Output, Policy, A >::reset_function_input(), and internal::function_input< Input, Output, Policy, A >::~function_input().