Lines Matching refs:queue_
85 std::queue<std::unique_ptr<T>> queue_; variable
105 EnqueueBuffer(IQueueEnqueue<T>* queue) : queue_(queue) {} in EnqueueBuffer()
109 queue_->UnregisterEnqueue(); in ~EnqueueBuffer()
117 …queue_->RegisterEnqueue(handler, common::Bind(&EnqueueBuffer<T>::enqueue_callback, common::Unretai… in Enqueue()
124 queue_->UnregisterEnqueue(); in Clear()
146 queue_->UnregisterEnqueue(); in enqueue_callback()
155 IQueueEnqueue<T>* queue_; variable
238 if (queue_.empty()) { in TryDequeue()
244 std::unique_ptr<T> data = std::move(queue_.front()); in TryDequeue()
245 queue_.pop(); in TryDequeue()
258 queue_.push(std::move(data)); in EnqueueCallbackInternal()