Intel(R) Threading Building Blocks Doxygen Documentation
version 4.2.3
|
Implements methods for an executable node that takes continue_msg as input. More...
#include <flow_graph.h>
Public Types | |
typedef continue_msg | input_type |
The input type of this receiver. More... | |
typedef Output | output_type |
The output type of this receiver. More... | |
typedef function_body< input_type, output_type > | function_body_type |
typedef continue_input< output_type, Policy > | class_type |
![]() | |
typedef continue_msg | input_type |
The input type. More... | |
typedef receiver< input_type >::predecessor_type | predecessor_type |
The predecessor type for this node. More... | |
![]() | |
typedef continue_msg | input_type |
The input type of this receiver. More... | |
typedef internal::async_helpers< continue_msg >::filtered_type | filtered_type |
![]() | |
typedef untyped_sender | predecessor_type |
The predecessor type for this node. More... | |
Public Member Functions | |
template<typename Body > | |
continue_input (graph &g, __TBB_FLOW_GRAPH_PRIORITY_ARG1(Body &body, node_priority_t priority)) | |
template<typename Body > | |
continue_input (graph &g, int number_of_predecessors,) | |
continue_input (const continue_input &src) | |
~continue_input () | |
template<typename Body > | |
Body | copy_function_object () |
void | reset_receiver (reset_flags f) __TBB_override |
put receiver back in initial state More... | |
![]() | |
continue_receiver (__TBB_FLOW_GRAPH_PRIORITY_ARG1(int number_of_predecessors, node_priority_t priority)) | |
Constructor. More... | |
continue_receiver (const continue_receiver &src) | |
Copy constructor. More... | |
bool | register_predecessor (predecessor_type &) __TBB_override |
Increments the trigger threshold. More... | |
bool | remove_predecessor (predecessor_type &) __TBB_override |
Decrements the trigger threshold. More... | |
![]() | |
bool | try_put (const typename internal::async_helpers< continue_msg >::filtered_type &t) |
Put an item to the receiver. More... | |
bool | try_put (const typename internal::async_helpers< continue_msg >::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 | |
virtual broadcast_cache< output_type > & | successors ()=0 |
task * | apply_body_bypass (input_type) |
Applies the body to the provided input. More... | |
task * | execute () __TBB_override |
Does whatever should happen when the threshold is reached. More... | |
graph & | graph_reference () __TBB_override |
![]() | |
task * | try_put_task (const input_type &) __TBB_override |
Put item to successor; return task to run the successor if possible. More... | |
bool | is_continue_receiver () __TBB_override |
![]() | |
virtual task * | try_put_task_wrapper (const void *p, bool is_async) __TBB_override |
![]() | |
template<typename X > | |
task * | try_put_task (const X &t) |
Protected Attributes | |
graph & | my_graph_ref |
function_body_type * | my_body |
function_body_type * | my_init_body |
![]() | |
spin_mutex | my_mutex |
int | my_predecessor_count |
int | my_current_count |
int | my_initial_predecessor_count |
Friends | |
class | apply_body_task_bypass< class_type, continue_msg > |
Implements methods for an executable node that takes continue_msg as input.
Definition at line 678 of file flow_graph.h.
typedef continue_input<output_type, Policy> tbb::flow::interface10::internal::continue_input< Output, Policy >::class_type |
Definition at line 687 of file flow_graph.h.
typedef function_body<input_type, output_type> tbb::flow::interface10::internal::continue_input< Output, Policy >::function_body_type |
Definition at line 686 of file flow_graph.h.
typedef continue_msg tbb::flow::interface10::internal::continue_input< Output, Policy >::input_type |
The input type of this receiver.
Definition at line 682 of file flow_graph.h.
typedef Output tbb::flow::interface10::internal::continue_input< Output, Policy >::output_type |
The output type of this receiver.
Definition at line 685 of file flow_graph.h.
|
inline |
Definition at line 690 of file flow_graph.h.
|
inline |
Definition at line 698 of file flow_graph.h.
|
inline |
Definition at line 706 of file flow_graph.h.
|
inline |
Definition at line 711 of file flow_graph.h.
|
inlineprotected |
Applies the body to the provided input.
Definition at line 742 of file flow_graph.h.
|
inline |
Definition at line 717 of file flow_graph.h.
|
inlineprotectedvirtual |
Does whatever should happen when the threshold is reached.
This should be very fast or else spawn a task. This is called while the sender is blocked in the try_put().
Implements tbb::flow::interface10::continue_receiver.
Definition at line 751 of file flow_graph.h.
|
inlineprotectedvirtual |
Implements tbb::flow::interface10::internal::untyped_receiver.
Definition at line 772 of file flow_graph.h.
|
inlinevirtual |
put receiver back in initial state
Reimplemented from tbb::flow::interface10::continue_receiver.
Definition at line 722 of file flow_graph.h.
|
protectedpure virtual |
Implemented in tbb::flow::interface10::continue_node< Output, Policy >.
|
friend |
Definition at line 739 of file flow_graph.h.
|
protected |
Definition at line 734 of file flow_graph.h.
|
protected |
Definition at line 733 of file flow_graph.h.
|
protected |
Definition at line 735 of file flow_graph.h.