Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface10::internal::continue_input< Output, Policy > Class Template Referenceabstract

Implements methods for an executable node that takes continue_msg as input. More...

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface10::internal::continue_input< Output, Policy >:
Collaboration diagram for tbb::flow::interface10::internal::continue_input< Output, Policy >:

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_typefunction_body_type
 
typedef continue_input< output_type, Policyclass_type
 
- Public Types inherited from tbb::flow::interface10::continue_receiver
typedef continue_msg input_type
 The input type. More...
 
typedef receiver< input_type >::predecessor_type predecessor_type
 The predecessor type for this node. More...
 
- Public Types inherited from tbb::flow::interface10::receiver< continue_msg >
typedef continue_msg input_type
 The input type of this receiver. More...
 
typedef internal::async_helpers< continue_msg >::filtered_type filtered_type
 
- Public Types inherited from tbb::flow::interface10::internal::untyped_receiver
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...
 
- Public Member Functions inherited from tbb::flow::interface10::continue_receiver
 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...
 
- Public Member Functions inherited from tbb::flow::interface10::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::interface10::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

virtual broadcast_cache< output_type > & successors ()=0
 
taskapply_body_bypass (input_type)
 Applies the body to the provided input. More...
 
taskexecute () __TBB_override
 Does whatever should happen when the threshold is reached. More...
 
graphgraph_reference () __TBB_override
 
- Protected Member Functions inherited from tbb::flow::interface10::continue_receiver
tasktry_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
 
- Protected Member Functions inherited from tbb::flow::interface10::receiver< continue_msg >
virtual tasktry_put_task_wrapper (const void *p, bool is_async) __TBB_override
 
- Protected Member Functions inherited from tbb::flow::interface10::internal::untyped_receiver
template<typename X >
tasktry_put_task (const X &t)
 

Protected Attributes

graphmy_graph_ref
 
function_body_typemy_body
 
function_body_typemy_init_body
 
- Protected Attributes inherited from tbb::flow::interface10::continue_receiver
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 >
 

Detailed Description

template<typename Output, typename Policy>
class tbb::flow::interface10::internal::continue_input< Output, Policy >

Implements methods for an executable node that takes continue_msg as input.

Definition at line 682 of file flow_graph.h.

Member Typedef Documentation

◆ class_type

template<typename Output , typename Policy >
typedef continue_input<output_type, Policy> tbb::flow::interface10::internal::continue_input< Output, Policy >::class_type

Definition at line 691 of file flow_graph.h.

◆ function_body_type

template<typename Output , typename Policy >
typedef function_body<input_type, output_type> tbb::flow::interface10::internal::continue_input< Output, Policy >::function_body_type

Definition at line 690 of file flow_graph.h.

◆ input_type

template<typename Output , typename Policy >
typedef continue_msg tbb::flow::interface10::internal::continue_input< Output, Policy >::input_type

The input type of this receiver.

Definition at line 686 of file flow_graph.h.

◆ output_type

template<typename Output , typename Policy >
typedef Output tbb::flow::interface10::internal::continue_input< Output, Policy >::output_type

The output type of this receiver.

Definition at line 689 of file flow_graph.h.

Constructor & Destructor Documentation

◆ continue_input() [1/3]

template<typename Output , typename Policy >
template<typename Body >
tbb::flow::interface10::internal::continue_input< Output, Policy >::continue_input ( graph g,
__TBB_FLOW_GRAPH_PRIORITY_ARG1(Body &body, node_priority_t priority)   
)
inline

Definition at line 694 of file flow_graph.h.

695  {
696  return t.key();
697  }
698 #endif /* __TBB_PREVIEW_MESSAGE_BASED_KEY_MATCHING */
699 

◆ continue_input() [2/3]

template<typename Output , typename Policy >
template<typename Body >
tbb::flow::interface10::internal::continue_input< Output, Policy >::continue_input ( graph g,
int  number_of_predecessors 
)
inline

Definition at line 702 of file flow_graph.h.

