Searched refs:task_queue_ (Results 1 – 1 of 1) sorted by relevance
289 task_queue_.erase(tasks_by_id[async_task_id]); in CancelAsyncTask()302 task_queue_.clear(); in stopThread()368 task_queue_.insert(task); in scheduleTask()410 if (!task_queue_.empty()) { in ThreadRoutine()411 std::shared_ptr<Task> task_p = *(task_queue_.begin()); in ThreadRoutine()415 task_queue_.erase(task_p); // need to remove and add again if in ThreadRoutine()419 task_queue_.insert(task_p); in ThreadRoutine()433 if (task_queue_.size() > 0) { in ThreadRoutine()434 internal_cond_var_.wait_until(guard, (*task_queue_.begin())->time); in ThreadRoutine()451 std::set<std::shared_ptr<Task>, task_p_comparator> task_queue_; member in test_vendor_lib::AsyncManager::AsyncTaskManager