Searched refs:SynchronizedQueue (Results 1 – 3 of 3) sorted by relevance
31 struct SynchronizedQueue { struct32 SynchronizedQueue(size_t limit);68 SynchronizedQueue<T>::SynchronizedQueue(size_t limit) : mQueueLimit(limit) { in SynchronizedQueue() function72 T SynchronizedQueue<T>::wait_pop() { in wait_pop()86 bool SynchronizedQueue<T>::push(const T &item) { in push()103 size_t SynchronizedQueue<T>::size() { in size()
32 mQueue = std::make_shared<SynchronizedQueue<Task>>(limit); in start()
29 struct SynchronizedQueue;63 std::shared_ptr<SynchronizedQueue<Task>> mQueue;