Searched refs:queues_ (Results 1 – 7 of 7) sorted by relevance
35 queues_.pop(); in Pop()42 queues_.push(data); in Push()48 …or(lock, std::chrono::milliseconds(timeout_), [&data, this]() { return data == queues_.front(); }); in Wait()54 return data == queues_.front(); in IsReady()60 if (queues_.empty()) { in GetFront()63 data = queues_.front(); in GetFront()70 std::queue<T> queues_; variable
36 queues_.pop(); in Pop()43 queues_.push(data); in Push()49 …or(lock, std::chrono::milliseconds(timeout_), [&data, this]() { return data == queues_.front(); }); in Wait()55 if (queues_.empty()) { in GetFront()58 data = queues_.front(); in GetFront()65 std::queue<T> queues_; variable
34 queues_.pop(); in Pop()41 queues_.push(data); in Push()55 return data == queues_.front(); in IsReady()61 std::queue<T> queues_; variable
63 queues_.clear(); in ~ObjectRegistry()528 if (auto queue = queues_.find(queueId); queue != queues_.end()) { in GetTaskQueue()539 if (auto existing = queues_.find(queueId); existing != queues_.end()) { in RegisterTaskQueue()540 queues_.erase(existing); in RegisterTaskQueue()546 queues_[queueId] = queue; in RegisterTaskQueue()553 if (auto existing = queues_.find(queueId); existing != queues_.end()) { in UnregisterTaskQueue()554 queues_.erase(existing); in UnregisterTaskQueue()563 return queues_.find(queueId) != queues_.end(); in HasTaskQueue()569 queues_.clear(); in UnregisterAllTaskQueues()
169 BASE_NS::unordered_map<BASE_NS::Uid, ITaskQueue::Ptr> queues_; variable
65 if (queues_.empty()) {75 queue = queues_.front();76 queues_.pop_front();91 queues_.push_back(queue);
79 Queues queues_; variable