Searched refs:tasks_ (Results 1 – 12 of 12) sorted by relevance
33 if (!tasks_.empty()) { in ~TaskProcessor()34 LOG(WARNING) << "TaskProcessor: Finalizing " << tasks_.size() << " unprocessed tasks."; in ~TaskProcessor()35 for (HeapTask* task : tasks_) { in ~TaskProcessor()44 tasks_.insert(task); in AddTask()52 if (tasks_.empty()) { in GetTask()60 HeapTask* task = *tasks_.begin(); in GetTask()65 tasks_.erase(tasks_.begin()); in GetTask()82 auto range = tasks_.equal_range(task); in UpdateTargetRunTime()87 tasks_.erase(it); in UpdateTargetRunTime()89 tasks_.insert(task); in UpdateTargetRunTime()[all …]
80 std::multiset<HeapTask*, CompareByTargetRunTime> tasks_ GUARDED_BY(lock_);
55 tasks_.emplace(now + delay, std::move(task)); in PostPackagedTaskWithDelay()70 while (!terminate_loop_ && tasks_.empty()) { in TaskExecutorWorker()78 auto timepoint = tasks_.begin()->first; in TaskExecutorWorker()83 timepoint = tasks_.begin()->first; in TaskExecutorWorker()96 while (!tasks_.empty()) { in TaskExecutorWorker()97 auto task_with_delay = tasks_.begin(); in TaskExecutorWorker()102 tasks_.erase(task_with_delay); in TaskExecutorWorker()
62 std::multimap<std::chrono::time_point<std::chrono::steady_clock>, Task> tasks_
39 …: tasks_(new std::queue<OnceClosure>()), thread_(thread), fd_(eventfd(0, EFD_SEMAPHORE | EFD_NONBL… in Handler()63 tasks_->emplace(std::move(closure)); in Post()75 std::swap(tasks_, tmp); in Clear()104 closure = std::move(tasks_->front()); in handle_next_event()105 tasks_->pop(); in handle_next_event()
29 while (!tasks_.empty()) { in run()30 auto task = tasks_.front(); in run()31 tasks_.pop(); in run()
68 while (!tasks_.empty()) tasks_.pop(); in shutdown()181 if (tasks_.empty()) { in loop()185 std::packaged_task<std::string()> task = std::move(tasks_.front()); in loop()186 tasks_.pop(); in loop()
51 tasks_.emplace([=](bool cancelled) { in add()67 std::queue<Task> tasks_; variable
162 tasks_.push(std::move(packaged_task)); in post()196 std::queue<Task> tasks_; variable
144 tasks_.push_back(task); in AddTask()159 tasks_.clear(); in RemoveAllTasks()288 Task* task = tasks_.front(); in TryGetTaskLocked()289 tasks_.pop_front(); in TryGetTaskLocked()317 return tasks_.size(); in GetTaskCount()
190 return started_ && !tasks_.empty(); in HasOutstandingTasks()201 std::deque<Task*> tasks_ GUARDED_BY(task_queue_lock_);
101 return tasks_ == nullptr; in was_cleared()103 std::queue<common::OnceClosure>* tasks_; variable