Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface11::async_node< Input, Output, Policy, Allocator > Class Template Reference

Implements async node. More...

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >:
Collaboration diagram for tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >:

Classes

class  receiver_gateway_impl
 
struct  try_put_functor
 

Public Types

typedef Input input_type
 
typedef Output output_type
 
typedef receiver< input_typereceiver_type
 
typedef receiver_type::predecessor_type predecessor_type
 
typedef sender< output_type >::successor_type successor_type
 
typedef receiver_gateway< output_typegateway_type
 
typedef internal::async_body_base< gateway_typeasync_body_base_type
 
typedef base_type::output_ports_type output_ports_type
 
- Public Types inherited from tbb::flow::interface11::multifunction_node< Input, tuple< Output >, queueing_lightweight, __TBB_DEFAULT_NODE_ALLOCATOR(Input) >
typedef Input input_type
 
typedef null_type output_type
 
typedef internal::wrap_tuple_elements< N, internal::multifunction_output, tuple< Output > >::type output_ports_type
 
typedef internal::multifunction_input< input_type, output_ports_type, queueing_lightweight, internals_allocatorinput_impl_type
 
typedef internal::function_input_queue< input_type, internals_allocatorinput_queue_type
 
- Public Types inherited from internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >
typedef Input input_type
 
typedef internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type output_ports_type
 
typedef multifunction_body< input_type, output_ports_typemultifunction_body_type
 
typedef multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > > my_class
 
typedef function_input_base< Input, queueing_lightweight, cache_aligned_allocator< Input >, my_classbase_type
 
typedef function_input_queue< input_type, cache_aligned_allocator< Input > > input_queue_type
 
- Public Types inherited from internal::function_input_base< Input, queueing_lightweight, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > > >
typedef Input input_type
 The input type of this receiver. More...
 
typedef receiver< input_type >::predecessor_type predecessor_type
 
typedef predecessor_cache< input_type, null_mutex > predecessor_cache_type
 
typedef function_input_queue< input_type, cache_aligned_allocator< Input > > input_queue_type
 
typedef tbb::internal::allocator_rebind< cache_aligned_allocator< Input >, input_queue_type >::type queue_allocator_type
 

Public Member Functions

template<typename Body >
__TBB_NOINLINE_SYM async_node (graph &g, size_t concurrency,)
 
__TBB_NOINLINE_SYM async_node (const async_node &other)
 
gateway_typegateway ()
 
bool register_successor (successor_type &r) __TBB_override
 Add a new successor to this node. More...
 
bool remove_successor (successor_type &r) __TBB_override
 Removes a successor from this node. More...
 
template<typename Body >
Body copy_function_object ()
 
- Public Member Functions inherited from tbb::flow::interface11::multifunction_node< Input, tuple< Output >, queueing_lightweight, __TBB_DEFAULT_NODE_ALLOCATOR(Input) >
__TBB_NOINLINE_SYM multifunction_node (graph &g, size_t concurrency,)
 
__TBB_NOINLINE_SYM multifunction_node (const multifunction_node &other)
 
- Public Member Functions inherited from tbb::flow::interface11::graph_node
 graph_node (graph &g)
 
virtual ~graph_node ()
 
- Public Member Functions inherited from internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >
 multifunction_input (graph &g, size_t max_concurrency,)
 
 multifunction_input (const multifunction_input &src)
 Copy constructor. More...
 
 ~multifunction_input ()
 
Body copy_function_object ()
 
taskapply_body_impl_bypass (const input_type &i)
 
output_ports_typeoutput_ports ()
 
- Public Member Functions inherited from internal::function_input_base< Input, queueing_lightweight, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > > >
 __TBB_STATIC_ASSERT (!((internal::has_policy< queueing, queueing_lightweight >::value) &&(internal::has_policy< rejecting, queueing_lightweight >::value)), "queueing and rejecting policies can't be specified simultaneously")
 
 function_input_base (graph &g, __TBB_FLOW_GRAPH_PRIORITY_ARG1(size_t max_concurrency, node_priority_t priority))
 Constructor for function_input_base. More...
 
 function_input_base (const function_input_base &src)
 Copy constructor. More...
 
virtual ~function_input_base ()
 Destructor. More...
 
tasktry_put_task (const input_type &t) __TBB_override
 
bool register_predecessor (predecessor_type &src) __TBB_override
 Adds src to the list of cached predecessors. More...
 
bool remove_predecessor (predecessor_type &src) __TBB_override
 Removes src from the list of cached predecessors. More...
 
- Public Member Functions inherited from tbb::flow::interface11::receiver< Input >
virtual ~receiver ()
 Destructor. More...
 
bool try_put (const Input &t)
 Put an item to the receiver. More...
 
virtual __TBB_DEPRECATED bool register_predecessor (predecessor_type &)
 Add a predecessor to the node. More...
 
