Searched refs:tasks_ (Results 1 – 5 of 5) sorted by relevance
57 tasks_.push_back(task); in StartTask()90 for (size_t i = 0; i < tasks_.size(); ++i) { in InternalRunTasks()91 while (!tasks_[i]->Blocked()) { in InternalRunTasks()92 tasks_[i]->Step(); in InternalRunTasks()99 for (size_t i = 0; i < tasks_.size(); ++i) { in InternalRunTasks()100 if (tasks_[i]->IsDone()) { in InternalRunTasks()101 Task* task = tasks_[i]; in InternalRunTasks()115 tasks_[i] = NULL; in InternalRunTasks()120 it = std::remove(tasks_.begin(), in InternalRunTasks()121 tasks_.end(), in InternalRunTasks()[all …]
104 std::vector<Task *> tasks_; variable
107 while (!tasks_.empty()) { in ~PosixDynamicThreadPool()108 Task* task = tasks_.front(); in ~PosixDynamicThreadPool()109 tasks_.pop(); in ~PosixDynamicThreadPool()128 tasks_.push(task); in PostTask()131 if (static_cast<size_t>(num_idle_threads_) >= tasks_.size()) { in PostTask()148 if (tasks_.empty()) { // No work available, wait for work. in WaitForTask()157 if (tasks_.empty()) { in WaitForTask()164 Task* task = tasks_.front(); in WaitForTask()165 tasks_.pop(); in WaitForTask()
78 std::queue<Task*> tasks_; variable
28 const std::queue<Task*>& tasks() const { return pool_->tasks_; } in tasks()