Home
last modified time | relevance | path

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

123

/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Dsequential_task_queue.cpp41 for (auto& entry : tasks_) { in Execute()
48 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in Submit()
50 tasks_.emplace_back(taskIdentifier, std::move(task)); in Submit()
55 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
56 if (it != tasks_.end()) { in SubmitAfter()
57 tasks_.emplace(++it, taskIdentifier, std::move(task)); in SubmitAfter()
59 tasks_ in SubmitAfter()
[all...]
H A Ddispatcher_task_queue.cpp45 auto it = std::find(tasks_.begin(), tasks_.end(), taskIdentifier); in Remove()
46 if (it != tasks_.end()) { in Remove()
47 tasks_.erase(it); in Remove()
57 tasks_.clear(); in Clear()
65 tasks_.emplace_back(taskIdentifier, move(task)); in Submit()
72 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
73 if (it != tasks_.end()) { in SubmitAfter()
74 tasks_ in SubmitAfter()
[all...]
H A Dparallel_task_queue.cpp91 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in Submit()
93 tasks_.emplace_back(taskIdentifier, std::move(task)); in Submit()
98 CORE_ASSERT(std::find(tasks_.cbegin(), tasks_.cend(), taskIdentifier) == tasks_.cend()); in SubmitAfter()
100 auto it = std::find(tasks_.begin(), tasks_.end(), afterIdentifier); in SubmitAfter()
101 if (it != tasks_ in SubmitAfter()
[all...]
/foundation/graphic/graphic_3d/lume/metaobject/src/
H A Dtask_queue.h70 for (auto it = tasks_.begin(); it != tasks_.end();) { in CancelTask()
72 it = tasks_.erase(it); in CancelTask()
89 if (tasks_.empty()) { in AddTaskImpl()
90 tasks_.emplace_back(delay, excTime, BASE_NS::move(p)); in AddTaskImpl()
91 } else if (tasks_.size() == 1) { in AddTaskImpl()
92 if (tasks_.front().executeTime >= excTime) { in AddTaskImpl()
93 tasks_.emplace_back(delay, excTime, BASE_NS::move(p)); in AddTaskImpl()
95 tasks_.insert(tasks_ in AddTaskImpl()
201 BASE_NS::vector<Task> tasks_; global() member in TaskQueueImpl
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/parallel_render/
H A Drs_render_task.cpp25 tasks_.pop(); in ~RSSuperRenderTask()
35 tasks_.push(std::move(task)); in AddTask()
43 auto surfaceNode = tasks_.front()->GetNode(); in GetSurfaceNode()
44 tasks_.pop(); in GetSurfaceNode()
53 auto task = std::move(tasks_.front()); in GetNextRenderTask()
54 tasks_.pop(); in GetNextRenderTask()
H A Drs_render_task.h85 return tasks_.size(); in GetTaskSize()
97 std::queue<std::unique_ptr<RSRenderTask>> tasks_; member in OHOS::Rosen::RSSuperRenderTask
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dtask_queue.cpp31 tasks_.push(task); in PutTask()
46 if (tasks_.empty()) { in GetTaskAutoLock()
51 Task task = tasks_.front(); in GetTaskAutoLock()
52 tasks_.pop(); in GetTaskAutoLock()
73 return tasks_.empty(); in IsEmptyAndUnlocked()
83 return !tasks_.empty(); in CanGetTask()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/
H A Dtask_board.cpp38 [this]() { return tasks_.empty(); }); in WaitForALLTaskFinish()
51 return this->tasks_.empty(); in IsAllTaskFinish()
63 if (this->tasks_.find(task->GetId()) != this->tasks_.end()) { in AddTask()
67 this->tasks_.emplace(task->GetId(), task); in AddTask()
75 if (tasks_.empty()) { in RemoveTask()
82 if (tasks_.find(taskId) == tasks_.end()) { in RemoveTaskInner()
87 tasks_.erase(taskId); in RemoveTaskInner()
93 for (auto t : tasks_) { in DumpAllTasks()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/common/
H A Dtask_scheduler.h66 if (tasks_.size() >= capacity_) { in At()
74 auto it = tasks_.insert({ begin, innerTask}); in At()
75 if (it == tasks_.begin()) { in At()
96 auto it = tasks_.insert({ std::chrono::steady_clock::now() + interval, std::move(innerTask) }); in Reset()
97 if (it == tasks_.begin() || index->second == tasks_.begin()) { in Reset()
100 tasks_.erase(index->second); in Reset()
108 tasks_.clear(); in Clean()
126 tasks_.erase(index->second); in Remove()
158 return !tasks_ in Loop()
198 std::multimap<Time, InnerTask> tasks_; global() member in OHOS::TaskScheduler
[all...]
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dpriority_queue.h49 while (!tasks_.empty()) { in Pop()
50 auto waitTme = tasks_.begin()->first; in Pop()
55 auto temp = tasks_.begin(); in Pop()
59 tasks_.erase(temp); in Pop()
72 auto temp = tasks_.emplace(tme, PQMatrix(std::move(tsk), id)); in Push()
81 return tasks_.size(); in Size()
100 tasks_.erase(index->second); in Update()
101 index->second = tasks_.emplace(time, std::move(matrix)); in Update()
129 tasks_.erase(index->second); in Remove()
139 tasks_ in Clean()
165 std::multimap<_Tme, PQMatrix> tasks_; global() member in OHOS::PriorityQueue
[all...]
/foundation/distributeddatamgr/preferences/frameworks/native/include/
H A Dpriority_queue.h48 while (!tasks_.empty()) { in Pop()
49 auto waitTme = tasks_.begin()->first; in Pop()
54 auto temp = tasks_.begin(); in Pop()
58 tasks_.erase(temp); in Pop()
71 auto temp = tasks_.emplace(tme, PQMatrix(std::move(tsk), id)); in Push()
80 return tasks_.size(); in Size()
102 tasks_.erase(index->second); in Update()
103 index->second = tasks_.emplace(time, std::move(matrix)); in Update()
127 tasks_.erase(index->second); in Remove()
137 tasks_ in Clean()
161 std::multimap<_Tme, PQMatrix> tasks_; global() member in OHOS::NativePreferences::PriorityQueue
[all...]
/foundation/CastEngine/castengine_wifi_display/services/event/
H A Dtaskpool.cpp81 tasks_.emplace_back(std::move(task)); in PushTask()
88 return (maxTaskNum_ > 0) && (tasks_.size() >= maxTaskNum_); in IsOverload()
96 if (tasks_.empty() && isRunning_) { in TaskMainWorker()
99 std::packaged_task<BindedTask> task = std::move(tasks_.front()); in TaskMainWorker()
100 tasks_.pop_front(); in TaskMainWorker()
H A Dtaskpool.h55 return tasks_.size(); in GetTaskNum()
77 std::deque<std::packaged_task<BindedTask>> tasks_; member in OHOS::Sharing::TaskPool
/foundation/multimodalinput/input/intention/scheduler/task_scheduler/src/
H A Dtask_scheduler.cpp121 if (tasks_.empty()) { in PopPendingTaskList()
124 auto firstTask = tasks_.front(); in PopPendingTaskList()
128 tasks_.pop(); in PopPendingTaskList()
134 FI_HILOGD("tasks_ size:%{public}zu", tasks_.size()); in PostTask()
137 size_t tsize = tasks_.size(); in PostTask()
151 tasks_.push(task); in PostTask()
/foundation/ability/ability_runtime/frameworks/native/appkit/app_startup/
H A Dstartup_task_dispatcher.cpp25 const std::shared_ptr<StartupSortResult> &sortResult) : tasks_(tasks), sortResult_(sortResult) in StartupTaskDispatcher()
40 for (auto &iter : tasks_) { in Run()
50 tasksCount_ = tasks_.size(); in Run()
63 auto findResult = tasks_.find(iter); in Run()
64 if (findResult == tasks_.end()) { in Run()
91 auto findResult = tasks_.find(name); in Dispatch()
92 if (findResult == tasks_.end() || findResult->second == nullptr) { in Dispatch()
136 auto childStartupTask = tasks_.find(child); in NotifyChildren()
137 if (childStartupTask == tasks_.end()) { in NotifyChildren()
138 OnError(ERR_STARTUP_INTERNAL_ERROR, child + "is not found in tasks_ in NotifyChildren()
[all...]
H A Dstartup_task_manager.cpp26 : startupTaskManagerId_(startupTaskManagerId), tasks_(std::move(tasks)) in StartupTaskManager()
41 auto result = tasks_.emplace(name, task); in AddTask()
56 TAG_LOGD(AAFwkTag::STARTUP, "id: %{public}u, task number: %{public}zu", startupTaskManagerId_, tasks_.size()); in Prepare()
58 int32_t result = StartupTopologySort::Sort(tasks_, startupSortResult); in Prepare()
68 if (tasks_.empty()) { in Prepare()
72 dispatcher_ = std::make_shared<StartupTaskDispatcher>(tasks_, startupSortResult); in Prepare()
78 TAG_LOGD(AAFwkTag::STARTUP, "id: %{public}u, task number: %{public}zu", startupTaskManagerId_, tasks_.size()); in Run()
/foundation/ability/ability_runtime/services/common/src/
H A Dtask_handler_wrap.cpp111 auto it = tasks_.find(name); in SubmitTask()
112 if (it != tasks_.end()) { in SubmitTask()
122 tasks_.emplace(name, result); in SubmitTask()
154 auto it = tasks_.find(name); in CancelTask()
155 if (it == tasks_.end()) { in CancelTask()
160 tasks_.erase(it); in CancelTask()
167 auto it = tasks_.find(name); in RemoveTask()
168 if (it == tasks_.end() || !it->second.IsSame(taskHandle)) { in RemoveTask()
171 tasks_.erase(it); in RemoveTask()
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/
H A Dthread_pool.cpp35 : name_(name), numThreads_(numThreads), workers_(), isStopped_(false), mutex_(), taskCv_(), tasks_() in ThreadPool()
134 taskCv_.wait(lock, [this] { return isStopped_.load() || !tasks_.empty(); }); in GetTask()
138 auto task = std::move(tasks_.front()); in GetTask()
139 tasks_.pop_front(); in GetTask()
146 return !tasks_.empty(); in HasPendingTasks()
156 tasks_.emplace_front([task = std::move(func)] { task(); }); in Submit()
158 tasks_.emplace_back([task = std::move(func)] { task(); }); in Submit()
/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dbackground_task_executor.cpp109 tasks_.emplace_back(std::move(task)); in PostTask()
143 tasks_.emplace_back(task); in PostTask()
197 if (tasks_.empty() && lowPriorityTasks_.empty()) { in ThreadLoop()
209 // deal with tasks_ first. do lowPriorityTasks_ only when all tasks_ done. in ThreadLoop()
210 if (!tasks_.empty()) { in ThreadLoop()
211 task = std::move(tasks_.front()); in ThreadLoop()
212 tasks_.pop_front(); in ThreadLoop()
/foundation/multimodalinput/input/service/delegate_task/src/
H A Ddelegate_tasks.cpp130 if (tasks_.empty()) { in PopPendingTaskList()
133 auto task = tasks_.front(); in PopPendingTaskList()
137 tasks_.pop(); in PopPendingTaskList()
148 MMI_HILOGD("tasks_ size:%{public}d", static_cast<int32_t>(tasks_.size())); in PostTask()
150 auto tsize = tasks_.size(); in PostTask()
164 tasks_.push(task); in PostTask()
/foundation/arkui/ace_engine/frameworks/core/components_ng/image_provider/
H A Dimage_provider.cpp49 std::unordered_map<std::string, ImageProvider::Task> ImageProvider::tasks_; member in OHOS::Ace::NG::ImageProvider
227 auto it = tasks_.find(key); in RegisterTask()
228 if (it != tasks_.end()) { in RegisterTask()
232 tasks_[key].ctxs_.insert(ctx); in RegisterTask()
239 auto it = tasks_.find(key); in EndTask()
240 if (it == tasks_.end()) { in EndTask()
248 tasks_.erase(it); in EndTask()
255 auto it = tasks_.find(key); in CancelTask()
256 CHECK_NULL_VOID(it != tasks_.end()); in CancelTask()
262 tasks_ in CancelTask()
[all...]
/foundation/arkui/ace_engine/frameworks/core/components/xcomponent/
H A Dxcomponent_component.h46 tasks_.emplace_back(task); in PushTask()
57 return tasks_; in GetTasks()
62 tasks_.clear(); in ClearTasks()
73 std::list<TaskFunction> tasks_; member in OHOS::Ace::XComponentTaskPool
/foundation/bundlemanager/app_domain_verify/frameworks/common/src/httpsession/
H A Dapp_domain_verify_task_mgr.cpp97 if (!tasks_.empty()) { in Init()
98 auto task = std::move(tasks_.front()); in Init()
99 tasks_.pop(); in Init()
104 while (tasks_.empty() && !this->stop_) { in Init()
174 tasks_.push(std::move(taskWrapper)); in AddTask()
/foundation/arkui/ace_engine/frameworks/core/components/custom_paint/
H A Drender_custom_paint.cpp24 tasks_.emplace_back(func); in PushTask()
50 std::copy(taskPool->GetTasks().begin(), taskPool->GetTasks().end(), std::back_inserter(tasks_)); in Update()
H A Dcustom_paint_component.h47 tasks_.emplace_back(task); in PushTask()
58 return tasks_; in GetTasks()
63 tasks_.clear(); in ClearTasks()
157 std::list<TaskFunc> tasks_; member in OHOS::Ace::CanvasTaskPool

Completed in 220 milliseconds

123