Intel(R) Threading Building Blocks Doxygen Documentation
version 4.2.3
|
Base class for receivers of completion messages. More...
#include <flow_graph.h>
Public Member Functions | |
__TBB_DEPRECATED | continue_receiver (__TBB_FLOW_GRAPH_PRIORITY_ARG1(int number_of_predecessors, node_priority_t priority)) |
Constructor. More... | |
__TBB_DEPRECATED | continue_receiver (const continue_receiver &src) |
Copy constructor. More... | |
__TBB_DEPRECATED bool | register_predecessor (predecessor_type &) __TBB_override |
Increments the trigger threshold. More... | |
__TBB_DEPRECATED bool | remove_predecessor (predecessor_type &) __TBB_override |
Decrements the trigger threshold. More... | |
![]() | |
virtual | ~receiver () |
Destructor. More... | |
bool | try_put (const continue_msg &t) |
Put an item to the receiver. More... | |
Public Attributes | |
__TBB_DEPRECATED typedef continue_msg | input_type |
The input type. More... | |
__TBB_DEPRECATED typedef receiver< input_type >::predecessor_type | predecessor_type |
The predecessor type for this node. More... | |
![]() | |
__TBB_DEPRECATED typedef continue_msg | input_type |
The input type of this receiver. More... | |
__TBB_DEPRECATED typedef sender< continue_msg > | predecessor_type |
The predecessor type for this node. More... | |
Protected Member Functions | |
task * | try_put_task (const input_type &) __TBB_override |
void | reset_receiver (reset_flags f) __TBB_override |
put receiver back in initial state More... | |
virtual task * | execute ()=0 |
Does whatever should happen when the threshold is reached. More... | |
bool | is_continue_receiver () __TBB_override |
![]() | |
virtual task * | try_put_task (const continue_msg &t)=0 |
virtual graph & | graph_reference () const=0 |
Protected Attributes | |
spin_mutex | my_mutex |
int | my_predecessor_count |
int | my_current_count |
int | my_initial_predecessor_count |
Friends | |
template<typename R , typename B > | |
class | run_and_put_task |
template<typename X , typename Y > | |
class | internal::broadcast_cache |
template<typename X , typename Y > | |
class | internal::round_robin_cache |
template<typename U , typename V > | |
class | tbb::flow::interface11::limiter_node |
template<typename TT , typename M > | |
class | internal::successor_cache |
Base class for receivers of completion messages.
These receivers automatically reset, but cannot be explicitly waited on
Definition at line 598 of file flow_graph.h.
|
inlineexplicit |
Constructor.
Definition at line 608 of file flow_graph.h.
References __TBB_FLOW_GRAPH_PRIORITY_EXPR, my_current_count, my_initial_predecessor_count, and my_predecessor_count.
|
inline |
Copy constructor.
Definition at line 616 of file flow_graph.h.
References __TBB_FLOW_GRAPH_PRIORITY_EXPR, my_current_count, my_initial_predecessor_count, and my_predecessor_count.
|
protectedpure virtual |
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().
Referenced by try_put_task().
|
inlineprotectedvirtual |
Reimplemented from tbb::flow::interface11::receiver< continue_msg >.
Definition at line 712 of file flow_graph.h.
|
inlinevirtual |
Increments the trigger threshold.
Reimplemented from tbb::flow::interface11::receiver< continue_msg >.
Definition at line 623 of file flow_graph.h.
References my_mutex, and my_predecessor_count.
|
inlinevirtual |
Decrements the trigger threshold.
Does not check to see if the removal of the predecessor now makes the current count exceed the new threshold. So removing a predecessor while the graph is active can cause unexpected results.
Reimplemented from tbb::flow::interface11::receiver< continue_msg >.
Definition at line 633 of file flow_graph.h.
References my_mutex, and my_predecessor_count.
|
inlineprotectedvirtual |
put receiver back in initial state
Implements tbb::flow::interface11::receiver< continue_msg >.
Definition at line 697 of file flow_graph.h.
References my_current_count, my_initial_predecessor_count, my_predecessor_count, and tbb::flow::interface11::rf_clear_edges.
|
inlineprotected |
Definition at line 671 of file flow_graph.h.
References execute(), my_current_count, my_mutex, my_predecessor_count, and tbb::flow::internal::SUCCESSFULLY_ENQUEUED.
|
friend |
Definition at line 668 of file flow_graph.h.
|
friend |
Definition at line 669 of file flow_graph.h.
|
friend |
Definition at line 711 of file flow_graph.h.
|
friend |
Definition at line 667 of file flow_graph.h.
|
friend |
Definition at line 695 of file flow_graph.h.
__TBB_DEPRECATED typedef continue_msg tbb::flow::interface11::continue_receiver::input_type |
The input type.
Definition at line 602 of file flow_graph.h.
|
protected |
Definition at line 690 of file flow_graph.h.
Referenced by continue_receiver(), reset_receiver(), and try_put_task().
|
protected |
Definition at line 691 of file flow_graph.h.
Referenced by continue_receiver(), and reset_receiver().
|
protected |
Definition at line 688 of file flow_graph.h.
Referenced by register_predecessor(), remove_predecessor(), and try_put_task().
|
protected |
Definition at line 689 of file flow_graph.h.
Referenced by continue_receiver(), register_predecessor(), remove_predecessor(), reset_receiver(), and try_put_task().
__TBB_DEPRECATED typedef receiver<input_type>::predecessor_type tbb::flow::interface11::continue_receiver::predecessor_type |
The predecessor type for this node.
Definition at line 605 of file flow_graph.h.