Intel(R) Threading Building Blocks Doxygen Documentation  version 4.2.3
tbb::flow::interface10::internal::item_buffer< T, A > Class Template Reference

#include <flow_graph.h>

Inheritance diagram for tbb::flow::interface10::internal::item_buffer< T, A >:
Collaboration diagram for tbb::flow::interface10::internal::item_buffer< T, A >:

Public Types

enum  buffer_item_state { no_item =0, has_item =1, reserved_item =2 }
 
typedef T item_type
 

Public Member Functions

 item_buffer ()
 Constructor. More...
 
 ~item_buffer ()
 
void reset ()
 

Protected Types

typedef size_t size_type
 
typedef aligned_pair< item_type, buffer_item_state >::type buffer_item_type
 
typedef A::template rebind< buffer_item_type >::other allocator_type
 

Protected Member Functions

bool buffer_empty () const
 
buffer_item_typeitem (size_type i)
 
const buffer_item_typeitem (size_type i) const
 
bool my_item_valid (size_type i) const
 
bool my_item_reserved (size_type i) const
 
const item_typeget_my_item (size_t i) const
 
void set_my_item (size_t i, const item_type &o)
 
void fetch_item (size_t i, item_type &o)
 
void move_item (size_t to, size_t from)
 
bool place_item (size_t here, const item_type &me)
 
void swap_items (size_t i, size_t j)
 
void destroy_item (size_type i)
 
const item_typefront () const
 
const item_typeback () const
 
void reserve_item (size_type i)
 
void release_item (size_type i)
 
void destroy_front ()
 
void destroy_back ()
 
size_type size (size_t new_tail=0)
 
size_type capacity ()
 
bool buffer_full ()
 
void grow_my_array (size_t minimum_size)
 Grows the internal array. More...
 
bool push_back (item_type &v)
 
bool pop_back (item_type &v)
 
bool pop_front (item_type &v)
 
void clean_up_buffer (bool reset_pointers)
 

Protected Attributes

buffer_item_typemy_array
 
size_type my_array_size
 
size_type my_head
 
size_type my_tail
 

Static Protected Attributes

static const size_type initial_buffer_size = 4
 

Detailed Description

template<typename T, typename A = cache_aligned_allocator<T>>
class tbb::flow::interface10::internal::item_buffer< T, A >

Definition at line 41 of file flow_graph.h.

Member Typedef Documentation

◆ allocator_type

template<typename T, typename A = cache_aligned_allocator<T>>
typedef A::template rebind<buffer_item_type>::other tbb::flow::interface10::internal::item_buffer< T, A >::allocator_type
protected

Definition at line 48 of file flow_graph.h.

◆ buffer_item_type

template<typename T, typename A = cache_aligned_allocator<T>>
typedef aligned_pair<item_type, buffer_item_state>::type tbb::flow::interface10::internal::item_buffer< T, A >::buffer_item_type
protected

Definition at line 47 of file flow_graph.h.

◆ item_type

template<typename T, typename A = cache_aligned_allocator<T>>
typedef T tbb::flow::interface10::internal::item_buffer< T, A >::item_type

Definition at line 43 of file flow_graph.h.

◆ size_type

template<typename T, typename A = cache_aligned_allocator<T>>
typedef size_t tbb::flow::interface10::internal::item_buffer< T, A >::size_type
protected

Definition at line 46 of file flow_graph.h.

Member Enumeration Documentation

◆ buffer_item_state

template<typename T, typename A = cache_aligned_allocator<T>>
enum tbb::flow::interface10::internal::item_buffer::buffer_item_state
Enumerator
no_item 
has_item 
reserved_item 

Definition at line 44 of file flow_graph.h.

Constructor & Destructor Documentation

◆ item_buffer()

template<typename T, typename A = cache_aligned_allocator<T>>
tbb::flow::interface10::internal::item_buffer< T, A >::item_buffer ( )
inline

Constructor.

Definition at line 232 of file flow_graph.h.

◆ ~item_buffer()

template<typename T, typename A = cache_aligned_allocator<T>>
tbb::flow::interface10::internal::item_buffer< T, A >::~item_buffer ( )
inline

Definition at line 237 of file flow_graph.h.