virtual __TBB_DEPRECATED bool remove_predecessor (predecessor_type &)
 Remove a predecessor from the node. More...
 
- Public Member Functions inherited from tbb::flow::interface11::sender< Output >
virtual ~sender ()
 
virtual __TBB_DEPRECATED bool register_successor (successor_type &r)=0
 Add a new successor to this node. More...
 
virtual __TBB_DEPRECATED bool remove_successor (successor_type &r)=0
 Removes a successor from this node. More...
 
virtual bool try_get (Output &)
 Request an item from the sender. More...
 
virtual bool try_reserve (Output &)
 Reserves an item in the sender. More...
 
virtual bool try_release ()
 Releases the reserved item. More...
 
virtual bool try_consume ()
 Consumes the reserved item. More...
 

Protected Member Functions

void reset_node (reset_flags f) __TBB_override
 
- Protected Member Functions inherited from tbb::flow::interface11::multifunction_node< Input, tuple< Output >, queueing_lightweight, __TBB_DEFAULT_NODE_ALLOCATOR(Input) >
void reset_node (reset_flags f) __TBB_override
 
- Protected Member Functions inherited from internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >
void reset (reset_flags f)
 
- Protected Member Functions inherited from internal::function_input_base< Input, queueing_lightweight, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > > >
void reset_function_input_base (reset_flags f)
 
void reset_receiver (reset_flags f) __TBB_override
 
graph & graph_reference () const __TBB_override
 
tasktry_get_postponed_task (const input_type &i)
 
- Protected Member Functions inherited from tbb::flow::interface11::receiver< Input >
virtual void reset_receiver (reset_flags f=rf_reset_protocol)=0
 put receiver back in initial state More...
 
virtual bool is_continue_receiver ()
 

Private Types

typedef multifunction_node< Input, tuple< Output >, Policy, Allocator > base_type
 
typedef internal::multifunction_input< Input, typename base_type::output_ports_type, Policy, Allocator > mfn_input_type
 

Private Member Functions

 __TBB_STATIC_ASSERT ((tbb::internal::is_same_type< Allocator, null_type >::value), "Allocator template parameter for flow graph nodes is deprecated and will removed in the future. " "To temporary enable the deprecated interface specify TBB_ENABLE_DEPRECATED_NODE_ALLOCATOR.")
 
async_nodeself ()
 
bool try_put_impl (const Output &i)
 Implements gateway_type::try_put for an external activity to submit a message to FG. More...
 

Private Attributes

tbb::flow::interface11::async_node::receiver_gateway_impl my_gateway
 

Additional Inherited Members

- Public Attributes inherited from tbb::flow::interface11::receiver< Input >
__TBB_DEPRECATED typedef Input input_type
 The input type of this receiver. More...
 
__TBB_DEPRECATED typedef sender< Input > predecessor_type
 The predecessor type for this node. More...
 
- Public Attributes inherited from tbb::flow::interface11::sender< Output >
__TBB_DEPRECATED typedef Output output_type
 The output type of this sender. More...
 
__TBB_DEPRECATED typedef receiver< Output > successor_type
 The successor type for this node. More...
 
- Static Public Attributes inherited from internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >
static const int N
 
- Protected Attributes inherited from tbb::flow::interface11::graph_node
graphmy_graph
 
graph_nodenext
 
graph_nodeprev
 
- Protected Attributes inherited from internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >
multifunction_body_typemy_body
 
multifunction_body_typemy_init_body
 
output_ports_type my_output_ports
 
- Protected Attributes inherited from internal::function_input_base< Input, queueing_lightweight, cache_aligned_allocator< Input >, multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > > >
graph & my_graph_ref
 
const size_t my_max_concurrency
 
size_t my_concurrency
 
input_queue_typemy_queue
 
predecessor_cache< input_type, null_mutex > my_predecessors
 
- Static Protected Attributes inherited from tbb::flow::interface11::multifunction_node< Input, tuple< Output >, queueing_lightweight, __TBB_DEFAULT_NODE_ALLOCATOR(Input) >
static const int N
 

Detailed Description

template<typename Input, typename Output, typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
class tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >

Implements async node.

Definition at line 4203 of file flow_graph.h.

Member Typedef Documentation

◆ async_body_base_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef internal::async_body_base<gateway_type> tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::async_body_base_type

Definition at line 4223 of file flow_graph.h.

◆ base_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef multifunction_node< Input, tuple< Output >, Policy, Allocator > tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::base_type
private

Definition at line 4213 of file flow_graph.h.

◆ gateway_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef receiver_gateway<output_type> tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::gateway_type

Definition at line 4222 of file flow_graph.h.

◆ input_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef Input tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::input_type

Definition at line 4217 of file flow_graph.h.

