concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType > Class Template Reference

Your opinion will help to improve our service

Leave a feedback >

Table of Contents

• Detailed Description
• Public Member Functions
• Constructor & Destructor Documentation
• ~Consumer()
• Member Function Documentation
• operator=()
• Pop()
• PopNoblock()
• Queue()
• Reset()

#include <userver/concurrent/queue_helpers.hpp>

Detailed Description

template<typename QueueType, typename ConsumerToken, typename EmplaceEnablerType>
class concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType >

Consumer side of concurrent queues.

Warning

A single Consumer must not be used from multiple threads concurrently

See also

concurrent_queues

Definition at line 101 of file queue_helpers.hpp.

Public Member Functions
	Consumer (const Consumer &)=delete
	Consumer (Consumer &&) noexcept=default
Consumer &	operator= (const Consumer &)=delete
Consumer &	operator= (Consumer &&other) noexcept
bool	Pop (ValueType &value, engine::Deadline deadline={}) const
	Pop an element from queue. May wait asynchronously if the queue is empty, but the producer is alive.
bool	PopNoblock (ValueType &value) const
	Try to pop an element from queue without blocking. May be used in non-coroutine environment.
void	Reset () &&
std::shared_ptr< const QueueType >	Queue () const
	Const access to source queue.

Constructor & Destructor Documentation

~Consumer()

template<typename QueueType, typename ConsumerToken, typename EmplaceEnablerType>

concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType >::~Consumer ( )

inline

Definition at line 120 of file queue_helpers.hpp.

Member Function Documentation

operator=()

template<typename QueueType, typename ConsumerToken, typename EmplaceEnablerType>

Consumer & concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType >::operator= ( Consumer< QueueType, ConsumerToken, EmplaceEnablerType > && other )

inlinenoexcept

Definition at line 114 of file queue_helpers.hpp.

Pop()

template<typename QueueType, typename ConsumerToken, typename EmplaceEnablerType>

bool concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType >::Pop ( ValueType & value, engine::Deadline deadline = {} ) const

inlinenodiscard

Pop an element from queue. May wait asynchronously if the queue is empty, but the producer is alive.

Returns

whether something was popped before the deadline or before a task cancellation. false can be returned before the deadline when the producer is no longer alive.

Warning

Be careful when using a method in a loop. The engine::Deadline is a wrapper over std::chrono::time_point, not duration! If you need a timeout, you must reconstruct the deadline in the loop.

Definition at line 132 of file queue_helpers.hpp.

PopNoblock()

template<typename QueueType, typename ConsumerToken, typename EmplaceEnablerType>

bool concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType >::PopNoblock ( ValueType & value ) const

inlinenodiscard

Try to pop an element from queue without blocking. May be used in non-coroutine environment.

Returns

whether something was popped.

Definition at line 142 of file queue_helpers.hpp.

Queue()

template<typename QueueType, typename ConsumerToken, typename EmplaceEnablerType>

std::shared_ptr< const QueueType > concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType >::Queue ( ) const

inlinenodiscard

Const access to source queue.

Definition at line 154 of file queue_helpers.hpp.

Reset()

template<typename QueueType, typename ConsumerToken, typename EmplaceEnablerType>

void concurrent::Consumer< QueueType, ConsumerToken, EmplaceEnablerType >::Reset ( ) &&

inline

Definition at line 147 of file queue_helpers.hpp.

---

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

• userver/concurrent/queue_helpers.hpp