Home
last modified time | relevance | path

Searched refs:submit_h (Results 1 - 25 of 49) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dconcurrent_adapter.cpp41 return ffrt::submit_h(action); in ScheduleTaskH()
43 return ffrt::submit_h(action, {}, { outDeps }); in ScheduleTaskH()
45 return ffrt::submit_h(action, { inDeps }, {}); in ScheduleTaskH()
47 return ffrt::submit_h(action, { inDeps }, { outDeps }); in ScheduleTaskH()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_execute_unit.cpp59 auto h1 = ffrt::submit_h([&]() { x.fetch_add(3); }); in HWTEST_F()
60 auto h2 = ffrt::submit_h([&]() { x.fetch_add(4); }, {}, {}, ffrt::task_attr().delay(2)); in HWTEST_F()
71 auto h1 = ffrt::submit_h([&]() { x += 1; }); in HWTEST_F()
72 auto h2 = ffrt::submit_h([&]() { x += 2; }, {&x}, {&x}, ffrt::task_attr().delay(1)); in HWTEST_F()
H A Dut_flo.cpp117 auto handle = ffrt::submit_h([] { in HWTEST_F()
127 auto handle = ffrt::submit_h([] { in HWTEST_F()
H A Dut_init.cpp61 auto h = ffrt::submit_h( in HWTEST_F()
H A Dut_dfx.cpp121 auto task = ffrt::submit_h(basic2Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_background))); in HWTEST_F()
158 auto task = ffrt::submit_h(basic3Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_background))); in HWTEST_F()
/foundation/ability/ability_runtime/services/common/src/
H A Dffrt_task_handler_wrap.cpp24 return std::make_shared<InnerTaskHandle>(ffrt::submit_h(std::move(task))); in SubmitTaskInner()
28 return std::make_shared<InnerTaskHandle>(ffrt::submit_h(std::move(task), in SubmitTaskInner()
H A Dqueue_task_handler_wrap.cpp37 return std::make_shared<InnerTaskHandle>(taskQueue_.submit_h(std::move(task))); in SubmitTaskInner()
41 return std::make_shared<InnerTaskHandle>(taskQueue_.submit_h(std::move(task), in SubmitTaskInner()
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Djobutils.cpp39 JobHandle handle = ffrt::submit_h(job); in SubmitJobOnce()
46 JobHandle handle = ffrt::submit_h(job); in SubmitJobOnceAsync()
/foundation/communication/netmanager_base/services/netpolicymanager/src/core/
H A Dnet_policy_callback.cpp44 netPolicyCallbackFfrtQueue_->submit_h([this, callback, &ret]() { in RegisterNetPolicyCallbackAsync()
85 netPolicyCallbackFfrtQueue_->submit_h([this, callback, &ret]() { in UnregisterNetPolicyCallbackAsync()
118 netPolicyCallbackFfrtQueue_->submit_h([this, uid, policy, &ret]() { in NotifyNetUidPolicyChangeAsync()
147 netPolicyCallbackFfrtQueue_->submit_h([this, uid, rule, &ret]() { in NotifyNetUidRuleChangeAsync()
175 netPolicyCallbackFfrtQueue_->submit_h([this, isAllowed, &ret]() { in NotifyNetBackgroundPolicyChangeAsync()
206 netPolicyCallbackFfrtQueue_->submit_h([this, &quotaPolicies, &ret]() { in NotifyNetQuotaPolicyChangeAsync()
233 netPolicyCallbackFfrtQueue_->submit_h([this, &ifaces, &ret]() { in NotifyNetMeteredIfacesChangeAsync()
/foundation/resourceschedule/ffrt/interfaces/kits/cpp/
H A Dtask.h487 static inline task_handle submit_h(std::function<void()>&& func, const task_attr& attr = {}) in submit_h() function
503 static inline task_handle submit_h(std::function<void()>&& func, std::initializer_list<dependence> in_deps, in submit_h() function
522 static inline task_handle submit_h(std::function<void()>&& func, std::initializer_list<dependence> in_deps, in submit_h() function
541 static inline task_handle submit_h(std::function<void()>&& func, const std::vector<dependence>& in_deps, in submit_h() function
560 static inline task_handle submit_h(std::function<void()>&& func, const std::vector<dependence>& in_deps, in submit_h() function
578 static inline task_handle submit_h(const std::function<void()>& func, const task_attr& attr = {}) in submit_h() function
594 static inline task_handle submit_h(const std::function<void()>& func, std::initializer_list<dependence> in_deps, in submit_h() function
613 static inline task_handle submit_h(const std::function<void()>& func, std::initializer_list<dependence> in_deps, in submit_h() function
632 static inline task_handle submit_h(const std::function<void()>& func, const std::vector<dependence>& in_deps, in submit_h() function
651 static inline task_handle submit_h(cons function
[all...]
H A Dqueue.h167 inline task_handle submit_h(const std::function<void()>& func, const task_attr& attr = {}) in submit_h() function in ffrt::queue
182 inline task_handle submit_h(std::function<void()>&& func, const task_attr& attr = {}) in submit_h() function in ffrt::queue
/foundation/systemabilitymgr/samgr/services/samgr/native/source/
H A Dffrt_handler.cpp59 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()
/foundation/communication/netmanager_base/services/netconnmanager/src/
H A Dnet_factoryreset_callback.cpp41 ffrt::task_handle ResetCallbackAsyncTask = factoryResetCallFfrtQueue_->submit_h([this, &callback, &ret]() { in RegisterNetFactoryResetCallbackAsync()
81 factoryResetCallFfrtQueue_->submit_h([this, &callback, &ret]() { in UnregisterNetFactoryResetCallbackAsync()
114 ffrt::task_handle NotifyNetFactoryResetAsyncTask = factoryResetCallFfrtQueue_->submit_h([this, &ret]() { in NotifyNetFactoryResetAsync()
/foundation/ability/form_fwk/services/src/
H A Dform_serial_queue.cpp46 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleTask()
60 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleDelayTask()
/foundation/ability/form_fwk/services/form_render_service/src/
H A Dform_render_serial_queue.cpp47 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleTask()
49 HILOG_ERROR("submit_h return null"); in ScheduleTask()
61 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleDelayTask()
63 HILOG_ERROR("submit_h return null"); in ScheduleDelayTask()
/foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/
H A Dthread.h34 *is_joinable = ffrt::submit_h([tup]() { in thread()
47 *is_joinable = ffrt::submit_h([tup]() { in thread()
62 *is_joinable = ffrt::submit_h([tup]() { in thread()
/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/
H A Dslide_recognizer.cpp137 listFlingEndTask_ = ffrt::submit_h([payload]() { in HandleListFlingStart()
143 listFlingTimeOutTask_ = ffrt::submit_h([payload]() { in HandleListFlingStart()
167 listFlingEndTask_ = ffrt::submit_h([payload]() { in HandleSendFrameEvent()
H A Dcontinuous_app_install_recognizer.cpp52 exitAppInstall_ = ffrt::submit_h([recognizer = shared_from_this()]() { in OnDispatchResource()
/foundation/resourceschedule/device_usage_statistics/services/packagegroup/src/
H A Dbundle_active_group_handler.cpp85 checkBundleTaskMap_[msgKey] = ffrtQueue_->submit_h([groupHandler, eventId, handlerobj, msgKey]() { in SendCheckBundleMsg()
133 ffrt::task_handle taskHandle = ffrtQueue_->submit_h([groupHandler, eventId, handlerobj]() { in SendEvent()
169 auto taskHandle = ffrtQueue_->submit_h(fuc); in PostSyncTask()
/foundation/arkui/ace_engine/adapter/ohos/osal/
H A Dlong_frame_report_impl.cpp30 ffrtTask = ffrt::submit_h([] { in SubmitEvent()
/foundation/resourceschedule/ffrt/examples/
H A Dsubmit.cpp41 ffrt::task_handle h = ffrt::submit_h([&]() { x = 2; }, {}, {}); in ffrt_submit_example3()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Diptables_wrapper.cpp109 ffrt::task_handle RunCommandForResTaskIpv4 = iptablesWrapperFfrtQueue_->submit_h(executeCommandForRes); in RunCommandForRes()
120 ffrt::task_handle RunCommandForResTaskIpv6 = iptablesWrapperFfrtQueue_->submit_h(executeCommandForRes); in RunCommandForRes()
/foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/
H A Dffrt_utils.cpp41 return queue.submit_h(task, ffrt::task_attr().delay(us.count())); in SubmitDelayTask()
49 return queue->submit_h(task, ffrt::task_attr().delay(us.count())); in SubmitDelayTask()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/common/
H A Dserial_queue.cpp46 task_handle task_handle = queue_->submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR)); in ScheduleDelayTask()
48 APP_LOGE("submit_h return null, ScheduleDelayTask failed"); in ScheduleDelayTask()
/foundation/communication/wifi/wifi/utils/src/
H A Dwifi_event_handler.cpp151 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()

Completed in 9 milliseconds

12