Searched refs:task_queue_ (Results 1 – 12 of 12) sorted by relevance
36 return (!task_queue_.empty()) || should_quit_; in Run()42 task = std::move(task_queue_.front()); in Run()43 task_queue_.pop(); in Run()57 task_queue_.emplace(std::move(work)); in PostTask()68 task = std::move(task_queue_.front()); in RunUntilIdleForTesting()69 task_queue_.pop(); in RunUntilIdleForTesting()71 if (task_queue_.empty()) in RunUntilIdleForTesting()
124 task_queue_.emplace(std::move(work)); in PostTask()138 return (!task_queue_.empty()) || should_stop_processing_; in Worker()141 if (should_stop_processing_ && task_queue_.empty()) in Worker()144 task = std::move(task_queue_.front()); in Worker()145 task_queue_.pop(); in Worker()
38 std::queue<std::function<void()>> task_queue_; variable
28 std::queue<std::function<void()>> task_queue_; variable
21 DCHECK(task_queue_.empty()); in ~TaskQueue()27 task_queue_.push(std::move(task)); in Append()35 if (!task_queue_.empty()) { in GetNext()36 std::unique_ptr<Task> result = std::move(task_queue_.front()); in GetNext()37 task_queue_.pop(); in GetNext()61 if (task_queue_.empty()) return; in BlockUntilQueueEmptyForTesting()
20 DCHECK(task_queue_.empty()); in ~DelayedTaskQueue()30 task_queue_.push(std::move(task)); in Append()53 task_queue_.push(std::move(task)); in GetNext()56 if (!task_queue_.empty()) { in GetNext()57 std::unique_ptr<Task> result = std::move(task_queue_.front()); in GetNext()58 task_queue_.pop(); in GetNext()67 if (task_queue_.empty() && !delayed_task_queue_.empty()) { in GetNext()
34 while (!task_queue_.empty()) task_queue_.pop_front(); in Terminate()43 task_queue_.push_back(std::make_pair(nestability, std::move(task))); in PostTaskLocked()100 if (nesting_depth_ == 0) return !task_queue_.empty(); in HasPoppableTaskInQueue()101 for (auto it = task_queue_.cbegin(); it != task_queue_.cend(); it++) { in HasPoppableTaskInQueue()129 auto it = task_queue_.begin(); in PopTaskFromQueue()130 for (; it != task_queue_.end(); it++) { in PopTaskFromQueue()135 DCHECK(it != task_queue_.end()); in PopTaskFromQueue()137 task_queue_.erase(it); in PopTaskFromQueue()
48 std::queue<std::unique_ptr<Task>> task_queue_; variable
61 std::queue<std::unique_ptr<Task>> task_queue_; variable
96 std::deque<TaskQueueEntry> task_queue_; in NON_EXPORTED_BASE() local
575 outstanding_tasks_(0), stopped_(false), task_queue_() { } in TaskQueue()581 task_queue_.push(std::move(task)); in Push()588 if (task_queue_.empty()) { in Pop()591 std::unique_ptr<T> result = std::move(task_queue_.front()); in Pop()592 task_queue_.pop(); in Pop()599 while (task_queue_.empty() && !stopped_) { in BlockingPop()605 std::unique_ptr<T> result = std::move(task_queue_.front()); in BlockingPop()606 task_queue_.pop(); in BlockingPop()637 result.swap(task_queue_); in PopAll()
42 std::queue<std::unique_ptr<T>> task_queue_; variable