Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType > Class Template Reference

Input and scheduling for a function node that takes a type Input as input. More...

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >:
Collaboration diagram for tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >:

Classes

class  operation_type
 

Public Types

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_mutexpredecessor_cache_type
 
typedef function_input_queue< input_type, A > input_queue_type
 
typedef A::template rebind< input_queue_type >::other queue_allocator_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

 __TBB_STATIC_ASSERT (!((internal::has_policy< queueing, Policy >::value) &&(internal::has_policy< rejecting, Policy >::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
 Put item to successor; return task to run the successor if possible. More...
 
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 >
bool try_put (const typename internal::async_helpers< Input >::filtered_type &t)
 Put an item to the receiver. More...
 
bool try_put (const typename internal::async_helpers< Input >::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

void reset_function_input_base (reset_flags f)
 
void reset_receiver (reset_flags f) __TBB_override
 put receiver back in initial state More...
 
graphgraph_reference () const __TBB_override
 
tasktry_get_postponed_task (const input_type &i)
 
- Protected Member Functions inherited from tbb::flow::interface11::receiver< Input >
virtual tasktry_put_task_wrapper (const void *p, bool is_async) __TBB_override
 
- Protected Member Functions inherited from tbb::flow::interface11::internal::untyped_receiver
template<typename X >
tasktry_put_task (const X &t)
 
virtual bool is_continue_receiver ()
 

Protected Attributes

graphmy_graph_ref
 
const size_t my_max_concurrency
 
size_t my_concurrency
 
input_queue_typemy_queue
 
predecessor_cache< input_type, null_mutexmy_predecessors
 

Private Types

enum  op_type {
  reg_pred, rem_pred, try_fwd, tryput_bypass,
  app_body_bypass, occupy_concurrency
}
 
typedef function_input_base< Input, Policy, A, ImplType > class_type
 
typedef internal::aggregating_functor< class_type, operation_typehandler_type
 

Private Member Functions

taskperform_queued_requests ()
 
void handle_operations (operation_type *op_list)
 
void internal_try_put_task (operation_type *op)
 Put to the node, but return the task instead of enqueueing it. More...
 
void internal_forward (operation_type *op)
 Creates tasks for postponed messages if available and if concurrency allows. More...
 
taskinternal_try_put_bypass (const input_type &t)
 
tasktry_put_task_impl (const input_type &t, tbb::internal::true_type)
 
tasktry_put_task_impl (const input_type &t, tbb::internal::false_type)
 
taskapply_body_bypass (const input_type &i)
 Applies the body to the provided input. More...
 
taskcreate_body_task (const input_type &input)
 allocates a task to apply a body More...
 
taskforward_task ()
 This is executed by an enqueued task, the "forwarder". More...
 
taskcreate_forward_task ()
 
void spawn_forward_task ()
 Spawns a task that calls forward() More...
 
- Private Member Functions inherited from tbb::internal::no_assign
void operator= (const no_assign &)=delete
 
 no_assign (const no_assign &)=default
 
 no_assign ()=default
 

Private Attributes

bool forwarder_busy
 
aggregator< handler_type, operation_typemy_aggregator
 

Friends

class apply_body_task_bypass< class_type, input_type >
 
class forward_task_bypass< class_type >
 
class internal::aggregating_functor< class_type, operation_type >
 

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 internal::async_helpers< Input >::filtered_type filtered_type
 

Detailed Description

template<typename Input, typename Policy, typename A, typename ImplType>
class tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >

Input and scheduling for a function node that takes a type Input as input.

Definition at line 61 of file flow_graph.h.

Member Typedef Documentation

◆ class_type

template<typename Input, typename Policy, typename A, typename ImplType>
typedef function_input_base<Input, Policy, A, ImplType> tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::class_type
private

Definition at line 68 of file flow_graph.h.

◆ handler_type

template<typename Input, typename Policy, typename A, typename ImplType>
typedef internal::aggregating_functor<class_type, operation_type> tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::handler_type
private

Definition at line 227 of file flow_graph.h.

◆ input_queue_type

template<typename Input, typename Policy, typename A, typename ImplType>
typedef function_input_queue<input_type, A> tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::input_queue_type

Definition at line 76 of file flow_graph.h.

◆ input_type

template<typename Input, typename Policy, typename A, typename ImplType>
typedef Input tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::input_type

The input type of this receiver.

Definition at line 73 of file flow_graph.h.

◆ predecessor_cache_type

template<typename Input, typename Policy, typename A, typename ImplType>
typedef predecessor_cache<input_type, null_mutex > tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::predecessor_cache_type

Definition at line 75 of file flow_graph.h.

◆ predecessor_type

template<typename Input, typename Policy, typename A, typename ImplType>
typedef receiver<input_type>::predecessor_type tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::predecessor_type

Definition at line 74 of file flow_graph.h.

◆ queue_allocator_type

template<typename Input, typename Policy, typename A, typename ImplType>
typedef A::template rebind< input_queue_type >::other tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::queue_allocator_type

Definition at line 77 of file flow_graph.h.

Member Enumeration Documentation

◆ op_type

template<typename Input, typename Policy, typename A, typename ImplType>
enum tbb::flow::interface11::internal::function_input_base::op_type
private
Enumerator
reg_pred 
rem_pred 
try_fwd 
tryput_bypass 
app_body_bypass 
occupy_concurrency 

Definition at line 62 of file flow_graph.h.

69  {

Constructor & Destructor Documentation

◆ function_input_base() [1/2]

template<typename Input, typename Policy, typename A, typename ImplType>
tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::function_input_base ( graph g,
__TBB_FLOW_GRAPH_PRIORITY_ARG1(size_t max_concurrency, node_priority_t priority)   
)
inline

Constructor for function_input_base.

Definition at line 87 of file flow_graph.h.

94  {
95 namespace flow {
96 

◆ function_input_base() [2/2]

template<typename Input, typename Policy, typename A, typename ImplType>
tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::function_input_base ( const function_input_base< Input, Policy, A, ImplType > &  src)
inline

Copy constructor.

Definition at line 99 of file flow_graph.h.

100  {
101 
103 struct null_type {};
104 
106 class continue_msg {};
107 

◆ ~function_input_base()

template<typename Input, typename Policy, typename A, typename ImplType>
virtual tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::~function_input_base ( )
inlinevirtual

Destructor.

Definition at line 113 of file flow_graph.h.

117  {

Member Function Documentation

◆ __TBB_STATIC_ASSERT()

template<typename Input, typename Policy, typename A, typename ImplType>
tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::__TBB_STATIC_ASSERT ( (internal::has_policy< queueing, Policy >::value) &&(internal::has_policy< rejecting, Policy >::value),
"queueing and rejecting policies can't be specified simultaneously"   
)

◆ apply_body_bypass()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::apply_body_bypass ( const input_type i)
inlineprivate

Applies the body to the provided input.

Definition at line 373 of file flow_graph.h.

381  { return false; }

◆ create_body_task()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::create_body_task ( const input_type input)
inlineprivate

allocates a task to apply a body

Definition at line 378 of file flow_graph.h.

381  { return false; }
382 
384  virtual bool remove_predecessor( predecessor_type & ) { return false; }
bool remove_predecessor(predecessor_type &src) __TBB_override
Removes src from the list of cached predecessors.
Definition: flow_graph.h:130
receiver< input_type >::predecessor_type predecessor_type
Definition: flow_graph.h:74

◆ create_forward_task()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::create_forward_task ( )
inlineprivate

Definition at line 402 of file flow_graph.h.

410  { return false; }

◆ forward_task()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::forward_task ( )
inlineprivate

This is executed by an enqueued task, the "forwarder".

Definition at line 387 of file flow_graph.h.

395  :
396  template<typename X>
397  task *try_put_task(const X& t) {
399  }
400 
virtual task * try_put_task_wrapper(const void *p, bool is_async) __TBB_override
Definition: flow_graph.h:473
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 * task
task * try_put_task(const input_type &t) __TBB_override
Put item to successor; return task to run the successor if possible.
Definition: flow_graph.h:117
static const void * to_void_ptr(const T &t)
Definition: flow_graph.h:221

◆ graph_reference()

template<typename Input, typename Policy, typename A, typename ImplType>
graph& tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::graph_reference ( ) const
inlineprotectedvirtual

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

Definition at line 194 of file flow_graph.h.

198  {

◆ handle_operations()

template<typename Input, typename Policy, typename A, typename ImplType>
void tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::handle_operations ( operation_type op_list)
inlineprivate

Definition at line 250 of file flow_graph.h.

256  {
257  typedef T async_type;
258  typedef typename T::async_msg_data_type filtered_type;
259 
260  static const bool is_async_type = true;
261 
262  // Receiver-classes use const interfaces
263  static const void* to_void_ptr(const T& t) {
264  return static_cast<const void*>(&static_cast<const async_msg<filtered_type>&>(t));
265  }
266 
267  static void* to_void_ptr(T& t) {
268  return static_cast<void*>(&static_cast<async_msg<filtered_type>&>(t));
269  }
270 
271  // Sender-classes use non-const interfaces
272  static const T& from_void_ptr(const void* p) {
273  return *static_cast<const T*>(static_cast<const async_msg<filtered_type>*>(p));
274  }
275 
276  static T& from_void_ptr(void* p) {
277  return *static_cast<T*>(static_cast<async_msg<filtered_type>*>(p));
278  }
279 
280  // Used in receiver<T> class
281  static task* try_put_task_wrapper_impl(receiver<T>* const this_recv, const void *p, bool is_async) {
282  if (is_async) {
283  // Both are async
284  return this_recv->try_put_task(from_void_ptr(p));
285  }
286  else {
287  // This (T) is async and incoming 'X t' is NOT async
288  // Create async_msg for X
290  const T msg(t);
291  return this_recv->try_put_task(msg);
292  }
293  }
294 };
295 
296 class untyped_receiver;
297 
298 class untyped_sender {
299  template< typename, typename > friend class internal::predecessor_cache;
300  template< typename, typename > friend class internal::reservable_predecessor_cache;
301 public:
303  typedef untyped_receiver successor_type;
304 
305  virtual ~untyped_sender() {}
306 
307  // NOTE: Following part of PUBLIC section is copy-paste from original sender<T> class
308 
309  // TODO: Prevent untyped successor registration
A cache of predecessors that only supports try_get.
void const char const char int ITT_FORMAT __itt_group_sync p
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 * task
static const T & from_void_ptr(const void *p)
Definition: flow_graph.h:229
An cache of predecessors that supports requests and reservations.
__TBB_DEPRECATED typedef internal::async_helpers< Input >::filtered_type filtered_type
Definition: flow_graph.h:461

◆ internal_forward()

template<typename Input, typename Policy, typename A, typename ImplType>
void tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::internal_forward ( operation_type op)
inlineprivate

Creates tasks for postponed messages if available and if concurrency allows.

Definition at line 329 of file flow_graph.h.

333  :
335  template< typename X >
336  bool try_get( X &t ) {
338  }
339 
static const void * to_void_ptr(const T &t)
Definition: flow_graph.h:221

◆ internal_try_put_bypass()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::internal_try_put_bypass ( const input_type t)
inlineprivate

Definition at line 341 of file flow_graph.h.

342  {
344  }
345 
346  virtual bool try_get_wrapper( void* p, bool is_async ) = 0;
347  virtual bool try_reserve_wrapper( void* p, bool is_async ) = 0;
348 };
void const char const char int ITT_FORMAT __itt_group_sync p
static const void * to_void_ptr(const T &t)
Definition: flow_graph.h:221

◆ internal_try_put_task()

template<typename Input, typename Policy, typename A, typename ImplType>
void tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::internal_try_put_task ( operation_type op)
inlineprivate

Put to the node, but return the task instead of enqueueing it.

Definition at line 312 of file flow_graph.h.

318  { return false; }
319 
321  virtual bool try_consume( ) { return false; }
322 
323 #if TBB_DEPRECATED_FLOW_NODE_EXTRACTION
324  typedef internal::edge_container<successor_type> built_successors_type;
326  typedef built_successors_type::edge_list_type successor_list_type;

◆ perform_queued_requests()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::perform_queued_requests ( )
inlineprivate

Definition at line 231 of file flow_graph.h.

233  {
234  return *static_cast<T*>(p);
235  }
236 
237  static task* try_put_task_wrapper_impl(receiver<T>* const this_recv, const void *p, bool is_async) {
238  if (is_async) {
239  // This (T) is NOT async and incoming 'A<X> t' IS async
240  // Get data from async_msg
241  const async_msg<filtered_type>& msg = async_helpers< async_msg<filtered_type> >::from_void_ptr(p);
242  task* const new_task = msg.my_storage->subscribe(*this_recv, this_recv->graph_reference());
243  // finalize() must be called after subscribe() because set() can be called in finalize()
244  // and 'this_recv' client must be subscribed by this moment
245  msg.finalize();
246  return new_task;
247  }
248  else {
249  // Incoming 't' is NOT async
async_storage_ptr my_storage
void const char const char int ITT_FORMAT __itt_group_sync p
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 * task
virtual void finalize() const

◆ register_predecessor()

template<typename Input, typename Policy, typename A, typename ImplType>
bool tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::register_predecessor ( predecessor_type src)
inlinevirtual

Adds src to the list of cached predecessors.

Reimplemented from tbb::flow::interface11::internal::untyped_receiver.

Definition at line 122 of file flow_graph.h.

126  {
127 struct following;

◆ remove_predecessor()

template<typename Input, typename Policy, typename A, typename ImplType>
bool tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::remove_predecessor ( predecessor_type src)
inlinevirtual

Removes src from the list of cached predecessors.

Reimplemented from tbb::flow::interface11::internal::untyped_receiver.

Definition at line 130 of file flow_graph.h.

137  {

◆ reset_function_input_base()

template<typename Input, typename Policy, typename A, typename ImplType>
void tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::reset_function_input_base ( reset_flags  f)
inlineprotected

Definition at line 171 of file flow_graph.h.

172  :
173  edge_list_type built_edges;
174 }; // class edge_container
175 #endif /* TBB_DEPRECATED_FLOW_NODE_EXTRACTION */
176 
177 } // namespace internal
178 

◆ reset_receiver()

template<typename Input, typename Policy, typename A, typename ImplType>
void tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::reset_receiver ( reset_flags  f)
inlineprotectedvirtual

put receiver back in initial state

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

Definition at line 187 of file flow_graph.h.

187  {
188 namespace interface11 {
189 
190 // enqueue left task if necessary. Returns the non-enqueued task if there is one.
191 static inline tbb::task *combine_tasks(graph& g, tbb::task * left, tbb::task * right) {
192  // if no RHS task, don't change left.
Base class for user-defined tasks.
Definition: task.h:604
static tbb::task * combine_tasks(graph &g, tbb::task *left, tbb::task *right)
Definition: flow_graph.h:191

◆ spawn_forward_task()

template<typename Input, typename Policy, typename A, typename ImplType>
void tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::spawn_forward_task ( )
inlineprivate

Spawns a task that calls forward()

Definition at line 410 of file flow_graph.h.

410  { return false; }
411 };
412 
413 } // namespace internal
414 

◆ try_get_postponed_task()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::try_get_postponed_task ( const input_type i)
inlineprotected

Definition at line 198 of file flow_graph.h.

198  {
199  // both are valid tasks
201  return right;
202  }
void spawn_in_graph_arena(tbb::flow::interface10::graph &g, tbb::task &arena_task)
Spawns a task inside graph arena.

◆ try_put_task()

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::try_put_task ( const input_type t)
inlinevirtual

Put item to successor; return task to run the successor if possible.

Implements tbb::flow::interface11::receiver< Input >.

Definition at line 117 of file flow_graph.h.

117  {
118 
119 template<typename T, typename M> class successor_cache;

◆ try_put_task_impl() [1/2]

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::try_put_task_impl ( const input_type t,
tbb::internal::true_type   
)
inlineprivate

Definition at line 350 of file flow_graph.h.

350  {
351  template< typename, typename > friend class run_and_put_task;
352 
353  template< typename, typename > friend class internal::broadcast_cache;
354  template< typename, typename > friend class internal::round_robin_cache;
355  template< typename, typename > friend class internal::successor_cache;
356 
357 #if __TBB_PREVIEW_OPENCL_NODE
358  template< typename, typename > friend class proxy_dependency_receiver;
359 #endif /* __TBB_PREVIEW_OPENCL_NODE */
360 public:
A cache of successors that are put in a round-robin fashion.
An abstract cache of successors.
A cache of successors that are broadcast to.

◆ try_put_task_impl() [2/2]

template<typename Input, typename Policy, typename A, typename ImplType>
task* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::try_put_task_impl ( const input_type t,
tbb::internal::false_type   
)
inlineprivate

Definition at line 363 of file flow_graph.h.

365  {}
366 
368  template<typename X>
369  bool try_put(const X& t) {
bool try_put(const typename internal::async_helpers< Input >::filtered_type &t)
Put an item to the receiver.
Definition: flow_graph.h:464

Friends And Related Function Documentation

◆ apply_body_task_bypass< class_type, input_type >

template<typename Input, typename Policy, typename A, typename ImplType>
friend class apply_body_task_bypass< class_type, input_type >
friend

Definition at line 206 of file flow_graph.h.

◆ forward_task_bypass< class_type >

template<typename Input, typename Policy, typename A, typename ImplType>
friend class forward_task_bypass< class_type >
friend

Definition at line 207 of file flow_graph.h.

◆ internal::aggregating_functor< class_type, operation_type >

template<typename Input, typename Policy, typename A, typename ImplType>
friend class internal::aggregating_functor< class_type, operation_type >
friend

Definition at line 228 of file flow_graph.h.

Member Data Documentation

◆ forwarder_busy

template<typename Input, typename Policy, typename A, typename ImplType>
bool tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::forwarder_busy
private

Definition at line 226 of file flow_graph.h.

◆ my_aggregator

template<typename Input, typename Policy, typename A, typename ImplType>
aggregator< handler_type, operation_type > tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::my_aggregator
private

Definition at line 229 of file flow_graph.h.

◆ my_concurrency

template<typename Input, typename Policy, typename A, typename ImplType>
size_t tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::my_concurrency
protected

Definition at line 182 of file flow_graph.h.

◆ my_graph_ref

template<typename Input, typename Policy, typename A, typename ImplType>
graph& tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::my_graph_ref
protected

Definition at line 180 of file flow_graph.h.

◆ my_max_concurrency

template<typename Input, typename Policy, typename A, typename ImplType>
const size_t tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::my_max_concurrency
protected

Definition at line 181 of file flow_graph.h.

◆ my_predecessors

template<typename Input, typename Policy, typename A, typename ImplType>
predecessor_cache<input_type, null_mutex > tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::my_predecessors
protected

Definition at line 185 of file flow_graph.h.

◆ my_queue

template<typename Input, typename Policy, typename A, typename ImplType>
input_queue_type* tbb::flow::interface11::internal::function_input_base< Input, Policy, A, ImplType >::my_queue
protected

Definition at line 184 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.