#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. | |
Protected Member Functions | |
| task * | try_put_task (const input_type &) |
| void | reset_receiver () |
| virtual task * | execute ()=0 |
| Does whatever should happen when the threshold is reached. | |
| bool | is_continue_receiver () |
Protected Attributes | |
| spin_mutex | my_mutex |
| int | my_predecessor_count |
| int | my_current_count |
| int | my_initial_predecessor_count |
Friends | |
| class | run_and_put_task |
| put item to successor; return task to run the successor if possible. | |
| class | internal::broadcast_cache |
| class | internal::round_robin_cache |
| class | limiter_node |
| put receiver back in initial state | |
| class | internal::successor_cache |
These receivers automatically reset, but cannot be explicitly waited on
| virtual task* 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.