243  {

Member Function Documentation

◆ back()

template<typename T, typename A = cache_aligned_allocator<T>>
const item_type& tbb::flow::interface10::internal::item_buffer< T, A >::back ( ) const
inlineprotected

Definition at line 138 of file flow_graph.h.

139  {
140  return (size_t)(built_edges.size());
141  }
142 

◆ buffer_empty()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::buffer_empty ( ) const
inlineprotected

Definition at line 56 of file flow_graph.h.

56 {

◆ buffer_full()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::buffer_full ( )
inlineprotected

Definition at line 157 of file flow_graph.h.

166 {

◆ capacity()

template<typename T, typename A = cache_aligned_allocator<T>>
size_type tbb::flow::interface10::internal::item_buffer< T, A >::capacity ( )
inlineprotected

Definition at line 154 of file flow_graph.h.

166 {

◆ clean_up_buffer()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::clean_up_buffer ( bool  reset_pointers)
inlineprotected

Definition at line 216 of file flow_graph.h.

217  {
218  if (is_async) {
219  // This (T) is NOT async and incoming 'A<X> t' IS async
220  // Get data from async_msg
221  const async_msg<filtered_type>& msg = async_helpers< async_msg<filtered_type> >::from_void_ptr(p);
222  task* const new_task = msg.my_storage->subscribe(*this_recv, this_recv->graph_reference());
223  // finalize() must be called after subscribe() because set() can be called in finalize()
224  // and 'this_recv' client must be subscribed by this moment
225  msg.finalize();
226  return new_task;
227  }
228  else {
async_storage_ptr my_storage
virtual void finalize() const
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
void const char const char int ITT_FORMAT __itt_group_sync p

◆ destroy_back()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::destroy_back ( )
inlineprotected

Definition at line 149 of file flow_graph.h.

152 :
153  edge_list_type built_edges;

◆ destroy_front()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::destroy_front ( )
inlineprotected

Definition at line 148 of file flow_graph.h.

152 :
153  edge_list_type built_edges;

◆ destroy_item()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::destroy_item ( size_type  i)
inlineprotected

Definition at line 124 of file flow_graph.h.

126  {
127  for (typename edge_list_type::iterator i = built_edges.begin(); i != built_edges.end(); ++i) {
128  if (*i == &s) {
void const char const char int ITT_FORMAT __itt_group_sync s

◆ fetch_item()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::fetch_item ( size_t  i,
item_type o 
)
inlineprotected

Definition at line 90 of file flow_graph.h.

92  {};
93 

◆ front()

template<typename T, typename A = cache_aligned_allocator<T>>
const item_type& tbb::flow::interface10::internal::item_buffer< T, A >::front ( ) const
inlineprotected

Definition at line 131 of file flow_graph.h.

135  {

◆ get_my_item()

template<typename T, typename A = cache_aligned_allocator<T>>
const item_type& tbb::flow::interface10::internal::item_buffer< T, A >::get_my_item ( size_t  i) const
inlineprotected

Definition at line 74 of file flow_graph.h.

80  {

◆ grow_my_array()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::grow_my_array ( size_t  minimum_size)
inlineprotected

Grows the internal array.

Definition at line 160 of file flow_graph.h.

166  {
167 namespace flow {
168 namespace interface10 {
169 
170 // enqueue left task if necessary. Returns the non-enqueued task if there is one.
171 static inline tbb::task *combine_tasks(graph& g, tbb::task * left, tbb::task * right) {
172  // if no RHS task, don't change left.
173  if (right == NULL) return left;
174  // right != NULL
175  if (left == NULL) return right;
176  if (left == SUCCESSFULLY_ENQUEUED) return right;
177  // left contains a task
178  if (right != SUCCESSFULLY_ENQUEUED) {
179  // both are valid tasks
181  return right;
182  }
183  return left;
184 }
185 
void spawn_in_graph_arena(graph &g, tbb::task &arena_task)
Spawns a task inside graph arena.
static tbb::task *const SUCCESSFULLY_ENQUEUED
static tbb::task * combine_tasks(graph &g, tbb::task *left, tbb::task *right)
Definition: flow_graph.h:171
Base class for user-defined tasks.
Definition: task.h:589

◆ item() [1/2]

template<typename T, typename A = cache_aligned_allocator<T>>
buffer_item_type& tbb::flow::interface10::internal::item_buffer< T, A >::item ( size_type  i)
inlineprotected

Definition at line 58 of file flow_graph.h.

80  {

◆ item() [2/2]

template<typename T, typename A = cache_aligned_allocator<T>>
const buffer_item_type& tbb::flow::interface10::internal::item_buffer< T, A >::item ( size_type  i) const
inlineprotected

Definition at line 64 of file flow_graph.h.

80  {

◆ move_item()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::move_item ( size_t  to,
size_t  from 
)
inlineprotected

Definition at line 99 of file flow_graph.h.

99  {
100 template< typename T, typename U > class limiter_node; // needed for resetting decrementer
101 }
102 namespace interface10 {
103 template< typename R, typename B > class run_and_put_task;
104 
105 namespace internal {

◆ my_item_reserved()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::my_item_reserved ( size_type  i) const
inlineprotected

Definition at line 71 of file flow_graph.h.

80 {

◆ my_item_valid()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::my_item_valid ( size_type  i) const
inlineprotected

Definition at line 70 of file flow_graph.h.

80 {

◆ place_item()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::place_item ( size_t  here,
const item_type me 
)
inlineprotected

Definition at line 108 of file flow_graph.h.

117  {

◆ pop_back()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::pop_back ( item_type v)
inlineprotected

Definition at line 196 of file flow_graph.h.

201  {
202  return static_cast<const void*>(&t);
203  }

◆ pop_front()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::pop_front ( item_type v)
inlineprotected

Definition at line 205 of file flow_graph.h.

205  {
206  return static_cast<void*>(&t);
207  }
208 
209  static const T& from_void_ptr(const void* p) {
210  return *static_cast<const T*>(p);
211  }
212 
void const char const char int ITT_FORMAT __itt_group_sync p

◆ push_back()

template<typename T, typename A = cache_aligned_allocator<T>>
bool tbb::flow::interface10::internal::item_buffer< T, A >::push_back ( item_type v)
inlineprotected

Definition at line 187 of file flow_graph.h.

190  {
191 
192 template < typename T > class async_storage;
193 
194 template< typename T, typename = void >

◆ release_item()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::release_item ( size_type  i)
inlineprotected

Definition at line 146 of file flow_graph.h.

152 :
153  edge_list_type built_edges;

◆ reserve_item()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::reserve_item ( size_type  i)
inlineprotected

Definition at line 145 of file flow_graph.h.

152 :
153  edge_list_type built_edges;

◆ reset()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::reset ( )
inline

Definition at line 241 of file flow_graph.h.

243 {

◆ set_my_item()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::set_my_item ( size_t  i,
const item_type o 
)
inlineprotected

Definition at line 81 of file flow_graph.h.

81  {
82 
84 enum concurrency { unlimited = 0, serial = 1 };
85 
86 namespace interface10 {
87 
concurrency
An enumeration the provides the two most common concurrency levels: unlimited and serial...
Definition: flow_graph.h:84

◆ size()

template<typename T, typename A = cache_aligned_allocator<T>>
size_type tbb::flow::interface10::internal::item_buffer< T, A >::size ( size_t  new_tail = 0)
inlineprotected

Definition at line 153 of file flow_graph.h.

166 {

◆ swap_items()

template<typename T, typename A = cache_aligned_allocator<T>>
void tbb::flow::interface10::internal::item_buffer< T, A >::swap_items ( size_t  i,
size_t  j 
)
inlineprotected

Definition at line 117 of file flow_graph.h.

117  {
118 
119 public:
120  typedef std::list<C *, tbb::tbb_allocator<C *> > edge_list_type;
121 
122  void add_edge(C &s) {
void const char const char int ITT_FORMAT __itt_group_sync s

Member Data Documentation

◆ initial_buffer_size

template<typename T, typename A = cache_aligned_allocator<T>>
const size_type tbb::flow::interface10::internal::item_buffer< T, A >::initial_buffer_size = 4
staticprotected

Definition at line 52 of file flow_graph.h.

◆ my_array

template<typename T, typename A = cache_aligned_allocator<T>>
buffer_item_type* tbb::flow::interface10::internal::item_buffer< T, A >::my_array
protected

Definition at line 50 of file flow_graph.h.

◆ my_array_size

template<typename T, typename A = cache_aligned_allocator<T>>
size_type tbb::flow::interface10::internal::item_buffer< T, A >::my_array_size
protected

Definition at line 51 of file flow_graph.h.

◆ my_head

template<typename T, typename A = cache_aligned_allocator<T>>
size_type tbb::flow::interface10::internal::item_buffer< T, A >::my_head
protected

Definition at line 53 of file flow_graph.h.

◆ my_tail

template<typename T, typename A = cache_aligned_allocator<T>>
size_type tbb::flow::interface10::internal::item_buffer< T, A >::my_tail
protected

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