Searched refs:tasks_ (Results 1 – 4 of 4) sorted by relevance
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_
30 Handler::Handler(Thread* thread) : tasks_(new std::queue<OnceClosure>()), thread_(thread) { in Handler()51 tasks_->emplace(std::move(closure)); in Post()61 std::swap(tasks_, tmp); in Clear()89 closure = std::move(tasks_->front()); in handle_next_event()90 tasks_->pop(); in handle_next_event()
73 return tasks_ == nullptr; in was_cleared()75 std::queue<common::OnceClosure>* tasks_; variable