#include <_concurrent_queue_impl.h>

Inheritance diagram for tbb::strict_ppl::internal::concurrent_queue_iterator_rep< T >:

Collaboration diagram for tbb::strict_ppl::internal::concurrent_queue_iterator_rep< T >:

Public Member Functions
	concurrent_queue_iterator_rep (const concurrent_queue_base_v3< T > &queue)

bool	get_item (T *&item, size_t k)
	Set item to point to kth element. Return true if at end of queue or item is marked valid; false otherwise. More...

Public Attributes
ticket	head_counter

const concurrent_queue_base_v3< T > &	my_queue

concurrent_queue_base_v3< T >::page *	array [concurrent_queue_rep< T >::n_queue]

Private Types
typedef micro_queue< T >::padded_page	padded_page

Additional Inherited Members
Private Member Functions inherited from tbb::internal::no_assign
void	operator= (const no_assign &)=delete

	no_assign (const no_assign &)=default

	no_assign ()=default

Detailed Description

template<typename T>
class tbb::strict_ppl::internal::concurrent_queue_iterator_rep< T >

Definition at line 393 of file _concurrent_queue_impl.h.

Member Typedef Documentation

◆ padded_page

template<typename T>

typedef micro_queue<T>::padded_page tbb::strict_ppl::internal::concurrent_queue_iterator_rep< T >::padded_page

private

Definition at line 612 of file _concurrent_queue_impl.h.

Constructor & Destructor Documentation

◆ concurrent_queue_iterator_rep()

template<typename T>

tbb::strict_ppl::internal::concurrent_queue_iterator_rep< T >::concurrent_queue_iterator_rep ( const concurrent_queue_base_v3< T > & queue )

inline

Definition at line 617 of file _concurrent_queue_impl.h.

                                                                               :
         head_counter(queue.my_rep->head_counter),
         my_queue(queue)
     {
         for( size_t k=0; k<concurrent_queue_rep<T>::n_queue; ++k )
             array[k] = queue.my_rep->array[k].head_page;
     }

Member Function Documentation

◆ get_item()

template<typename T>

bool tbb::strict_ppl::internal::concurrent_queue_iterator_rep< T >::get_item	(	T *&	item,
		size_t	k
	)

Set item to point to kth element. Return true if at end of queue or item is marked valid; false otherwise.

Definition at line 630 of file _concurrent_queue_impl.h.

                                                                     {
     if( k==my_queue.my_rep->tail_counter ) {
         item = NULL;
         return true;
     } else {
         typename concurrent_queue_base_v3<T>::page* p = array[concurrent_queue_rep<T>::index(k)];
         __TBB_ASSERT(p,NULL);
         size_t i = modulo_power_of_two( k/concurrent_queue_rep<T>::n_queue, my_queue.my_rep->items_per_page );
         item = &micro_queue<T>::get_ref(*p,i);
         return (p->mask & uintptr_t(1)<<i)!=0;
     }
 }