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 Member Functions | |
template<typename Body > | |
function_input (graph &g, size_t max_concurrency,) | |
function_input (const function_input &src) | |
Copy constructor. More... | |
~function_input () | |
template<typename Body > | |
Body | copy_function_object () |
output_type | apply_body_impl (const input_type &i) |
task * | apply_body_impl_bypass (const input_type &i) |
![]() | |
__TBB_STATIC_ASSERT (!((internal::has_policy< queueing, Policy >::value) &&(internal::has_policy< rejecting, Policy >::value)), "queueing and rejecting policies can't be specified simultaneously") | |
function_input_base (graph &g, __TBB_FLOW_GRAPH_PRIORITY_ARG1(size_t max_concurrency, node_priority_t priority)) | |
Constructor for function_input_base. More... | |
function_input_base (const function_input_base &src) | |
Copy constructor. More... | |
virtual | ~function_input_base () |
Destructor. More... | |
task * | try_put_task (const input_type &t) __TBB_override |
Put item to successor; return task to run the successor if possible. More... | |
bool | register_predecessor (predecessor_type &src) __TBB_override |
Adds src to the list of cached predecessors. More... | |
bool | remove_predecessor (predecessor_type &src) __TBB_override |
Removes src from the list of cached predecessors. More... | |
![]() | |
bool | try_put (const typename internal::async_helpers< Input >::filtered_type &t) |
Put an item to the receiver. More... | |
bool | try_put (const typename internal::async_helpers< Input >::async_type &t) |
![]() | |
virtual | ~untyped_receiver () |
Destructor. More... | |
template<typename X > | |
bool | try_put (const X &t) |
Put an item to the receiver. More... | |
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 () __TBB_override |
task * | try_get_postponed_task (const input_type &i) |
![]() | |
virtual task * | try_put_task_wrapper (const void *p, bool is_async) __TBB_override |
![]() | |
template<typename X > | |
task * | try_put_task (const X &t) |
virtual void | reset_receiver (reset_flags f=rf_reset_protocol)=0 |
put receiver back in initial state More... | |
virtual bool | is_continue_receiver () |
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 |
Copy constructor.
Definition at line 441 of file _flow_graph_node_impl.h.
|
inline |
Definition at line 447 of file _flow_graph_node_impl.h.
|
inline |
Definition at line 458 of file _flow_graph_node_impl.h.
References tbb::internal::fgt_begin_body(), and tbb::internal::fgt_end_body().
|
inline |
Definition at line 468 of file _flow_graph_node_impl.h.
References __TBB_ASSERT, tbb::flow::interface10::combine_tasks(), tbb::flow::interface10::internal::spawn_in_graph_arena(), tbb::flow::internal::SUCCESSFULLY_ENQUEUED, and task.
|
inline |
Definition at line 453 of file _flow_graph_node_impl.h.
|
inlineprotected |
Definition at line 508 of file _flow_graph_node_impl.h.
References tbb::flow::interface10::rf_reset_bodies.
|
protectedpure virtual |
|
protected |
Definition at line 517 of file _flow_graph_node_impl.h.
|
protected |
Definition at line 518 of file _flow_graph_node_impl.h.