◆ mfn_input_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef internal::multifunction_input<Input, typename base_type::output_ports_type, Policy, Allocator> tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::mfn_input_type
private

Definition at line 4214 of file flow_graph.h.

◆ output_ports_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef base_type::output_ports_type tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::output_ports_type

Definition at line 4224 of file flow_graph.h.

◆ output_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef Output tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::output_type

Definition at line 4218 of file flow_graph.h.

◆ predecessor_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef receiver_type::predecessor_type tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::predecessor_type

Definition at line 4220 of file flow_graph.h.

◆ receiver_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef receiver<input_type> tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::receiver_type

Definition at line 4219 of file flow_graph.h.

◆ successor_type

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
typedef sender<output_type>::successor_type tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::successor_type

Definition at line 4221 of file flow_graph.h.

Constructor & Destructor Documentation

◆ async_node() [1/2]

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
template<typename Body >
__TBB_NOINLINE_SYM tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::async_node ( graph g,
size_t  concurrency 
)
inline

Definition at line 4283 of file flow_graph.h.

4290  : base_type(
4291  g, concurrency,
4292  internal::async_body<Input, typename base_type::output_ports_type, gateway_type, Body>
4293  (body, &my_gateway) __TBB_FLOW_GRAPH_PRIORITY_ARG0(priority) ), my_gateway(self()) {
4294  tbb::internal::fgt_multioutput_node_with_body<1>(
4295  CODEPTR(), tbb::internal::FLOW_ASYNC_NODE,
4296  &this->my_graph, static_cast<receiver<input_type> *>(this),
4297  this->output_ports(), this->my_body
4298  );
4299  }

References CODEPTR.

◆ async_node() [2/2]

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
__TBB_NOINLINE_SYM tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::async_node ( const async_node< Input, Output, Policy, Allocator > &  other)
inline

Definition at line 4323 of file flow_graph.h.

4323  : base_type(other), sender<Output>(), my_gateway(self()) {
4324  static_cast<async_body_base_type*>(this->my_body->get_body_ptr())->set_gateway(&my_gateway);
4325  static_cast<async_body_base_type*>(this->my_init_body->get_body_ptr())->set_gateway(&my_gateway);
4326 
4327  tbb::internal::fgt_multioutput_node_with_body<1>( CODEPTR(), tbb::internal::FLOW_ASYNC_NODE,
4328  &this->my_graph, static_cast<receiver<input_type> *>(this),
4329  this->output_ports(), this->my_body );
4330  }

References CODEPTR.

Member Function Documentation

