Home
last modified time | relevance | path

Searched refs:TaskManager (Results 1 – 25 of 81) sorted by relevance

1234

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/
H A Dtask_manager.cpp18 TaskManager::TaskManager(std::shared_ptr<ExecutorPool> executors) : executors_(executors) in TaskManager() function in OHOS::DistributedData::TaskManager
22 TaskManager::~TaskManager() in ~TaskManager()
26 TaskManager::TaskId TaskManager::Execute(const Task &task) in Execute()
30 TaskManager::TaskId TaskManager::Execute(const Task &task, Duration delay) in Execute()
34 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration interval) in Schedule()
38 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval) in Schedule()
42 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval, uint… in Schedule()
46 bool TaskManager::Remove(const TaskId &taskId, bool wait) in Remove()
50 TaskManager::TaskId TaskManager::Reset(const TaskId &taskId, Duration interval) in Reset()
H A Dtask_manager.h21 class TaskManager : public DistributedDB::IThreadPool {
26 TaskManager() = default;
27 explicit TaskManager(std::shared_ptr<ExecutorPool> executors);
28 ~TaskManager() override;
/ohos5.0/foundation/arkui/ui_lite/interfaces/innerkits/common/
H A Dtask_manager.h25 class TaskManager : public HeapBase {
31 static TaskManager* GetInstance();
74 TaskManager() : canTaskRun_(false), isHandlerRunning_(false) {} in TaskManager() function
75 ~TaskManager() {} in ~TaskManager()
77 TaskManager(const TaskManager&) = delete;
78 TaskManager& operator=(const TaskManager&) = delete;
79 TaskManager(TaskManager&&) = delete;
80 TaskManager& operator=(TaskManager&&) = delete;
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/task_manager/
H A Dtask_manager.cpp24 TaskManager::TaskManager(const std::string& name, uint32_t numThreads, bool serial) in TaskManager() function in OHOS::CameraStandard::DeferredProcessing::TaskManager
37 void TaskManager::Initialize() in Initialize()
57 TaskManager::~TaskManager() in ~TaskManager()
71 void TaskManager::CreateDelayedTaskGroupIfNeed() in CreateDelayedTaskGroupIfNeed()
88 void TaskManager::BeginBackgroundTasks() in BeginBackgroundTasks()
93 void TaskManager::EndBackgroundTasks() in EndBackgroundTasks()
116 bool TaskManager::SubmitTask(std::function<void()> task) in SubmitTask()
127 bool TaskManager::SubmitTask(TaskGroupHandle handle, std::any param) in SubmitTask()
137 void TaskManager::CancelAllTasks() in CancelAllTasks()
147 bool TaskManager::IsEmpty() in IsEmpty()
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask_manager.cpp67 TaskManager& TaskManager::GetInstance() in GetInstance()
69 static TaskManager manager; in GetInstance()
73 TaskManager::TaskManager() in TaskManager() function in Commonlibrary::Concurrent::TaskPoolModule::TaskManager
81 TaskManager::~TaskManager() in ~TaskManager()
284 void TaskManager::TryTriggerExpand() in TryTriggerExpand()
509 TaskManager& taskManager = TaskManager::GetInstance(); in TriggerLoadBalance()
516 void TaskManager::TryExpand() in TryExpand()
556 TaskManager& taskManager = TaskManager::GetInstance(); in NotifyExpand()
560 void TaskManager::RunTaskManager() in RunTaskManager()
718 uint32_t TaskManager::GetTaskNum() in GetTaskNum()
[all …]
H A Dworker.cpp38 if (TaskManager::GetInstance().EnableFfrt()) { in PriorityScope()
77 TaskManager::GetInstance().RemoveWorker(worker); in ReleaseWorkerHandles()
80 TaskManager::GetInstance().GetThreadNum()); in ReleaseWorkerHandles()
116 TaskManager& taskManager = TaskManager::GetInstance(); in CheckFreeConditions()
162 if (TaskManager::GetInstance().EnableFfrt()) { in InitFfrtInfo()
250 TaskManager::GetInstance().RemoveWorker(worker); in ExecuteInThread()
251 TaskManager::GetInstance().CountTraceForWorker(); in ExecuteInThread()
318 TaskManager::GetInstance().NotifyWorkerIdle(this); in NotifyIdle()
323 TaskManager::GetInstance().NotifyWorkerCreated(this); in NotifyWorkerCreated()
374 TaskManager::GetInstance().NotifyWorkerRunning(worker); in PerformTask()
[all …]
H A Dtask_manager.h57 class TaskManager {
59 static TaskManager& GetInstance();
155 TaskManager();
156 ~TaskManager();
157 TaskManager(const TaskManager &) = delete;
158 TaskManager& operator=(const TaskManager &) = delete;
159 TaskManager(TaskManager &&) = delete;
160 TaskManager& operator=(TaskManager &&) = delete;
H A Dtaskpool.cpp103 TaskManager::GetInstance().InitTaskManager(env); in InitTaskPool()
110 auto* msgQueue = TaskManager::GetInstance().GetMessageQueue(req); in ExecuteCallback()
182 napi_value taskInfos = TaskManager::GetInstance().GetTaskInfos(env);
206 auto task = TaskManager::GetInstance().GetTask(taskId); in TerminateTask()
212 TaskManager::GetInstance().TerminateTask(taskId); in TerminateTask()
275 TaskManager::GetInstance().StoreTask(task->taskId_, task); in Execute()
529 TaskManager::GetInstance().RemoveTask(task->taskId_); in TriggerTask()
568 auto task = TaskManager::GetInstance().GetTask(taskId); in UpdateGroupInfoByResult()
602 TaskManager::GetInstance().IncreaseRefCount(task->taskId_); in ExecuteTask()
636 TaskManager::GetInstance().CancelTask(env, taskId); in Cancel()
[all …]
H A Dtask.cpp85 TaskManager::GetInstance().StoreTask(task->taskId_, task); in TaskConstructor()
114 TaskManager::GetInstance().ReleaseTaskData(env, task);
126 TaskManager::GetInstance().ReleaseTaskData(env, task, shouldDelete);
423 TaskManager::GetInstance().RegisterCallback(env, taskId, nullptr); in OnReceiveData()
440 auto task = TaskManager::GetInstance().GetTask(taskId); in OnReceiveData()
1073 TaskManager::GetInstance().NotifyDependencyTaskInfo(taskId_); in NotifyPendingTask()
1345 if ((!TaskManager::GetInstance().IsDependentByTaskId(taskId_)) && in TryClearHasDependency()
1346 (!TaskManager::GetInstance().IsDependendByTaskId(taskId_))) { in TryClearHasDependency()
1413 Task* task = TaskManager::GetInstance().GetTask(taskId); in VerifyAndPostResult()
1454 TaskManager::GetInstance().RemoveTask(taskId_); in ShouldDeleteTask()
[all …]
/ohos5.0/foundation/filemanagement/dfs_service/test/unittests/cloudsync_sa/mock/
H A Dtask_mock.cpp79 TaskManager::TaskManager() {} in TaskManager() function in OHOS::FileManagement::CloudSync::TaskManager
81 TaskManager::~TaskManager() {} in ~TaskManager()
83 shared_ptr<TaskRunner> TaskManager::AllocRunner(int32_t userId, in AllocRunner()
97 void TaskManager::ReleaseRunner(int32_t userId, const std::string &bundleName) in ReleaseRunner()
104 shared_ptr<TaskRunner> TaskManager::GetRunner(int32_t userId, const std::string &bundleName) in GetRunner()
114 void TaskManager::InitRunner(TaskRunner &runner) in InitRunner()
116 runner.SetCommitFunc(bind(&TaskManager::CommitTask, this, placeholders::_1, placeholders::_2)); in InitRunner()
119 int32_t TaskManager::CommitTask(shared_ptr<TaskRunner> runner, shared_ptr<Task> t) in CommitTask()
125 string TaskManager::GetKey(int32_t userId, const string &bundleName) in GetKey()
/ohos5.0/foundation/arkui/ui_lite/frameworks/core/
H A Dtask_manager.cpp22 TaskManager* TaskManager::GetInstance() in GetInstance()
24 static TaskManager taskManager; in GetInstance()
28 void TaskManager::Add(Task* task) in Add()
46 void TaskManager::Remove(Task* task) in Remove()
61 void TaskManager::TaskHandler() in TaskHandler()
93 void TaskManager::ResetTaskHandlerMutex() in ResetTaskHandlerMutex()
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp188 TaskManager& taskManager = TaskManager::GetInstance(); in TryTriggerExpand()
199 TaskManager& taskManager = TaskManager::GetInstance(); in CheckForBlockedWorkers()
233 TaskManager& taskManager = TaskManager::GetInstance(); in TriggerShrink()
267 TaskManager& taskManager = TaskManager::GetInstance(); in NotifyShrink()
307 TaskManager& taskManager = TaskManager::GetInstance(); in TryExpand()
328 TaskManager& taskManager = TaskManager::GetInstance(); in CancelTask()
363 TaskManager& taskManager = TaskManager::GetInstance(); in NotifyWorkerIdle()
380 TaskManager& taskManager = TaskManager::GetInstance(); in EnqueueTaskId()
401 TaskManager& taskManager = TaskManager::GetInstance(); in GetTaskByPriority()
421 TaskManager& taskManager = TaskManager::GetInstance(); in RestoreWorker()
[all …]
H A Dtest_taskpool.cpp93 TaskManager &taskManager = TaskManager::GetInstance(); in CreateTaskObject()
128 TaskManager &taskManager = TaskManager::GetInstance();
161 TaskManager &taskManager = TaskManager::GetInstance();
168 TaskManager &taskManager = TaskManager::GetInstance();
176 TaskManager &taskManager = TaskManager::GetInstance();
261 TaskManager& taskManager = TaskManager::GetInstance();
279 TaskManager& taskManager = TaskManager::GetInstance();
290 TaskManager& taskManager = TaskManager::GetInstance();
302 TaskManager& taskManager = TaskManager::GetInstance();
314 TaskManager& taskManager = TaskManager::GetInstance();
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_scheduler.cpp70 expectCount[static_cast<size_t>(state)] = TaskManager::Instance().GetCount(state);
144 … EXPECT_EQ(expectCount[static_cast<size_t>(preState)], TaskManager::Instance().GetCount(preState));
145 … EXPECT_EQ(expectCount[static_cast<size_t>(curState)], TaskManager::Instance().GetCount(curState));
153 …expectCount[static_cast<size_t>(TaskState::PENDING)], TaskManager::Instance().GetCount(TaskState::…
154 …EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::READY)], TaskManager::Instance().GetCount(Tas…
156 …expectCount[static_cast<size_t>(TaskState::RUNNING)], TaskManager::Instance().GetCount(TaskState::…
158 …expectCount[static_cast<size_t>(TaskState::BLOCKED)], TaskManager::Instance().GetCount(TaskState::…
159 …EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::EXITED)], TaskManager::Instance().GetCount(Ta…
174 TaskManager::Instance().TaskStateCount(task2);
/ohos5.0/foundation/resourceschedule/ffrt/src/sched/
H A Dtask_manager.h25 class TaskManager {
27 static TaskManager& Instance() in Instance()
29 static TaskManager manager; in Instance()
41 TaskManager() = default;
/ohos5.0/foundation/arkui/ui_lite/test/unittest/dfx/
H A Dview_bounds_unit_test.cpp162 TaskManager::GetInstance()->TaskHandler();
170 TaskManager::GetInstance()->TaskHandler();
176 TaskManager::GetInstance()->TaskHandler();
216 TaskManager::GetInstance()->TaskHandler();
221 TaskManager::GetInstance()->TaskHandler();
227 TaskManager::GetInstance()->TaskHandler();
/ohos5.0/foundation/arkui/ui_lite/test/unittest/animator/
H A Danimator_unit_test.cpp208 TaskManager::GetInstance()->SetTaskRun(true);
210 TaskManager::GetInstance()->TaskHandler();
221 TaskManager::GetInstance()->TaskHandler();
224 TaskManager::GetInstance()->SetTaskRun(false);
225 TaskManager::GetInstance()->Remove(AnimatorManager::GetInstance());
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/src/
H A Ddeferred_processing_service.cpp78 TaskManager* taskManager = GetPhotoTaskManager(userId); in CreateDeferredPhotoProcessingSession()
102 TaskManager* DeferredProcessingService::GetPhotoTaskManager(const int32_t userId) in GetPhotoTaskManager()
108 std::shared_ptr<TaskManager> taskManager = in GetPhotoTaskManager()
109 std::make_shared<TaskManager>("PhotoProcTaskManager_userid_" + std::to_string(userId), in GetPhotoTaskManager()
/ohos5.0/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/
H A Dtask_manager.h31 class TaskManager {
33 EXPORT_API TaskManager(const std::string& name, uint32_t numThreads, bool serial);
34 EXPORT_API ~TaskManager();
/ohos5.0/foundation/multimedia/camera_framework/services/camera_service/include/avcodec/
H A Davcodec_task_manager.h67 shared_ptr<TaskManager>& GetTaskManager();
68 shared_ptr<TaskManager>& GetEncoderManager();
83 shared_ptr<TaskManager> taskManager_ = nullptr;
84 shared_ptr<TaskManager> videoEncoderManager_ = nullptr;
/ohos5.0/foundation/arkui/ui_lite/test/unittest/common/
H A Dhardware_acceleration_unit_test.cpp143 TaskManager::GetInstance()->TaskHandler();
174 TaskManager::GetInstance()->TaskHandler();
207 TaskManager::GetInstance()->TaskHandler();
244 TaskManager::GetInstance()->TaskHandler();
284 TaskManager::GetInstance()->TaskHandler();
/ohos5.0/base/request/request/services/src/manage/events/
H A Dstart.rs15 use crate::manage::TaskManager;
17 impl TaskManager { impl
H A Dpause.rs15 use crate::manage::TaskManager;
17 impl TaskManager { impl
H A Dresume.rs15 use crate::manage::TaskManager;
17 impl TaskManager { impl
H A Dstop.rs17 use crate::manage::TaskManager;
19 impl TaskManager { implementation

1234