Searched refs:task_queue_ (Results 1 – 1 of 1) sorted by relevance
316 task_queue_.clear(); in stopThread()383 task_queue_.erase(tasks_by_id_[async_task_id]); in cancel_task_with_lock_held()401 task_queue_.insert(task); in scheduleTask()442 if (!task_queue_.empty()) { in ThreadRoutine()443 std::shared_ptr<Task> task_p = *(task_queue_.begin()); in ThreadRoutine()447 task_queue_.erase(task_p); // need to remove and add again if in ThreadRoutine()451 task_queue_.insert(task_p); in ThreadRoutine()467 if (task_queue_.size() > 0) { in ThreadRoutine()472 (*task_queue_.begin())->time; in ThreadRoutine()490 std::set<std::shared_ptr<Task>, task_p_comparator> task_queue_; member in test_vendor_lib::AsyncManager::AsyncTaskManager