◆ __TBB_STATIC_ASSERT()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::__TBB_STATIC_ASSERT ( (tbb::internal::is_same_type< Allocator, null_type >::value ,
"Allocator template parameter for flow graph nodes is deprecated and will removed in the future. " "To temporary enable the deprecated interface specify TBB_ENABLE_DEPRECATED_NODE_ALLOCATOR."   
)
private

◆ copy_function_object()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
template<typename Body >
Body tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::copy_function_object ( )
inline

Definition at line 4355 of file flow_graph.h.

4355  {
4357  typedef internal::async_body<Input, typename base_type::output_ports_type, gateway_type, Body> async_body_type;
4358  mfn_body_type &body_ref = *this->my_body;
4359  async_body_type ab = *static_cast<async_body_type*>(dynamic_cast< internal::multifunction_body_leaf<input_type, typename base_type::output_ports_type, async_body_type> & >(body_ref).get_body_ptr());
4360  return ab.get_body();
4361  }

References tbb::flow::interface11::internal::async_body< Input, Ports, Gateway, Body >::get_body().

Here is the call graph for this function:

◆ gateway()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
gateway_type& tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::gateway ( )
inline

Definition at line 4332 of file flow_graph.h.

4332  {
4333  return my_gateway;
4334  }

◆ register_successor()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
bool tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::register_successor ( successor_type r)
inline

Add a new successor to this node.

Definition at line 4345 of file flow_graph.h.

4345  {
4346  return internal::output_port<0>(*this).register_successor(r);
4347  }

◆ remove_successor()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
bool tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::remove_successor ( successor_type r)
inline

Removes a successor from this node.

Definition at line 4350 of file flow_graph.h.

4350  {
4351  return internal::output_port<0>(*this).remove_successor(r);
4352  }

◆ reset_node()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
void tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::reset_node ( reset_flags  f)
inlineprotectedvirtual

Implements tbb::flow::interface11::graph_node.

Definition at line 4390 of file flow_graph.h.

4390  {
4392  }

◆ self()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
async_node* tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::self ( )
inlineprivate

Definition at line 4262 of file flow_graph.h.

4262 { return this; }

◆ try_put_impl()

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
bool tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::try_put_impl ( const Output &  i)
inlineprivate

Implements gateway_type::try_put for an external activity to submit a message to FG.

Definition at line 4265 of file flow_graph.h.

4265  {
4266  internal::multifunction_output<Output> &port_0 = internal::output_port<0>(*this);
4267  internal::broadcast_cache<output_type>& port_successors = port_0.successors();
4269  task_list tasks;
4270  bool is_at_least_one_put_successful = port_successors.gather_successful_try_puts(i, tasks);
4271  __TBB_ASSERT( is_at_least_one_put_successful || tasks.empty(),
4272  "Return status is inconsistent with the method operation." );
4273 
4274  while( !tasks.empty() ) {
4275  internal::enqueue_in_graph_arena(this->my_graph, tasks.pop_front());
4276  }
4277  tbb::internal::fgt_async_try_put_end(this, &port_0);
4278  return is_at_least_one_put_successful;
4279  }

References __TBB_ASSERT, tbb::task_list::empty(), tbb::flow::interface11::internal::enqueue_in_graph_arena(), tbb::internal::fgt_async_try_put_begin(), tbb::internal::fgt_async_try_put_end(), tbb::task_list::pop_front(), and internal::function_output< Output >::successors().

Here is the call graph for this function:

Member Data Documentation

◆ my_gateway

template<typename Input , typename Output , typename Policy = queueing_lightweight, typename Allocator = __TBB_DEFAULT_NODE_ALLOCATOR(Input)>
tbb::flow::interface11::async_node::receiver_gateway_impl tbb::flow::interface11::async_node< Input, Output, Policy, Allocator >::my_gateway
private

The documentation for this class was generated from the following file:
tbb::internal::fgt_async_try_put_end
static void fgt_async_try_put_end(void *, void *)
Definition: _flow_graph_trace_impl.h:340
CODEPTR
#define CODEPTR()
Definition: _flow_graph_trace_impl.h:297
internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::my_body
multifunction_body_type * my_body
Definition: _flow_graph_node_impl.h:711
__TBB_ASSERT
#define __TBB_ASSERT(predicate, comment)
No-op version of __TBB_ASSERT.
Definition: tbb_stddef.h:165
tbb::flow::interface11::graph_node::my_graph
graph & my_graph
Definition: _flow_graph_impl.h:464
internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::my_init_body
multifunction_body_type * my_init_body
Definition: _flow_graph_node_impl.h:712
internal::function_output::successors
broadcast_cache_type & successors()
Definition: _flow_graph_node_impl.h:916
internal::multifunction_body_leaf
leaf for multifunction. OutputSet can be a std::tuple or a vector.
Definition: _flow_graph_body_impl.h:202
tbb::flow::interface11::multifunction_node::reset_node
void reset_node(reset_flags f) __TBB_override
Definition: flow_graph.h:1667
__TBB_FLOW_GRAPH_PRIORITY_ARG0
#define __TBB_FLOW_GRAPH_PRIORITY_ARG0(priority)
Definition: _flow_graph_impl.h:39
internal::multifunction_input< Input, internal::wrap_tuple_elements< tbb::flow::tuple_size< tuple< Output > >::value, internal::multifunction_output, tuple< Output > >::type, queueing_lightweight, cache_aligned_allocator< Input > >::output_ports
output_ports_type & output_ports()
Definition: _flow_graph_node_impl.h:691
tbb::flow::interface11::async_node::async_body_base_type
internal::async_body_base< gateway_type > async_body_base_type
Definition: flow_graph.h:4223
tbb::flow::concurrency
concurrency
An enumeration the provides the two most common concurrency levels: unlimited and serial.
Definition: flow_graph.h:105
internal::broadcast_cache::gather_successful_try_puts
bool gather_successful_try_puts(const T &t, task_list &tasks)
Definition: _flow_graph_cache_impl.h:512
tbb::flow::interface11::async_node::my_gateway
tbb::flow::interface11::async_node::receiver_gateway_impl my_gateway
internal::multifunction_body
function_body that takes an Input and a set of output ports
Definition: _flow_graph_body_impl.h:192
tbb::flow::interface11::async_node::base_type
multifunction_node< Input, tuple< Output >, Policy, Allocator > base_type
Definition: flow_graph.h:4213
tbb::internal::fgt_async_try_put_begin
static void fgt_async_try_put_begin(void *, void *)
Definition: _flow_graph_trace_impl.h:339
internal::multifunction_body::get_body_ptr
virtual void * get_body_ptr()=0
tbb::flow::interface11::internal::enqueue_in_graph_arena
void enqueue_in_graph_arena(tbb::flow::interface10::graph &g, tbb::task &arena_task)
Enqueues a task inside graph arena.
Definition: _flow_graph_impl.h:530
internal::broadcast_cache< output_type >
internal::multifunction_output
Definition: _flow_graph_node_impl.h:925

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.