userver: concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide Class Reference
Loading...
Searching...
No Matches
concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide Class Referencefinal

Detailed Description

template<typename T, typename QueuePolicy>
class concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide

Definition at line 560 of file queue.hpp.

Public Member Functions

 SingleConsumerSide (GenericQueue &queue)
 
template<typename Token >
bool Pop (Token &token, T &value, engine::Deadline deadline)
 
template<typename Token >
bool PopNoblock (Token &token, T &value)
 
void OnElementPushed ()
 
void StopBlockingOnPop ()
 
void ResumeBlockingOnPop ()
 
std::size_t GetElementCount () const
 

Constructor & Destructor Documentation

◆ SingleConsumerSide()

template<typename T , typename QueuePolicy >
concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide::SingleConsumerSide ( GenericQueue & queue)
inlineexplicit

Definition at line 562 of file queue.hpp.

Member Function Documentation

◆ GetElementCount()

template<typename T , typename QueuePolicy >
std::size_t concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide::GetElementCount ( ) const
inline

Definition at line 600 of file queue.hpp.

◆ OnElementPushed()

template<typename T , typename QueuePolicy >
void concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide::OnElementPushed ( )
inline

Definition at line 591 of file queue.hpp.

◆ Pop()

template<typename T , typename QueuePolicy >
template<typename Token >
bool concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide::Pop ( Token & token,
T & value,
engine::Deadline deadline )
inline

Definition at line 566 of file queue.hpp.

◆ PopNoblock()

template<typename T , typename QueuePolicy >
template<typename Token >
bool concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide::PopNoblock ( Token & token,
T & value )
inline

Definition at line 587 of file queue.hpp.

◆ ResumeBlockingOnPop()

template<typename T , typename QueuePolicy >
void concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide::ResumeBlockingOnPop ( )
inline

Definition at line 598 of file queue.hpp.

◆ StopBlockingOnPop()

template<typename T , typename QueuePolicy >
void concurrent::GenericQueue< T, QueuePolicy >::SingleConsumerSide::StopBlockingOnPop ( )
inline

Definition at line 596 of file queue.hpp.


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