| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | raw.rs | 25 use crate::task::task_handle::TaskHandle;
296 task_handle.get_result(out); in get_result()
305 task_handle.drop_ref(); in drop_ref()
324 task_handle.drop_join_handle(); in drop_join_handle()
334 task_handle.run();
345 task_handle.wake();
347 task_handle.wake_by_ref();
357 task_handle.shutdown();
366 task_handle.set_canceled();
395 task_handle.ffrt_run()
[all …]
|
| /ohos5.0/foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
| H A D | task.h | 206 class task_handle {
208 task_handle() : p(nullptr) in task_handle() function
211 task_handle(ffrt_task_handle_t p) : p(p) in task_handle() function
215 ~task_handle() in ~task_handle()
222 task_handle(task_handle const&) = delete;
223 task_handle& operator=(task_handle const&) = delete;
225 inline task_handle(task_handle&& h) in task_handle() function
242 inline task_handle& operator=(task_handle&& h)
269 dependence(const task_handle& h) in dependence()
524 static inline task_handle submit_h(std::function<void()>&& func, const task_attr& attr = {})
[all …]
|
| H A D | queue.h | 167 inline task_handle submit_h(const std::function<void()>& func, const task_attr& attr = {})
182 inline task_handle submit_h(std::function<void()>&& func, const task_attr& attr = {})
224 inline task_handle submit_head_h(const std::function<void()>& func, const task_attr& attr = {})
239 inline task_handle submit_head_h(std::function<void()>&& func, const task_attr& attr = {})
254 inline int cancel(const task_handle& handle) in cancel()
266 inline void wait(const task_handle& handle) in wait()
|
| /ohos5.0/foundation/ability/form_fwk/services/form_render_service/src/ |
| H A D | form_render_serial_queue.cpp | 47 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleTask() local
48 if (task_handle == nullptr) { in ScheduleTask()
61 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleDelayTask() local
62 if (task_handle == nullptr) { in ScheduleDelayTask()
66 taskMap_[taskName] = std::move(task_handle); in ScheduleDelayTask()
|
| /ohos5.0/foundation/ability/form_fwk/services/src/ |
| H A D | form_serial_queue.cpp | 46 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleTask() local
47 if (task_handle == nullptr) { in ScheduleTask()
60 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleDelayTask() local
61 if (task_handle == nullptr) { in ScheduleDelayTask()
65 taskMap_[eventMsg] = std::move(task_handle); in ScheduleDelayTask()
|
| /ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/common/ |
| H A D | serial_queue.cpp | 46 task_handle task_handle = queue_->submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleDelayTask() local
47 if (task_handle == nullptr) { in ScheduleDelayTask()
51 taskMap_[taskName] = std::move(task_handle); in ScheduleDelayTask()
|
| /ohos5.0/foundation/communication/netmanager_base/services/netpolicymanager/src/core/ |
| H A D | net_policy_callback.cpp | 43 ffrt::task_handle RegisterNetPolicyCallbackAsyncTask = in RegisterNetPolicyCallbackAsync()
84 ffrt::task_handle UnregisterNetPolicyCallbackAsyncTask = in UnregisterNetPolicyCallbackAsync()
117 ffrt::task_handle NotifyNetUidPolicyChangeAsyncTask = in NotifyNetUidPolicyChangeAsync()
146 ffrt::task_handle NotifyNetUidRuleChangeAsyncTask = in NotifyNetUidRuleChangeAsync()
174 ffrt::task_handle NotifyNetBackgroundPolicyChangeAsyncTask = in NotifyNetBackgroundPolicyChangeAsync()
205 ffrt::task_handle NotifyNetQuotaPolicyChangeTask = in NotifyNetQuotaPolicyChangeAsync()
232 ffrt::task_handle NotifyNetMeteredIfacesChangeTask = in NotifyNetMeteredIfacesChangeAsync()
|
| /ohos5.0/foundation/ability/ability_runtime/services/common/src/ |
| H A D | ffrt_task_utils_wrap.h | 27 explicit InnerTaskHandle(ffrt::task_handle &&taskHandle) in InnerTaskHandle()
32 ffrt::task_handle &GetFfrtHandle() in GetFfrtHandle()
37 ffrt::task_handle taskHandle_;
|
| /ohos5.0/base/notification/distributed_notification_service/services/ans/src/ |
| H A D | advanced_notification_slot_service.cpp | 78 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in AddSlots()
117 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetSlots()
155 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetSlotsByBundle()
195 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetSlotByBundle()
232 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in UpdateSlots()
263 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in RemoveAllSlots()
314 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in AddSlotByType()
352 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetEnabledForBundleSlotSelf()
397 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetSlotFlagsAsBundle()
448 ffrt::task_handle handler = notificationSvrQueue_->submit_h( in SetSlotFlagsAsBundle()
[all …]
|
| H A D | advanced_notification_publish_service.cpp | 220 ffrt::task_handle handler = notificationSvrQueue_->submit_h([&]() { in PublishNotificationForIndirectProxy()
338 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in ExcuteCancelAll()
530 ffrt::task_handle handler = notificationSvrQueue_->submit_h( in SetNotificationBadgeNum()
573 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in ExcuteDelete()
625 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in DeleteByBundle()
774 ffrt::task_handle handler = notificationSvrQueue_->submit_h( in SetShowBadgeEnabledForBundle()
2330 ffrt::task_handle handler = notificationSvrQueue_->submit_h([=]() { in UpdateUnifiedGroupInfo()
2417 ffrt::task_handle handler = notificationSvrQueue_->submit_h([&]() { in PublishNotificationBySa()
2476 ffrt::task_handle handler = notificationSvrQueue_->submit_h([&]() { in SetBadgeNumber()
2530 ffrt::task_handle handler = notificationSvrQueue_->submit_h([&]() { in SetBadgeNumberByBundle()
[all …]
|
| H A D | notification_local_live_view_subscriber_manager.cpp | 96 ffrt::task_handle handler = in AddLocalLiveViewSubscriber()
121 ffrt::task_handle handler = notificationButtonQueue_->submit_h(std::bind([this, &subscriber, in RemoveLocalLiveViewSubscriber()
155 ffrt::task_handle handler = notificationButtonQueue_->submit_h(std::bind([this, object]() { in OnRemoteDied()
|
| H A D | advanced_notification_service.cpp | 397 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in CancelPreparedNotification()
661 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in PublishPreparedNotification()
1069 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetActiveNotifications()
1097 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetActiveNotificationNums()
1142 ffrt::task_handle handler = notificationSvrQueue_->submit_h( in GetBundleImportance()
1405 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetAllActiveNotifications()
1453 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind([&]() { in GetSpecialActiveNotifications()
1594 ffrt::task_handle handler = notificationSvrQueue_->submit_h( in EnableDistributed()
1676 ffrt::task_handle handler = notificationSvrQueue_->submit_h(std::bind( in EnableDistributedSelf()
1817 ffrt::task_handle handler = notificationSvrQueue_->submit_h( in SetSyncNotificationEnabledWithoutApp()
[all …]
|
| /ohos5.0/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
| H A D | thread.h | 31 is_joinable = std::make_unique<task_handle>(); in thread()
44 is_joinable = std::make_unique<task_handle>(); in thread()
59 is_joinable = std::make_unique<task_handle>();
122 std::unique_ptr<task_handle> is_joinable;
|
| /ohos5.0/foundation/communication/netmanager_base/services/netconnmanager/src/ |
| H A D | net_factoryreset_callback.cpp | 41 …ffrt::task_handle ResetCallbackAsyncTask = factoryResetCallFfrtQueue_->submit_h([this, &callback, … in RegisterNetFactoryResetCallbackAsync()
80 ffrt::task_handle UnregisterNetFactoryResetCallbackAsync = in UnregisterNetFactoryResetCallbackAsync()
114 …ffrt::task_handle NotifyNetFactoryResetAsyncTask = factoryResetCallFfrtQueue_->submit_h([this, &r… in NotifyNetFactoryResetAsync()
|
| /ohos5.0/foundation/systemabilitymgr/samgr/services/samgr/native/source/ |
| H A D | ffrt_handler.cpp | 59 task_handle handler = queue_->submit_h(func); in PostTask()
73 task_handle handler = queue_->submit_h(func, task_attr().delay(delayTime * CONVERSION_FACTOR)); in PostTask()
88 task_handle handler = queue_->submit_h(func, task_attr().delay(delayTime * CONVERSION_FACTOR)); in PostTask()
|
| /ohos5.0/foundation/window/window_manager/window_scene/session/host/src/ |
| H A D | ws_ffrt_helper.cpp | 47 void SaveTask(const std::string& taskName, ffrt::task_handle handle) in SaveTask()
83 std::unordered_map<std::string, ffrt::task_handle> taskMap_;
110 …ffrt::task_handle handle = ffrt::submit_h(std::move(localTask), {}, {}, ffrt::task_attr().delay(de… in SubmitTask()
|
| /ohos5.0/foundation/resourceschedule/ffrt/docs/ |
| H A D | user_guide.md | 484 class task_handle {
486 task_handle();
487 task_handle(ffrt_task_handle_t p);
489 task_handle(task_handle const&) = delete;
492 task_handle(task_handle&& h);
493 task_handle& operator=(task_handle&& h);
528 * task_handle 可以和其他的数据depends 同时作为某个task 的in_deps，表示该task 的执行依赖task_handle 对应的task 执行完成
529 * task_handle 可以和其他的数据depends 同时作为wait 的deps，表示当前任务将被suspend，直到task_handle 对应的task 执行完成后将被恢复
723 int cancel(const task_handle& handle);
725 void wait(const task_handle& handle);
[all …]
|
| /ohos5.0/base/msdp/device_status/rust/modules/scheduler/test/src/ |
| H A D | lib.rs | 199 let mut task_handle = handler.post_async_task(move || { in test_post_async_task() localVariable
202 let ret = task_handle.result().unwrap(); in test_post_async_task()
251 let mut task_handle = handler.post_blocking_task(move || { in test_post_blocking_task() localVariable
255 let ret = task_handle.result().unwrap(); in test_post_blocking_task()
|
| /ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/include/ |
| H A D | slide_recognizer.h | 53 ffrt::task_handle listFlingEndTask_ = nullptr;
54 ffrt::task_handle listFlingTimeOutTask_ = nullptr;
|
| /ohos5.0/foundation/communication/dhcp/services/dhcp_client/src/ |
| H A D | dhcp_thread.cpp | 69 ffrt::task_handle handle = eventQueue->submit_h(callback); in PostSyncTask()
85 … ffrt::task_handle handle = eventQueue->submit_h(callback, ffrt::task_attr().delay(delayTimeUs)); in PostAsyncTask()
97 ffrt::task_handle handle = eventQueue->submit_h( in PostAsyncTask()
125 std::map<std::string, ffrt::task_handle> taskMap_;
|
| /ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packagegroup/include/ |
| H A D | bundle_active_group_handler.h | 73 std::map<int32_t, std::queue<ffrt::task_handle>> taskHandlerMap_;
74 std::map<std::string, ffrt::task_handle> checkBundleTaskMap_;
|
| /ohos5.0/foundation/communication/wifi/wifi/utils/src/ |
| H A D | wifi_event_handler.cpp | 151 ffrt::task_handle handle = eventQueue->submit_h(callback); in PostSyncTask()
167 … ffrt::task_handle handle = eventQueue->submit_h(callback, ffrt::task_attr().delay(delayTimeUs)); in PostAsyncTask()
179 ffrt::task_handle handle = eventQueue->submit_h( in PostAsyncTask()
203 std::map<std::string, ffrt::task_handle> taskMap_;
|
| /ohos5.0/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/aging/ |
| H A D | bundle_aging_mgr.cpp | 265 ffrt::task_handle task_handle = ffrt::submit_h(task); in Start() local
266 if (task_handle == nullptr) { in Start()
|
| /ohos5.0/foundation/resourceschedule/device_usage_statistics/services/packageusage/src/ |
| H A D | bundle_active_report_handler.cpp | 53 taskHandlerMap_[eventId] = std::queue<ffrt::task_handle>(); in SendEvent()
55 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([reportHandler, eventId, handlerobj]() { in SendEvent()
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/ |
| H A D | iptables_wrapper.cpp | 108 …ffrt::task_handle RunCommandForResTaskIpv4 = iptablesWrapperFfrtQueue_->submit_h(executeCommandFor… in RunCommandForRes()
119 …ffrt::task_handle RunCommandForResTaskIpv6 = iptablesWrapperFfrtQueue_->submit_h(executeCommandFor… in RunCommandForRes()
|