concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType > Class Template Reference

#include <userver/concurrent/queue_helpers.hpp>

Detailed Description

template<typename QueueType, typename ProducerToken, typename EmplaceEnablerType>
class concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType >

Warning

A single Producer must not be used from multiple threads concurrently

Definition at line 30 of file queue_helpers.hpp.

Public Member Functions
	Producer (const Producer &)=delete
	Producer (Producer &&) noexcept=default
Producer &	operator= (const Producer &)=delete
Producer &	operator= (Producer &&other) noexcept
bool	Push (ValueType &&value, engine::Deadline deadline={}) const
bool	PushNoblock (ValueType &&value) const
void	Reset () &&noexcept
std::shared_ptr< const QueueType >	Queue () const
	Const access to source queue.

Constructor & Destructor Documentation

~Producer()

template<typename QueueType , typename ProducerToken , typename EmplaceEnablerType >

concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType >::~Producer ( )

inline

Definition at line 49 of file queue_helpers.hpp.

Member Function Documentation

operator=()

template<typename QueueType , typename ProducerToken , typename EmplaceEnablerType >

Producer & concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType >::operator= ( Producer< QueueType, ProducerToken, EmplaceEnablerType > && other )

inlinenoexcept

Definition at line 43 of file queue_helpers.hpp.

Push()

template<typename QueueType , typename ProducerToken , typename EmplaceEnablerType >

bool concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType >::Push ( ValueType && value, engine::Deadline deadline = {} ) const

inline

Push element into queue. May wait asynchronously if the queue is full. Leaves the value unmodified if the operation does not succeed.

Returns

whether push succeeded before the deadline and before the task was canceled.

Definition at line 57 of file queue_helpers.hpp.

PushNoblock()

template<typename QueueType , typename ProducerToken , typename EmplaceEnablerType >

bool concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType >::PushNoblock ( ValueType && value ) const

inline

Try to push element into queue without blocking. May be used in non-coroutine environment. Leaves the value unmodified if the operation does not succeed.

Returns

whether push succeeded.

Definition at line 67 of file queue_helpers.hpp.

Queue()

template<typename QueueType , typename ProducerToken , typename EmplaceEnablerType >

std::shared_ptr< const QueueType > concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType >::Queue ( ) const

inline

Const access to source queue.

Definition at line 79 of file queue_helpers.hpp.

Reset()

template<typename QueueType , typename ProducerToken , typename EmplaceEnablerType >

void concurrent::Producer< QueueType, ProducerToken, EmplaceEnablerType >::Reset ( ) &&

inlinenoexcept

Definition at line 72 of file queue_helpers.hpp.

---

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

• userver/concurrent/queue_helpers.hpp