Searched refs:task_queue_ (Results 1 – 2 of 2) 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
1792 TaskQueue task_queue_; member in android::os::dumpstate::TaskQueueTest1810 task_queue_.add(task_1, std::placeholders::_1); in TEST_F()1811 task_queue_.add(task_2, std::placeholders::_1); in TEST_F()1813 task_queue_.run(/* do_cancel = */false); in TEST_F()1828 task_queue_.add(task_1, std::placeholders::_1); in TEST_F()1829 task_queue_.add(task_2, std::placeholders::_1); in TEST_F()1831 task_queue_.run(/* do_cancel = */true); in TEST_F()