Home
last modified time | relevance | path

Searched refs:TaskManager (Results 1 - 25 of 47) sorted by relevance

12

/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 in Execute()
[all...]
H A Dtask_manager.h21 class TaskManager : public DistributedDB::IThreadPool { class
26 TaskManager() = default;
27 explicit TaskManager(std::shared_ptr<ExecutorPool> executors);
28 ~TaskManager() override;
/foundation/arkui/ui_lite/interfaces/innerkits/common/
H A Dtask_manager.h25 class TaskManager : public HeapBase { class
28 * @brief return TaskManager's singleton
29 * @return TaskManager*
31 static TaskManager* GetInstance();
74 TaskManager() : canTaskRun_(false), isHandlerRunning_(false) {} in TaskManager() function in OHOS::TaskManager
75 ~TaskManager() {} in ~TaskManager()
77 TaskManager(const TaskManager&) = delete;
78 TaskManager& operator=(const TaskManager
[all...]
/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()
60 DP_INFO_LOG("TaskManager name: %{public}s.", name_.c_str()); in ~TaskManager()
71 void TaskManager::CreateDelayedTaskGroupIfNeed() in CreateDelayedTaskGroupIfNeed()
88 void TaskManager::BeginBackgroundTasks() in BeginBackgroundTasks()
93 void TaskManager::EndBackgroundTasks() in EndBackgroundTasks()
98 bool TaskManager
[all...]
/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()
85 * @brief TaskManager::ResetTaskHandlerMutex Reset the running flag.
90 * TaskManager is one single instance, so must reset this flag to false for other task's normal rendring
93 void TaskManager::ResetTaskHandlerMutex() in ResetTaskHandlerMutex()
/foundation/filemanagement/dfs_service/test/unittests/cloudsync_sa/mock/
H A Dtask_mock.cpp78 /* TaskManager */
79 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 in InitRunner()
[all...]
/foundation/resourceschedule/ffrt/src/sched/
H A Dtask_manager.h25 class TaskManager { class
27 static TaskManager& Instance() in Instance()
29 static TaskManager manager; in Instance()
41 TaskManager() = default;
H A Dtask_manager.cpp22 void TaskManager::TaskStateCount(CPUEUTask* task) in TaskStateCount()
34 void TaskManager::CalcTaskTime(CPUEUTask* task) in CalcTaskTime()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_scheduler.cpp71 expectCount[static_cast<size_t>(state)] = TaskManager::Instance().GetCount(state); in HWTEST_F()
145 EXPECT_EQ(expectCount[static_cast<size_t>(preState)], TaskManager::Instance().GetCount(preState)); in HWTEST_F()
146 EXPECT_EQ(expectCount[static_cast<size_t>(curState)], TaskManager::Instance().GetCount(curState)); in HWTEST_F()
154 expectCount[static_cast<size_t>(TaskState::PENDING)], TaskManager::Instance().GetCount(TaskState::PENDING)); in HWTEST_F()
155 EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::READY)], TaskManager::Instance().GetCount(TaskState::READY)); in HWTEST_F()
157 expectCount[static_cast<size_t>(TaskState::RUNNING)], TaskManager::Instance().GetCount(TaskState::RUNNING)); in HWTEST_F()
159 expectCount[static_cast<size_t>(TaskState::BLOCKED)], TaskManager::Instance().GetCount(TaskState::BLOCKED)); in HWTEST_F()
160 EXPECT_EQ(expectCount[static_cast<size_t>(TaskState::EXITED)], TaskManager::Instance().GetCount(TaskState::EXITED)); in HWTEST_F()
175 TaskManager::Instance().TaskStateCount(task2); in HWTEST_F()
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/task_manager/
H A Dtask_manager.h31 class TaskManager { class
33 EXPORT_API TaskManager(const std::string& name, uint32_t numThreads, bool serial);
34 EXPORT_API ~TaskManager();
/foundation/arkui/ui_lite/test/unittest/animator/
H A Danimator_unit_test.cpp208 TaskManager::GetInstance()->SetTaskRun(true); in HWTEST_F()
210 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
221 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
224 TaskManager::GetInstance()->SetTaskRun(false); in HWTEST_F()
225 TaskManager::GetInstance()->Remove(AnimatorManager::GetInstance()); in HWTEST_F()
/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()
/foundation/multimedia/camera_framework/services/camera_service/include/avcodec/
H A Davcodec_task_manager.h63 shared_ptr<TaskManager>& GetTaskManager();
64 shared_ptr<TaskManager>& GetEncoderManager();
73 shared_ptr<TaskManager> taskManager_ = nullptr;
74 shared_ptr<TaskManager> videoEncoderManager_ = nullptr;
/foundation/arkui/ui_lite/test/unittest/dfx/
H A Dview_bounds_unit_test.cpp162 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
170 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
176 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
216 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
221 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
227 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/
H A Ddeferred_processing_service.h50 TaskManager* GetPhotoTaskManager(const int32_t userId);
53 std::unordered_map<int, std::shared_ptr<TaskManager>> photoTaskManagerMap_;
/foundation/arkui/ui_lite/test/unittest/common/
H A Dhardware_acceleration_unit_test.cpp143 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
174 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
207 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
244 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
284 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/
H A Dscheduler_manager.h38 TaskManager* taskManager, std::shared_ptr<IImageProcessCallbacks> callbacks);
45 TaskManager* taskManager, std::shared_ptr<IImageProcessCallbacks> callbacks);
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/session/photo_session/
H A Ddeferred_photo_processing_session.h43 TaskManager* taskManager, sptr<IDeferredPhotoProcessingSessionCallback> callback);
59 TaskManager* taskManager_;
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/schedule/photo_processor/
H A Ddeferred_photo_processor.h30 DeferredPhotoProcessor(const int32_t userId, TaskManager* taskManager,
60 TaskManager* taskManager_;
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/post_processor/
H A Dphoto_post_processor.h50 PhotoPostProcessor(const int32_t userId, TaskManager* taskManager, IImageProcessCallbacks* callbacks);
82 TaskManager* taskManager_;
/foundation/arkui/ui_lite/tools/qt/simulator/drivers/display/
H A Dtask_thread.cpp23 TaskManager::GetInstance()->TaskHandler(); in run()
/foundation/arkui/ui_lite/frameworks/common/
H A Dtask.cpp32 TaskManager::GetInstance()->Add(this); in Init()
/foundation/arkui/ui_lite/test/unittest/render/
H A Drender_uni_test.cpp101 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
133 TaskManager::GetInstance()->TaskHandler(); in HWTEST_F()
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/schedule/
H A Dscheduler_manager.cpp47 TaskManager* taskManager, std::shared_ptr<IImageProcessCallbacks> callbacks) in GetPhotoProcessor()
56 void SchedulerManager::CreatePhotoProcessor(const int32_t userId, TaskManager* taskManager, in CreatePhotoProcessor()
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/session/
H A Dsession_info.h35 std::shared_ptr<DeferredPhotoProcessor> processor, TaskManager* taskManager,

Completed in 7 milliseconds

12