userver: concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide Class Reference
Loading...
Searching...
No Matches
Public Member Functions | List of all members
concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide Class Referencefinal

Detailed Description

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

Definition at line 474 of file queue.hpp.

Public Member Functions

 MultiProducerSide (GenericQueue &queue, std::size_t capacity)
 
template<typename Token >
bool Push (Token &token, T &&value, engine::Deadline deadline, std::size_t value_size)
 
template<typename Token >
bool PushNoblock (Token &token, T &&value, std::size_t value_size)
 
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
 

Constructor & Destructor Documentation

◆ MultiProducerSide()

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

Definition at line 476 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 500 of file queue.hpp.

◆ GetSoftMaxSize()

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

Definition at line 502 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 492 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,
std::size_t value_size )
inline

Definition at line 482 of file queue.hpp.

◆ PushNoblock()

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

Definition at line 488 of file queue.hpp.

◆ ResumeBlockingOnPush()

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

Definition at line 496 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 498 of file queue.hpp.

◆ StopBlockingOnPush()

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

Definition at line 494 of file queue.hpp.

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