Searched refs:ThreadSafeRingBuffer (Results 1 – 4 of 4) sorted by relevance
39 class ThreadSafeRingBuffer class42 ThreadSafeRingBuffer (size_t size);43 ~ThreadSafeRingBuffer (void) {} in ~ThreadSafeRingBuffer()70 ThreadSafeRingBuffer<T>::ThreadSafeRingBuffer (size_t size) in ThreadSafeRingBuffer() function in de::ThreadSafeRingBuffer83 inline void ThreadSafeRingBuffer<T>::pushFrontInternal (const T& elem) in pushFrontInternal()90 inline T ThreadSafeRingBuffer<T>::popBackInternal () in popBackInternal()98 void ThreadSafeRingBuffer<T>::pushFront (const T& elem) in pushFront()108 bool ThreadSafeRingBuffer<T>::tryPushFront (const T& elem) in tryPushFront()126 T ThreadSafeRingBuffer<T>::popBack () in popBack()137 bool ThreadSafeRingBuffer<T>::tryPopBack (T& dst) in tryPopBack()
59 Consumer (ThreadSafeRingBuffer<Message>& buffer, int numProducers) in Consumer()91 ThreadSafeRingBuffer<Message>& m_buffer;99 Producer (ThreadSafeRingBuffer<Message>& buffer, deUint16 threadId, int dataSize) in Producer()116 ThreadSafeRingBuffer<Message>& m_buffer;133 ThreadSafeRingBuffer<Message> buffer (bufSize); in ThreadSafeRingBuffer_selfTest()
118 typedef de::ThreadSafeRingBuffer<Message> MessageQueue;
66 typedef de::ThreadSafeRingBuffer<Task*> TaskQueue;