Home
last modified time | relevance | path

Searched refs:TaskExecutor (Results 1 – 25 of 395) sorted by relevance

12345678910>>...16

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dtask_executor.cpp19 TaskExecutor::~TaskExecutor() in ~TaskExecutor()
24 TaskExecutor &TaskExecutor::GetInstance() in GetInstance()
26 static TaskExecutor instance; in GetInstance()
30 TaskExecutor::TaskId TaskExecutor::Execute(const Task &task) in Execute()
41 TaskExecutor::TaskId TaskExecutor::Schedule(Duration delay, const Task &task, Duration interval, ui… in Schedule()
52 bool TaskExecutor::Remove(TaskExecutor::TaskId taskId, bool wait) in Remove()
60 TaskExecutor::TaskId TaskExecutor::Reset(TaskExecutor::TaskId taskId, Duration interval) in Reset()
68 void TaskExecutor::SetExecutors(std::shared_ptr<ExecutorPool> executors) in SetExecutors()
76 void TaskExecutor::GenerateExecutors() in GenerateExecutors()
H A Dtask_executor_adapter.cpp20 return TaskExecutor::GetInstance().Execute(task); in Execute()
25 return TaskExecutor::GetInstance().Schedule(delay, task); in Execute()
30 return TaskExecutor::GetInstance().Schedule(TaskExecutor::INVALID_DURATION, task, interval); in Schedule()
35 return TaskExecutor::GetInstance().Schedule(delay, task, interval); in Schedule()
40 return TaskExecutor::GetInstance().Schedule(delay, task, interval, times); in Schedule()
45 return TaskExecutor::GetInstance().Remove(taskId, wait); in Remove()
50 return TaskExecutor::GetInstance().Reset(taskId, interval); in Reset()
H A Dauto_sync_timer_mock.cpp31 if (forceSyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
33 …TaskExecutor::GetInstance().Schedule(std::chrono::milliseconds(FORCE_SYNC_INTERVAL), ProcessTask()… in StartTimer()
35 if (delaySyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
37 …TaskExecutor::GetInstance().Schedule(std::chrono::milliseconds(AUTO_SYNC_INTERVAL), ProcessTask()); in StartTimer()
40 …TaskExecutor::GetInstance().Reset(delaySyncTaskId_, std::chrono::milliseconds(AUTO_SYNC_INTERVAL)); in StartTimer()
127 TaskExecutor::GetInstance().Remove(forceSyncTaskId_); in StopTimer()
128 TaskExecutor::GetInstance().Remove(delaySyncTaskId_); in StopTimer()
129 forceSyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
130 delaySyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
H A Dauto_sync_timer.cpp33 if (forceSyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
35 …TaskExecutor::GetInstance().Schedule(std::chrono::milliseconds(FORCE_SYNC_INTERVAL), ProcessTask()… in StartTimer()
37 if (delaySyncTaskId_ == TaskExecutor::INVALID_TASK_ID) { in StartTimer()
39 …TaskExecutor::GetInstance().Schedule(std::chrono::milliseconds(AUTO_SYNC_INTERVAL), ProcessTask()); in StartTimer()
42 …TaskExecutor::GetInstance().Reset(delaySyncTaskId_, std::chrono::milliseconds(AUTO_SYNC_INTERVAL)); in StartTimer()
145 TaskExecutor::GetInstance().Remove(forceSyncTaskId_); in StopTimer()
146 TaskExecutor::GetInstance().Remove(delaySyncTaskId_); in StopTimer()
147 forceSyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
148 delaySyncTaskId_ = TaskExecutor::INVALID_TASK_ID; in StopTimer()
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/src/
H A Dtask_executor.cpp19 TaskExecutor::TaskExecutor():pool_(nullptr) in TaskExecutor() function in OHOS::NativeRdb::TaskExecutor
23 TaskExecutor::~TaskExecutor() in ~TaskExecutor()
28 TaskExecutor &TaskExecutor::GetInstance() in GetInstance()
30 static TaskExecutor instance; in GetInstance()
34 std::shared_ptr<TaskExecutor::ExecutorPool> TaskExecutor::GetExecutor() in GetExecutor()
39 void TaskExecutor::SetExecutor(std::shared_ptr<TaskExecutor::ExecutorPool> executor) in SetExecutor()
/ohos5.0/foundation/arkui/ace_engine/test/unittest/core/common/task/
H A Dthread_test.cpp101 case TaskExecutor::TaskType::UI:
102 case TaskExecutor::TaskType::IO:
103 case TaskExecutor::TaskType::GPU:
104 case TaskExecutor::TaskType::JS:
133 case TaskExecutor::TaskType::UI:
136 case TaskExecutor::TaskType::IO:
139 case TaskExecutor::TaskType::GPU:
142 case TaskExecutor::TaskType::JS:
296 case TaskExecutor::TaskType::UI:
297 case TaskExecutor::TaskType::IO:
[all …]
/ohos5.0/foundation/ai/intelligent_voice_framework/utils/
H A Dtask_executor.cpp23 TaskExecutor::TaskExecutor(const std::string &threadName, uint32_t capacity) : threadName_(threadNa… in TaskExecutor() function in OHOS::IntellVoiceUtils::TaskExecutor
28 TaskExecutor::~TaskExecutor() in ~TaskExecutor()
33 void TaskExecutor::StartThread() in StartThread()
36 int ret = pthread_create(&tid_, nullptr, TaskExecutor::ExecuteInThread, this); in StartThread()
45 void TaskExecutor::StopThread() in StopThread()
57 void *TaskExecutor::ExecuteInThread(void *arg) in ExecuteInThread()
59 TaskExecutor *executor = static_cast<TaskExecutor *>(arg); in ExecuteInThread()
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dtask_executor.cpp19 TaskExecutor::TaskExecutor() in TaskExecutor() function in OHOS::NativeRdb::TaskExecutor
24 TaskExecutor::~TaskExecutor() in ~TaskExecutor()
29 TaskExecutor &TaskExecutor::GetInstance() in GetInstance()
31 static TaskExecutor instance; in GetInstance()
35 std::shared_ptr<ExecutorPool> TaskExecutor::GetExecutor() in GetExecutor()
41 void TaskExecutor::SetExecutor(std::shared_ptr<ExecutorPool> executor) in SetExecutor()
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/common/stylus/
H A Dstylus_detector_callback.h29 static int32_t RequestFocus(int32_t nodeId, const RefPtr<TaskExecutor>& taskScheduler);
30 static int32_t SetText(int32_t nodeId, void* data, const RefPtr<TaskExecutor>& taskScheduler,
32 static int32_t GetText(int32_t nodeId, const RefPtr<TaskExecutor>& taskScheduler,
34 … static int32_t DeleteText(int32_t nodeId, void* data, const RefPtr<TaskExecutor>& taskScheduler);
35 … static int32_t ChoiceText(int32_t nodeId, void* data, const RefPtr<TaskExecutor>& taskScheduler);
36 … static int32_t InsertSpace(int32_t nodeId, void* data, const RefPtr<TaskExecutor>& taskScheduler);
37 … static int32_t MoveCursor(int32_t nodeId, void* data, const RefPtr<TaskExecutor>& taskScheduler);
39 static int32_t Redo(int32_t nodeId, const RefPtr<TaskExecutor>& taskScheduler);
40 static int32_t Undo(int32_t nodeId, const RefPtr<TaskExecutor>& taskScheduler);
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/task/
H A Dtask_executor.cpp33 IMPLEMENT_SINGLE_INSTANCE(TaskExecutor);
34 TaskExecutor::TaskExecutor() : taskThreadFlag_(true) in TaskExecutor() function in OHOS::DistributedHardware::TaskExecutor
40 TaskExecutor::~TaskExecutor() in ~TaskExecutor()
46 void TaskExecutor::PushTask(const std::shared_ptr<Task> task) in PushTask()
66 std::shared_ptr<Task> TaskExecutor::PopTask() in PopTask()
84 void TaskExecutor::TriggerTask() in TriggerTask()
/ohos5.0/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dtask_executor.h44 class TaskExecutor : public AceType {
45 DECLARE_ACE_TYPE(TaskExecutor, AceType);
46 ACE_DISALLOW_COPY_AND_MOVE(TaskExecutor);
63 ~TaskExecutor() override = default;
287 TaskExecutor() = default;
330 using Task = TaskExecutor::Task;
331 using CancelableTask = TaskExecutor::CancelableTask;
332 using TaskType = TaskExecutor::TaskType;
456 RefPtr<TaskExecutor> GetTaskExecutor() const in GetTaskExecutor()
467 RefPtr<TaskExecutor> taskExecutor_;
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/common/
H A Dtask_executor_impl.cpp42 TaskExecutor::Task TaskExecutorImpl::WrapTaskWithContainer( in WrapTaskWithContainer()
189 TaskExecutor::Task wrappedTask = in OnPostTask()
243 thread_local TaskExecutor::TaskType TaskExecutorImpl::localTaskType = TaskExecutor::TaskType::UNKNO…
249 case TaskExecutor::TaskType::PLATFORM: in TaskTypeToString()
251 case TaskExecutor::TaskType::UI: in TaskTypeToString()
253 case TaskExecutor::TaskType::IO: in TaskTypeToString()
255 case TaskExecutor::TaskType::GPU: in TaskTypeToString()
257 case TaskExecutor::TaskType::JS: in TaskTypeToString()
259 case TaskExecutor::TaskType::BACKGROUND: in TaskTypeToString()
261 case TaskExecutor::TaskType::UNKNOWN: in TaskTypeToString()
[all …]
H A Dwatch_dog.cpp114 void SetTaskExecutor(const RefPtr<TaskExecutor>& taskExecutor);
134 TaskExecutor::TaskType type_;
143 WeakPtr<TaskExecutor> taskExecutor_;
165 void ThreadWatcher::SetTaskExecutor(const RefPtr<TaskExecutor>& taskExecutor) in SetTaskExecutor()
203 case TaskExecutor::TaskType::JS: in InitThreadName()
206 case TaskExecutor::TaskType::UI: in InitThreadName()
310 taskId += taskExecutor->GetTotalTaskNum(TaskExecutor::TaskType::JS); in IsThreadStuck()
335 if (type_ == TaskExecutor::TaskType::JS) { in HiviewReport()
337 } else if (type_ == TaskExecutor::TaskType::UI) { in HiviewReport()
349 …(type_ == TaskExecutor::TaskType::JS || (useUIAsJSThread_ && (type_ == TaskExecutor::TaskType::UI)… in RawReport()
[all …]
H A Dwatch_dog_mingw.cpp77 ThreadWatcher(int32_t instanceId, TaskExecutor::TaskType type, bool useUIAsJSThread = false);
80 void SetTaskExecutor(const RefPtr<TaskExecutor>& taskExecutor);
100 TaskExecutor::TaskType type_;
106 WeakPtr<TaskExecutor> taskExecutor_;
113 ThreadWatcher::ThreadWatcher(int32_t instanceId, TaskExecutor::TaskType type, bool useUIAsJSThread) in ThreadWatcher()
129 void ThreadWatcher::SetTaskExecutor(const RefPtr<TaskExecutor>& taskExecutor) in SetTaskExecutor()
168 case TaskExecutor::TaskType::JS: in InitThreadName()
171 case TaskExecutor::TaskType::UI: in InitThreadName()
296 if (type_ == TaskExecutor::TaskType::JS) { in HiviewReport()
298 } else if (type_ == TaskExecutor::TaskType::UI) { in HiviewReport()
[all …]
H A Dtask_executor_impl.h31 class ACE_EXPORT TaskExecutorImpl final : public TaskExecutor {
32 DECLARE_ACE_TYPE(TaskExecutorImpl, TaskExecutor);
61 TaskExecutor::Task WrapTaskWithContainer(
62 TaskExecutor::Task&& task, int32_t id, std::function<void()>&& traceIdFunc = nullptr) const;
63 TaskExecutor::Task WrapTaskWithCustomWrapper(
64 TaskExecutor::Task&& task, int32_t id, std::function<void()>&& traceIdFunc = nullptr) const;
65 … bool PostTaskToTaskRunner(const RefPtr<TaskRunnerAdapter>& taskRunner, TaskExecutor::Task&& task,
H A Dthread_checker.cpp22 bool CheckThread(TaskExecutor::TaskType threadType) in CheckThread()
24 if (threadType == TaskExecutor::TaskType::UI || threadType == TaskExecutor::TaskType::JS) { in CheckThread()
32 if (threadType == TaskExecutor::TaskType::PLATFORM) { in CheckThread()
/ohos5.0/foundation/arkui/ace_engine/adapter/ohos/capability/clipboard/
H A Dclipboard_impl.cpp63 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardHasData"); in HasData()
85 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardHasDataType"); in HasDataType()
103 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardSetDataWithCopyOption"); in SetData()
156 TaskExecutor::TaskType::UI, "ArkUIClipboardTextDataCallback"); in GetData()
177 TaskExecutor::TaskType::UI, "ArkUIClipboardImageDataCallback"); in GetPixelMapData()
409 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardGetTextDataSync"); in GetDataSync()
451 TaskExecutor::TaskType::BACKGROUND, "ArkUIClipboardGetTextDataAsync"); in GetDataAsync()
500 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardGetPasteDataSync"); in GetDataSync()
567 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardGetDataAsync"); in GetDataAsync()
671 TaskExecutor::TaskType::PLATFORM, "ArkUIClipboardGetImageDataSync"); in GetPixelMapDataSync()
[all …]
/ohos5.0/foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/sa/
H A Dintell_voice_service_manager.cpp67 TaskExecutor::StartThread(); in IntellVoiceServiceManager()
73 TaskExecutor::StopThread(); in ~IntellVoiceServiceManager()
326 TaskExecutor::AddAsyncTask([uuid, this]() { in OnDetected()
449 TaskExecutor::AddSyncTask([this]() -> int32_t { in OnSwitchChange()
457 TaskExecutor::AddSyncTask([this]() -> int32_t { in OnSwitchChange()
491 TaskExecutor::AddSyncTask([&]() -> int32_t { in RegisterProxyDeathRecipient()
592 TaskExecutor::AddAsyncTask([this, result, param]() { in HandleUpdateComplete()
607 TaskExecutor::AddAsyncTask([this]() { in HandleUpdateRetry()
757 return TaskExecutor::AddSyncTask([this]() -> int32_t { in ClearUserData()
832 TaskExecutor::AddAsyncTask([this]() { SilenceUpdate(); }); in HandleSilenceUpdate()
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/bridge/plugin_frontend/
H A Dplugin_frontend_delegate.cpp366 TaskExecutor::TaskType::JS, "ArkUILoadPluginJsCode"); in LoadPluginJsCode()
425 TaskExecutor::TaskType::JS, "ArkUIPluginPageHide"); in OnBackGround()
436 TaskExecutor::TaskType::JS, "ArkUIPluginPageShow"); in OnForeground()
496 TaskExecutor::TaskType::JS, "ArkUIPluginSaveData"); in OnSaveData()
540 TaskExecutor::TaskType::JS, "ArkUIPluginActive"); in OnActive()
549 TaskExecutor::TaskType::JS, "ArkUIPluginInactive"); in OnInactive()
617 TaskExecutor::TaskType::JS, "ArkUIPluginNewWant"); in OnNewWant()
944 TaskExecutor::TaskType::UI, "ArkUIPluginShowToast"); in ShowToast()
1234 TaskExecutor::TaskType::UI, "ArkUIPluginPageReady"); in OnPageReady()
1339 TaskExecutor::TaskType::UI, "ArkUIPluginPopToPage"); in PopToPage()
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/bridge/js_frontend/
H A Dfrontend_delegate_impl.cpp258 TaskExecutor::TaskType::JS, "ArkUIHandleJsCallback"); in OnJsCallback()
533 TaskExecutor::TaskType::JS, "ArkUIFireAsyncEvent"); in FireAsyncEvent()
563 TaskExecutor::TaskType::JS, "ArkUIFireSyncEvent"); in FireSyncEvent()
959 TaskExecutor::TaskType::UI, "ArkUIShowToast"); in ShowToast()
1036 TaskExecutor::TaskType::UI, "ArkUIShowDialog"); in ShowDialog()
1283 TaskExecutor::TaskType::JS, "ArkUILoadJsPage"); in LoadPage()
1386 TaskExecutor::TaskType::UI, "ArkUIPageReady"); in OnPageReady()
1501 TaskExecutor::TaskType::UI, "ArkUIPopToPage"); in PopToPage()
1574 TaskExecutor::TaskType::UI, "ArkUIPopPage"); in PopPage()
1708 TaskExecutor::TaskType::UI, "ArkUIReplacePage"); in ReplacePage()
[all …]
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/task/
H A Dtask_executor.h28 class TaskExecutor {
29 DECLARE_SINGLE_INSTANCE_BASE(TaskExecutor);
31 explicit TaskExecutor();
32 ~TaskExecutor();
/ohos5.0/foundation/arkui/ace_engine/adapter/ohos/osal/
H A Dstylus_detector_callback.cpp64 TaskExecutor::TaskType::UI, "ArkUIDetectorSyncStylusAction"); in RequestFocus()
91 TaskExecutor::TaskType::UI, "ArkUIDetectorStylusAction"); in SetText()
121 TaskExecutor::TaskType::UI, "ArkUIDetectorStylusAction"); in GetText()
139 TaskExecutor::TaskType::UI, "ArkUIDetectorStylusAction"); in Redo()
157 TaskExecutor::TaskType::UI, "ArkUIDetectorStylusAction"); in Undo()
162 const RefPtr<TaskExecutor>& taskScheduler) in DeleteText()
192 TaskExecutor::TaskType::UI, "ArkUIDetectorSyncStylusAction"); in DeleteText()
197 const RefPtr<TaskExecutor>& taskScheduler) in ChoiceText()
236 TaskExecutor::TaskType::UI, "ArkUIDetectorSyncStylusAction"); in ChoiceText()
241 const RefPtr<TaskExecutor>& taskScheduler) in InsertSpace()
[all …]
/ohos5.0/foundation/arkui/ace_engine/adapter/preview/entrance/
H A Dace_container.cpp139 TaskExecutor::TaskType::UI, "ArkUIPipelineDestroy"); in Destroy()
149 TaskExecutor::TaskType::JS, "ArkUIFrontendDestroy"); in Destroy()
263 TaskExecutor::TaskType::JS, "ArkUISetHspBufferTracker"); in SetHspBufferTrackerCallback()
282 TaskExecutor::TaskType::JS, "ArkUISetMockModuleList"); in SetMockModuleListToJsEngine()
421 TaskExecutor::TaskType::UI, "ArkUISurfaceChanged"); in InitializeCallback()
434 TaskExecutor::TaskType::UI, "ArkUIDensityChanged"); in InitializeCallback()
794 TaskExecutor::TaskType::UI, "ArkUILoadTheme"); in UpdateDeviceConfig()
908 TaskExecutor::TaskType::UI, "ArkUISetupRootElement"); in AttachView()
1029 TaskExecutor::TaskType::UI, "ArkUIEnvCallback"); in AttachView()
1041 TaskExecutor::TaskType::UI, "ArkUISetupRootElement"); in AttachView()
[all …]
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Dtask_executor.h19 class TaskExecutor {
26 static TaskExecutor &GetInstance();
33 TaskExecutor();
34 ~TaskExecutor();
/ohos5.0/foundation/arkui/ace_engine/test/unittest/core/common/environment/
H A Dmock_environment.h27 explicit MockEnvironmentImpl(const RefPtr<TaskExecutor>& taskExecutor);
33 MockEnvironmentImpl::MockEnvironmentImpl(const RefPtr<TaskExecutor>& taskExecutor) : Environment(ta… in MockEnvironmentImpl()
45 RefPtr<Environment> GetEnvironment(const RefPtr<TaskExecutor>& taskExecutor) const override;
50 RefPtr<Environment> MockEnvironmentProxyImpl::GetEnvironment(const RefPtr<TaskExecutor>& taskExecut… in GetEnvironment()

12345678910>>...16