#include <flow_graph.h>
Inheritance diagram for tbb::flow::interface6::continue_receiver:
Public Types | |
| typedef continue_msg | input_type |
| The input type. | |
| typedef sender< continue_msg > | predecessor_type |
| The predecessor type for this node. | |
Public Member Functions | |
| continue_receiver (int number_of_predecessors=0) | |
| Constructor. | |
| continue_receiver (const continue_receiver &src) | |
| Copy constructor. | |
| virtual | ~continue_receiver () |
| Destructor. | |
| bool | register_predecessor (predecessor_type &) |
| Increments the trigger threshold. | |
| bool | remove_predecessor (predecessor_type &) |
| Decrements the trigger threshold. | |
| bool | try_put (const input_type &) |
| Puts a continue_msg to the receiver. | |
Protected Member Functions | |
| virtual void | execute ()=0 |
| Does whatever should happen when the threshold is reached. | |
Protected Attributes | |
| spin_mutex | my_mutex |
| int | my_predecessor_count |
| int | my_current_count |
| int | my_initial_predecessor_count |
These receivers automatically reset, but cannot be explicitly waited on
| virtual void tbb::flow::interface6::continue_receiver::execute | ( | ) | [protected, pure 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().
| bool tbb::flow::interface6::continue_receiver::remove_predecessor | ( | predecessor_type & | ) | [inline] |
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.
| bool tbb::flow::interface6::continue_receiver::try_put | ( | const input_type & | ) | [inline] |
Puts a continue_msg to the receiver.
If the message causes the message count to reach the predecessor count, execute() is called and the message count is reset to 0. Otherwise the message count is incremented.