userver: concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide Class Reference
•All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Modules Pages Concepts
Public Member Functions | List of all members
concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide Class Referencefinal

Table of Contents

Public Member Functions

 MultiProducerSide (GenericQueue &queue, std::size_t capacity)
 
template<typename Token >
bool Push (Token &token, T &&value, engine::Deadline deadline)
 
template<typename Token >
bool PushNoblock (Token &token, T &&value)
 
void OnElementPopped (std::size_t value_size)
 
void StopBlockingOnPush ()
 
void ResumeBlockingOnPush ()
 
void SetSoftMaxSize (std::size_t count)
 
std::size_t GetSizeApproximate () const noexcept
 
std::size_t GetSoftMaxSize () const noexcept
 

Detailed Description

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

Definition at line 417 of file queue.hpp.

Constructor & Destructor Documentation

◆ MultiProducerSide()

template<typename T , typename QueuePolicy >
concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide::MultiProducerSide ( GenericQueue &  queue,
std::size_t  capacity 
)
inlineexplicit

Definition at line 419 of file queue.hpp.

Member Function Documentation

◆ GetSizeApproximate()

template<typename T , typename QueuePolicy >
std::size_t concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide::GetSizeApproximate ( ) const
inlinenoexcept

Definition at line 457 of file queue.hpp.

◆ GetSoftMaxSize()

template<typename T , typename QueuePolicy >
std::size_t concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide::GetSoftMaxSize ( ) const
inlinenoexcept

Definition at line 461 of file queue.hpp.

◆ OnElementPopped()

template<typename T , typename QueuePolicy >
void concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide::OnElementPopped ( std::size_t  value_size)
inline

Definition at line 441 of file queue.hpp.

◆ Push()

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

Definition at line 427 of file queue.hpp.

◆ PushNoblock()

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

Definition at line 435 of file queue.hpp.

◆ ResumeBlockingOnPush()

template<typename T , typename QueuePolicy >
void concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide::ResumeBlockingOnPush ( )
inline

Definition at line 449 of file queue.hpp.

◆ SetSoftMaxSize()

template<typename T , typename QueuePolicy >
void concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide::SetSoftMaxSize ( std::size_t  count)
inline

Definition at line 453 of file queue.hpp.

◆ StopBlockingOnPush()

template<typename T , typename QueuePolicy >
void concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide::StopBlockingOnPush ( )
inline

Definition at line 445 of file queue.hpp.

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