Template Class ThreadSafeQueue

• Defined in File threadsafe-queue.h

Inheritance Relationships

Base Type

• public common::ThreadSafeQueueBase (Class ThreadSafeQueueBase)

Class Documentation

template<typename QueueType>
class common::ThreadSafeQueue : public common::ThreadSafeQueueBase

Public Functions

inline virtual void NotifyAll() const override

inline ThreadSafeQueue()

inline ~ThreadSafeQueue() override

inline virtual void Shutdown() override

inline virtual void Resume() override

inline void Push(const QueueType &value)

inline void PushNonBlocking(const QueueType &value)

inline virtual size_t Size() const override

inline virtual bool Empty() const override

inline bool PushBlockingIfFull(const QueueType &value, size_t max_queue_size)

inline bool PushNonBlockingDroppingOldestElementIfFull(const QueueType &value, size_t max_queue_size)

inline bool Pop(QueueType *value)

inline bool PopBlocking(QueueType *value)

inline bool PopNonBlocking(QueueType *value)

inline bool PopTimeout(QueueType *value, int64_t timeout_nanoseconds)

inline bool getCopyOfFront(QueueType *value)

inline bool getCopyOfFrontBlocking(QueueType *value)

inline bool getCopyOfBack(QueueType *value)

inline bool getCopyOfBackBlocking(QueueType *value)

Public Members

ThreadSafeQueue

mutable std::mutex mutex_

mutable std::condition_variable condition_empty_

mutable std::condition_variable condition_full_

std::queue<QueueType> queue_

std::atomic_bool shutdown_