Lines Matching refs:queue_
122 BGQueue queue_; member
141 queue_(), in Impl()
196 (queue_.empty() || IsExcessiveThread(thread_id))) { in BGThread()
203 queue_.empty()) { in BGThread()
223 auto func = std::move(queue_.front().function); in BGThread()
224 queue_.pop_front(); in BGThread()
226 queue_len_.store(static_cast<unsigned int>(queue_.size()), in BGThread()
370 queue_.push_back(BGItem()); in Submit()
372 auto& item = queue_.back(); in Submit()
377 queue_len_.store(static_cast<unsigned int>(queue_.size()), in Submit()
398 BGQueue::iterator it = queue_.begin(); in UnSchedule()
399 while (it != queue_.end()) { in UnSchedule()
404 it = queue_.erase(it); in UnSchedule()
410 queue_len_.store(static_cast<unsigned int>(queue_.size()), in UnSchedule()