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 571 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 573 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 614 of file queue.hpp.

◆ OnElementPushed()

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

Definition at line 605 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 )
inlinenodiscard

Definition at line 580 of file queue.hpp.

◆ PopNoblock()

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

Definition at line 601 of file queue.hpp.

◆ ResumeBlockingOnPop()

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

Definition at line 612 of file queue.hpp.

◆ StopBlockingOnPop()

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

Definition at line 610 of file queue.hpp.


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