Searched refs:ThreadSafeQueue (Results 1 – 3 of 3) sorted by relevance
34 class ThreadSafeQueue {37 ThreadSafeQueue() = default;38 explicit ThreadSafeQueue(std::size_t max_elements, in ThreadSafeQueue() function
48 static void EraseHalfOfElements(ThreadSafeQueue<Stripe>::QueueImpl* q);61 ThreadSafeQueue<Stripe> stripes_;
67 ThreadSafeQueue<Stripe>::QueueImpl* q) { in EraseHalfOfElements()