Searched refs:SynchronizedQueue (Results 1 – 3 of 3) sorted by relevance
31 struct SynchronizedQueue { struct32 SynchronizedQueue(size_t limit);56 SynchronizedQueue<T>::SynchronizedQueue(size_t limit) : mQueueLimit(limit) { in SynchronizedQueue() function60 T SynchronizedQueue<T>::wait_pop() { in wait_pop()74 bool SynchronizedQueue<T>::push(const T &item) { in push()91 size_t SynchronizedQueue<T>::size() { in size()
60 std::shared_ptr<SynchronizedQueue<Task>> mQueue;
28 mQueue = std::make_shared<SynchronizedQueue<Task>>(limit); in start()