Home
last modified time | relevance | path

Searched refs:tasks_ (Results 1 - 7 of 7) sorted by relevance

/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_queue.cpp21 tasks_.emplace_back(taskId); in EnqueueTaskId()
26 auto it = std::find(tasks_.begin(), tasks_.end(), taskId); in EraseWaitingTaskId()
27 if (it != tasks_.end()) { in EraseWaitingTaskId()
28 tasks_.erase(it); in EraseWaitingTaskId()
36 if (!tasks_.empty()) { in DequeueTaskId()
37 uint64_t taskId = tasks_.front(); in DequeueTaskId()
38 tasks_.pop_front(); in DequeueTaskId()
46 return tasks_.empty(); in IsEmpty()
H A Dtask_queue.h34 return tasks_.size(); in GetTaskNum()
38 std::list<uint64_t> tasks_ {};
H A Dtask_manager.cpp117 for (auto& [_, task] : tasks_) { in ~TaskManager()
121 tasks_.clear(); in ~TaskManager()
182 for (const auto& [_, task] : tasks_) { in GetTaskInfos()
1397 tasks_.emplace(taskId, task); in StoreTask()
1403 tasks_.erase(taskId); in RemoveTask()
1409 auto iter = tasks_.find(taskId); in GetTask()
1410 if (iter == tasks_.end()) { in GetTask()
1455 auto item = tasks_.find(taskId); in CheckTask()
1456 return item != tasks_.end(); in CheckTask()
H A Dtask_manager.h180 std::unordered_map<uint64_t, Task*> tasks_ {};
/commonlibrary/c_utils/base/src/
H A Dthread_pool.cpp84 tasks_.push_back(f); in AddTask()
92 return tasks_.size(); in GetCurTaskNum()
99 while (tasks_.empty() && running_) { in ScheduleTask()
104 if (!tasks_.empty()) { in ScheduleTask()
105 task = tasks_.front(); in ScheduleTask()
106 tasks_.pop_front(); in ScheduleTask()
117 return (maxTaskNum_ > 0) && (tasks_.size() >= maxTaskNum_); in Overloaded()
/commonlibrary/c_utils/base/include/
H A Dthread_pool.h111 std::deque<Task> tasks_; member in OHOS::ThreadPool
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp357 taskManager.tasks_.clear(); in CancelTask()
415 taskManager.tasks_.clear(); in GetTaskByPriority()

Completed in 8 milliseconds