concurrent::GenericQueue< T, QueuePolicy >::MultiProducerSide Class Reference

Detailed Description

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

Definition at line 478 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 480 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 507 of file queue.hpp.

GetSoftMaxSize()

template<typename T, typename QueuePolicy>

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

inlinenoexcept

Definition at line 509 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 499 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 )

inlinenodiscard

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

inlinenodiscard

Definition at line 495 of file queue.hpp.

ResumeBlockingOnPush()

template<typename T, typename QueuePolicy>

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

inline

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

StopBlockingOnPush()

template<typename T, typename QueuePolicy>

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

inline

Definition at line 501 of file queue.hpp.

---

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

• userver/concurrent/queue.hpp