Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface11::internal::decrementer< T, continue_msg, void > Class Template Reference

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface11::internal::decrementer< T, continue_msg, void >:
Collaboration diagram for tbb::flow::interface11::internal::decrementer< T, continue_msg, void >:

Public Types

typedef continue_msg input_type
 
typedef continue_msg output_type
 
- Public Types inherited from tbb::flow::interface11::internal::untyped_receiver
typedef untyped_sender predecessor_type
 The predecessor type for this node. More...
 

Public Member Functions

 decrementer (int number_of_predecessors=0)
 
void set_owner (T *node)
 
- Public Member Functions inherited from tbb::flow::interface11::continue_receiver
__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...
 
- Public Member Functions inherited from tbb::flow::interface11::receiver< continue_msg >
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)
 
- Public Member Functions inherited from tbb::flow::interface11::internal::untyped_receiver
virtual ~untyped_receiver ()
 Destructor. More...
 
template<typename X >
bool try_put (const X &t)
 Put an item to the receiver. More...
 

Protected Member Functions

graphgraph_reference () const __TBB_override
 
- Protected Member Functions inherited from tbb::flow::interface11::continue_receiver
tasktry_put_task (const input_type &) __TBB_override
 
void reset_receiver (reset_flags f) __TBB_override
 put receiver back in initial state More...
 
bool is_continue_receiver () __TBB_override
 
- Protected Member Functions inherited from tbb::flow::interface11::receiver< continue_msg >
virtual tasktry_put_task_wrapper (const void *p, bool is_async) __TBB_override
 
virtual tasktry_put_task (const continue_msg &t)=0
 Put item to successor; return task to run the successor if possible. More...
 
- Protected Member Functions inherited from tbb::flow::interface11::internal::untyped_receiver
template<typename X >
tasktry_put_task (const X &t)
 

Private Member Functions

taskexecute () __TBB_override
 Does whatever should happen when the threshold is reached. More...
 
- Private Member Functions inherited from tbb::internal::no_copy
 no_copy (const no_copy &)=delete
 
 no_copy ()=default
 

Private Attributes

T * my_node
 

Additional Inherited Members

- Public Attributes inherited from tbb::flow::interface11::continue_receiver
__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...
 
- Public Attributes inherited from tbb::flow::interface11::receiver< continue_msg >
__TBB_DEPRECATED typedef continue_msg input_type
 The input type of this receiver. More...
 
__TBB_DEPRECATED typedef internal::async_helpers< continue_msg >::filtered_type filtered_type
 
- Protected Attributes inherited from tbb::flow::interface11::continue_receiver
spin_mutex my_mutex
 
int my_predecessor_count
 
int my_current_count
 
int my_initial_predecessor_count
 

Detailed Description

template<typename T>
class tbb::flow::interface11::internal::decrementer< T, continue_msg, void >

Definition at line 417 of file flow_graph.h.

Member Typedef Documentation

◆ input_type

Definition at line 433 of file flow_graph.h.

◆ output_type

Definition at line 434 of file flow_graph.h.

Constructor & Destructor Documentation

◆ decrementer()

template<typename T >
tbb::flow::interface11::internal::decrementer< T, continue_msg, void >::decrementer ( int  number_of_predecessors = 0)
inline

Definition at line 435 of file flow_graph.h.

441  {
442  // Both async OR both are NOT async
443  if ( internal::async_helpers<T>::is_async_type == is_async ) {

Member Function Documentation

◆ execute()

template<typename T >
task* tbb::flow::interface11::internal::decrementer< T, continue_msg, void >::execute ( )
inlineprivatevirtual

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::interface11::continue_receiver.

Definition at line 421 of file flow_graph.h.

425  { return false; }

◆ graph_reference()

template<typename T >
graph& tbb::flow::interface11::internal::decrementer< T, continue_msg, void >::graph_reference ( ) const
inlineprotectedvirtual

Implements tbb::flow::interface11::internal::untyped_receiver.

Definition at line 427 of file flow_graph.h.

428  { return false; }
429 

◆ set_owner()

template<typename T >
void tbb::flow::interface11::internal::decrementer< T, continue_msg, void >::set_owner ( T *  node)
inline

Definition at line 444 of file flow_graph.h.

454 : public internal::untyped_receiver {

Member Data Documentation

◆ my_node

template<typename T >
T* tbb::flow::interface11::internal::decrementer< T, continue_msg, void >::my_node
private

Definition at line 419 of file flow_graph.h.


The documentation for this class was generated from the following file:

Copyright © 2005-2020 Intel Corporation. All Rights Reserved.

Intel, Pentium, Intel Xeon, Itanium, Intel XScale and VTune are registered trademarks or trademarks of Intel Corporation or its subsidiaries in the United States and other countries.

* Other names and brands may be claimed as the property of others.