/foundation/resourceschedule/ffrt/test/testfunc/ |
H A D | func_pool.cpp | 36 ffrt::submit([&]() { NestedFib(num - 1, val1); }, {}, { &val1 }); in NestedFib() 37 ffrt::submit([&]() { NestedFib(num - 2, val2); }, {}, { &val2 }); in NestedFib() 48 ffrt::submit([&]() { NestedAddOne(deepth - 1, val); }, { &val }, { &val }, in NestedAddOne() 59 ffrt::submit( in NestedWhile() 61 ffrt::submit( in NestedWhile() 63 ffrt::submit( in NestedWhile() 65 ffrt::submit( in NestedWhile() 67 ffrt::submit( in NestedWhile() 69 ffrt::submit( in NestedWhile() 71 ffrt::submit( in NestedWhile() [all...] |
/foundation/resourceschedule/ffrt/benchmarks/fib/ |
H A D | fib.cpp | 41 ffrt::submit([&]() { FibFFRTChildWait(x - 1, y1); }, {}, {}); in FibFFRTChildWait() 42 ffrt::submit([&]() { FibFFRTChildWait(x - 2, y2); }, {}, {}); in FibFFRTChildWait() 56 ffrt::submit([&]() { FibFFRTDataWait(x - 1, y1); }, {}, {&y1}); in FibFFRTDataWait() 57 ffrt::submit([&]() { FibFFRTDataWait(x - 2, y2); }, {}, {&y2}); in FibFFRTDataWait() 77 ffrt::submit([&]() { FibFFRTDataWait(FIB_NUM, output); }, {}, {&output}); in FibDataWait() 91 ffrt::submit([=]() { FibFFRTNoWait(x - 1, y1); }, {}, {y1}); in FibFFRTNoWait() 92 ffrt::submit([=]() { FibFFRTNoWait(x - 2, y2); }, {}, {y2}); in FibFFRTNoWait() 93 ffrt::submit( in FibFFRTNoWait() 117 ffrt::submit([&]() { FibFFRTNoWait(FIB_NUM, &output); }, {}, {&output}); in FibNoWait() 135 ffrt::submit([ in FibChildWait() [all...] |
/foundation/resourceschedule/ffrt/benchmarks/face_story/ |
H A D | face_story.cpp | 39 ffrt::submit( in FaceStory() 42 ffrt::submit([&]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in FaceStory() 45 ffrt::submit([&]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in FaceStory() 55 ffrt::submit( in FaceStory() 66 ffrt::submit([&]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {&faceBboxes_}, {}); in FaceStory() 71 ffrt::submit( in FaceStory() 82 ffrt::submit( in FaceStory() 93 ffrt::submit( in FaceStory() 104 ffrt::submit( in FaceStory() 115 ffrt::submit( in FaceStory() [all...] |
/foundation/resourceschedule/ffrt/examples/ |
H A D | submit.cpp | 21 ffrt::submit([&]() { x = 2; }, {}, {&x}); in ffrt_submit_example1() 22 ffrt::submit([&]() { x = x * 3; }, {&x}, {}); in ffrt_submit_example1() 30 ffrt::submit([&]() { x = 2; }, {}, {&x}, ffrt::task_attr().name("add2")); in ffrt_submit_example2() 31 ffrt::submit([&]() { x = x * 3; }, {&x}, {}, in ffrt_submit_example2()
|
/foundation/resourceschedule/ffrt/test/ut/testcase/ |
H A D | ut_condition.cpp | 54 ffrt::submit( in HWTEST_F() 61 ffrt::submit( in HWTEST_F() 77 ffrt::submit( in HWTEST_F() 83 ffrt::submit( in HWTEST_F() 90 ffrt::submit( in HWTEST_F() 107 ffrt::submit( in HWTEST_F() 115 ffrt::submit( in HWTEST_F() 132 ffrt::submit( in HWTEST_F() 207 ffrt::submit([&]() {}, {}, {}); in HWTEST_F() 217 ffrt::submit( in HWTEST_F() [all...] |
H A D | ut_csync.cpp | 146 ffrt::submit([&]() { in HWTEST_F() 150 ffrt::submit([&]() { in HWTEST_F() 153 ffrt::submit([&]() { in HWTEST_F() 157 ffrt::submit([&]() { in HWTEST_F() 165 ffrt::submit([&]() { in HWTEST_F() 168 ffrt::submit([&]() { in HWTEST_F() 171 ffrt::submit([&]() { in HWTEST_F() 175 ffrt::submit([&]() { in HWTEST_F() 196 ffrt::submit([&]() { in HWTEST_F() 205 ffrt::submit([ in HWTEST_F() [all...] |
H A D | ut_dependency.cpp | 57 ffrt::submit([&]() { x = 2; }, {}, {&x}); in HWTEST_F() 58 ffrt::submit([&]() { x = x * 3; }, {&x}, {}); in HWTEST_F() 74 ffrt::submit([] { in HWTEST_F() 90 ffrt::submit([] { in HWTEST_F() 100 ffrt::submit([] { in HWTEST_F() 117 ffrt::submit([&] { in HWTEST_F() 144 ffrt::submit([&] { in HWTEST_F() 163 ffrt::submit([] { in HWTEST_F() 231 ffrt::submit([&]() { stall_us(10); }, {}, {}); in HWTEST_F() 260 ffrt::submit( in HWTEST_F() [all...] |
H A D | ut_ffrt_io.cpp | 79 ffrt::submit([&]() { in HWTEST_F() 87 ffrt::submit([&]() { in HWTEST_F() 99 ffrt::submit([&]() { in HWTEST_F() 106 ffrt::submit([&]() { in HWTEST_F() 135 ffrt::submit([fd, i]() { in HWTEST_F() 145 ffrt::submit([&, i]() { in HWTEST_F() 191 ffrt::submit([&]() { in HWTEST_F() 238 ffrt::submit([&]() { in HWTEST_F() 265 ffrt::submit([&]() { in HWTEST_F() 293 ffrt::submit([ in HWTEST_F() [all...] |
H A D | ut_execute_unit.cpp | 57 ffrt::submit([&]() { x.fetch_add(1); }); in HWTEST_F() 58 ffrt::submit([&]() { x.fetch_add(2); }, {}, {}, ffrt::task_attr().delay(1)); in HWTEST_F()
|
H A D | ut_dfx.cpp | 58 ffrt::submit( in HWTEST_F() 116 ffrt::submit(basic1Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_default))); in HWTEST_F() 119 ffrt::submit(basic3Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_default))); in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
H A D | concurrent_adapter.cpp | 23 ffrt::submit(action); in ScheduleTask() 25 ffrt::submit(action, {}, { outDeps }); in ScheduleTask() 27 ffrt::submit(action, { inDeps }, {}); in ScheduleTask() 29 ffrt::submit(action, { inDeps }, { outDeps }); in ScheduleTask()
|
/foundation/resourceschedule/frame_aware_sched/interfaces/innerkits/frameintf/ |
H A D | frame_msg_intf.cpp | 48 taskQueue_->submit([] { in Init() 75 taskQueue_->submit([pid, uid, isFocus] { in ReportWindowFocus() 88 taskQueue_->submit([pid, uid, renderTid] { in ReportRenderThread() 101 taskQueue_->submit([pid, uid, bundleName, state] { in ReportAppInfo() 113 taskQueue_->submit([pid, uid, bundleName, state] { in ReportProcessInfo() 127 taskQueue_->submit([pid, uid, oldGroup, newGroup] { in ReportCgroupChange() 139 taskQueue_->submit([pid, uid, status] { in ReportContinuousTask()
|
/foundation/resourceschedule/ffrt/benchmarks/fork_join/ |
H A D | fork_join.cpp | 28 ffrt::submit([=]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in ForkJoin() 41 ffrt::submit( in ForkJoinWorker() 44 ffrt::submit([=]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in ForkJoinWorker()
|
/foundation/resourceschedule/ffrt/benchmarks/ |
H A D | common.h | 73 ffrt::submit([&]() { FibFFRT(x - 1, y1); }, {&x}, {&y1}); in FibFFRT() 74 ffrt::submit([&]() { FibFFRT(x - 2, y2); }, {&x}, {&y2}); in FibFFRT() 87 ffrt::submit([&]() { FibFFRT(20, output); }, {}, {&output}); in PreHotFFRT() 104 ffrt::submit([&]() { simulate_task_compute_time(duration); }, {}, {}); in completely_paralle() 116 ffrt::submit([&]() { simulate_task_compute_time(duration); }, {&x}, {&x}); in completely_serial()
|
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/quick_fix/ |
H A D | quick_fix_mgr.cpp | 48 ffrt::submit(task); in DeployQuickFix() 67 ffrt::submit(task); in SwitchQuickFix() 86 ffrt::submit(task); in DeleteQuickFix()
|
/foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
H A D | task.h | 323 static inline void submit(std::function<void()>&& func, const task_attr& attr = {}) in submit() function 337 static inline void submit(std::function<void()>&& func, std::initializer_list<dependence> in_deps, in submit() function 354 static inline void submit(std::function<void()>&& func, std::initializer_list<dependence> in_deps, in submit() function 371 static inline void submit(std::function<void()>&& func, const std::vector<dependence>& in_deps, in submit() function 388 static inline void submit(std::function<void()>&& func, const std::vector<dependence>& in_deps, in submit() function 404 static inline void submit(const std::function<void()>& func, const task_attr& attr = {}) in submit() function 418 static inline void submit(const std::function<void()>& func, std::initializer_list<dependence> in_deps, in submit() function 435 static inline void submit(const std::function<void()>& func, std::initializer_list<dependence> in_deps, in submit() function 452 static inline void submit(const std::function<void()>& func, const std::vector<dependence>& in_deps, in submit() function 469 static inline void submit(cons function [all...] |
H A D | queue.h | 139 inline void submit(const std::function<void()>& func, const task_attr& attr = {}) in submit() function in ffrt::queue 152 inline void submit(std::function<void()>&& func, const task_attr& attr = {}) in submit() function in ffrt::queue
|
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/ |
H A D | iptables_wrapper.cpp | 78 iptablesWrapperFfrtQueue_->submit(executeCommand); in RunCommand() 88 iptablesWrapperFfrtQueue_->submit(executeCommand); in RunCommand() 140 iptablesWrapperFfrtQueue_->submit(executeCommand); in RunMutipleCommands() 146 iptablesWrapperFfrtQueue_->submit(executeCommand); in RunMutipleCommands()
|
/foundation/resourceschedule/ffrt/src/sync/ |
H A D | thread.cpp | 47 ffrt::submit([p, func, arg]() { in ffrt_thread_create() 86 ffrt::submit([thr]() { free(thr); }, {thr}); in ffrt_thread_detach()
|
/foundation/bundlemanager/app_domain_verify/test/unittest/mock/include/mock_ffrt/ |
H A D | ffrt.h | 23 inline void submit(const std::function<void()>& func) in submit() function in ffrt::queue
|
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/utd/ |
H A D | utd_handler.cpp | 43 ffrt::submit(installUtdTask); in InstallUtdAsync() 54 ffrt::submit(uninstallUtdTask); in UninstallUtdAsync()
|
/foundation/communication/netmanager_base/services/netconnmanager/src/ |
H A D | nat464_service.cpp | 93 ffrt::submit([this]() { DiscoverPrefix(); }, {}, {}, in StartPrefixDiscovery() 118 ffrt::submit([this]() { DiscoverPrefix(); }, {}, {}, in DiscoverPrefix()
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcamera/ |
H A D | dcamera_service_state_listener.cpp | 56 ffrt::submit([=]() mutable { in OnRegisterNotify() 96 ffrt::submit([=]() mutable { in OnUnregisterNotify()
|
/foundation/communication/netmanager_ext/services/networksharemanager/src/ |
H A D | networkshare_upstreammonitor.cpp | 37 ffrtQueue.submit([weakMonitor = std::weak_ptr(this->NetworkMonitor_), netHandle]() mutable { in NetAvailable() 49 ffrtQueue.submit([weakMonitor = std::weak_ptr(this->NetworkMonitor_), netHandle, netAllCap]() mutable { in NetCapabilitiesChange() 61 ffrtQueue.submit([weakMonitor = std::weak_ptr(this->NetworkMonitor_), netHandle, info]() mutable { in NetConnectionPropertiesChange() 72 ffrtQueue.submit([weakMonitor = std::weak_ptr(this->NetworkMonitor_), netHandle]() mutable { in NetLost()
|
/foundation/communication/netmanager_base/services/netpolicymanager/src/common/ |
H A D | net_policy_event_handler.cpp | 41 ffrtQueue_.submit([this, eventId, eventData] { ProcessEvent(eventId, eventData); }, in SendEvent()
|