709  {

◆ continue_input() [3/3]

template<typename Output , typename Policy >
tbb::flow::interface10::internal::continue_input< Output, Policy >::continue_input ( const continue_input< Output, Policy > &  src)
inline

Definition at line 710 of file flow_graph.h.

710  {
711 namespace interface10 {
712 

◆ ~continue_input()

template<typename Output , typename Policy >
tbb::flow::interface10::internal::continue_input< Output, Policy >::~continue_input ( )
inline

Definition at line 715 of file flow_graph.h.

Member Function Documentation

◆ apply_body_bypass()

template<typename Output , typename Policy >
task* tbb::flow::interface10::internal::continue_input< Output, Policy >::apply_body_bypass ( input_type  )
inlineprotected

Applies the body to the provided input.

Definition at line 746 of file flow_graph.h.

◆ copy_function_object()

template<typename Output , typename Policy >
template<typename Body >
Body tbb::flow::interface10::internal::continue_input< Output, Policy >::copy_function_object ( )
inline

Definition at line 721 of file flow_graph.h.

722  : my_graph(g), current_node(NULL)
723 {
724  if (begin) current_node = my_graph->my_nodes;
void const char const char int ITT_FORMAT __itt_group_sync x void const char ITT_FORMAT __itt_group_sync s void ITT_FORMAT __itt_group_sync p void ITT_FORMAT p void ITT_FORMAT p no args __itt_suppress_mode_t unsigned int void size_t ITT_FORMAT d void ITT_FORMAT p void ITT_FORMAT p __itt_model_site __itt_model_site_instance ITT_FORMAT p __itt_model_task __itt_model_task_instance ITT_FORMAT p void ITT_FORMAT p void ITT_FORMAT p void size_t ITT_FORMAT d void ITT_FORMAT p const wchar_t ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s const char ITT_FORMAT s no args void ITT_FORMAT p size_t ITT_FORMAT d no args const wchar_t const wchar_t ITT_FORMAT s __itt_heap_function void size_t int ITT_FORMAT d __itt_heap_function void ITT_FORMAT p __itt_heap_function void void size_t int ITT_FORMAT d no args no args unsigned int ITT_FORMAT u const __itt_domain __itt_id ITT_FORMAT lu const __itt_domain __itt_id __itt_id __itt_string_handle ITT_FORMAT p const __itt_domain __itt_id ITT_FORMAT p const __itt_domain __itt_id __itt_timestamp begin

References begin.

◆ execute()

template<typename Output , typename Policy >
task* tbb::flow::interface10::internal::continue_input< Output, Policy >::execute ( )
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 755 of file flow_graph.h.

757  :
758  my_context(&use_this_context), my_nodes(NULL), my_nodes_last(NULL), my_task_arena(NULL) {
759  prepare_task_arena();
760  own_context = false;
761  my_root_task = (new (task::allocate_root(*my_context)) empty_task);
762  my_root_task->set_ref_count(1);
764  my_is_active = true;
765 }
766 
767 inline graph::~graph() {
768  wait_for_all();
769  my_root_task->set_ref_count(0);
770  tbb::task::destroy(*my_root_task);
771  if (own_context) delete my_context;
772  delete my_task_arena;
773 }
774 
~graph()
Destroys the graph.
Definition: flow_graph.h:767
static void fgt_graph(void *)
static internal::allocate_root_proxy allocate_root()
Returns proxy for overloaded new that allocates a root task.
Definition: task.h:636

◆ graph_reference()

template<typename Output , typename Policy >
graph& tbb::flow::interface10::internal::continue_input< Output, Policy >::graph_reference ( )
inlineprotectedvirtual

Implements tbb::flow::interface10::internal::untyped_receiver.

Definition at line 776 of file flow_graph.h.

776  {
777  my_root_task->increment_ref_count();
static void fgt_reserve_wait(void *)

◆ reset_receiver()

template<typename Output , typename Policy >
void tbb::flow::interface10::internal::continue_input< Output, Policy >::reset_receiver ( reset_flags  f)
inlinevirtual

put receiver back in initial state

Reimplemented from tbb::flow::interface10::continue_receiver.

Definition at line 726 of file flow_graph.h.

729  {
730  __TBB_ASSERT(current_node, "graph_iterator at end");
731  return *operator->();
732 }
733 
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
Definition: tbb_stddef.h:169

Referenced by tbb::flow::interface10::continue_node< Output, Policy >::reset_node().

Here is the caller graph for this function:

◆ successors()

template<typename Output , typename Policy >
virtual broadcast_cache<output_type >& tbb::flow::interface10::internal::continue_input< Output, Policy >::successors ( )
protectedpure virtual

Friends And Related Function Documentation

◆ apply_body_task_bypass< class_type, continue_msg >

template<typename Output , typename Policy >
friend class apply_body_task_bypass< class_type, continue_msg >
friend

Definition at line 743 of file flow_graph.h.

Member Data Documentation

◆ my_body

template<typename Output , typename Policy >
function_body_type* tbb::flow::interface10::internal::continue_input< Output, Policy >::my_body
protected

Definition at line 738 of file flow_graph.h.

◆ my_graph_ref

template<typename Output , typename Policy >
graph& tbb::flow::interface10::internal::continue_input< Output, Policy >::my_graph_ref
protected

Definition at line 737 of file flow_graph.h.

◆ my_init_body

template<typename Output , typename Policy >
function_body_type* tbb::flow::interface10::internal::continue_input< Output, Policy >::my_init_body
protected

Definition at line 739 of file flow_graph.h.


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

Copyright © 2005-2019 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.