Home
last modified time | relevance | path

Searched refs:ffrt (Results 1 – 25 of 1614) sorted by relevance

12345678910>>...65

/ohos5.0/foundation/resourceschedule/ffrt/test/testfunc/
H A Dfunc_pool.cpp27 using namespace ffrt;
38 ffrt::wait({ &val1, &val2 }); in NestedFib()
50 ffrt::wait({ &val }); in NestedAddOne()
59 ffrt::submit( in NestedWhile()
61 ffrt::submit( in NestedWhile()
63 ffrt::submit( in NestedWhile()
190 ffrt::submit( in NestedWhile()
196 ffrt::wait(); in NestedWhile()
199 ffrt::submit( in NestedWhile()
205 ffrt::wait(); in NestedWhile()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/util/
H A Dinit.cpp35 … return static_cast<ffrt::CPUEUTask*>(ffrt::SimpleAllocator<ffrt::SCPUEUTask>::AllocMem()); in ffrt_init()
38 ffrt::SimpleAllocator<ffrt::SCPUEUTask>::FreeMem(static_cast<ffrt::SCPUEUTask*>(task)); in ffrt_init()
40 ffrt::SimpleAllocator<ffrt::SCPUEUTask>::getUnfreedMem, in ffrt_init()
41 ffrt::SimpleAllocator<ffrt::SCPUEUTask>::LockMem, in ffrt_init()
42 ffrt::SimpleAllocator<ffrt::SCPUEUTask>::UnlockMem); in ffrt_init()
44 [] () -> ffrt::TaskScheduler* { return new ffrt::TaskScheduler{new ffrt::FIFOQueue()}; }, in ffrt_init()
48 ffrt::DependenceManager::RegistInsCb(ffrt::SDependenceManager::Instance); in ffrt_init()
49 ffrt::ExecuteUnit::RegistInsCb(ffrt::SExecuteUnit::Instance); in ffrt_init()
50 ffrt::FFRTScheduler::RegistInsCb(ffrt::SFFRTScheduler::Instance); in ffrt_init()
51 ffrt::SetFuncQosMap(ffrt::QoSMap); in ffrt_init()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_csync.cpp138 ffrt::wait();
164 ffrt::wait();
172 ffrt::wait();
177 ffrt::mutex* lock = new ffrt::mutex;
197 ffrt::wait();
208 ffrt::submit(
215 ffrt::submit(
222 ffrt::wait();
231 ffrt::submit(
237 ffrt::submit(
[all …]
H A Dut_dependency.cpp58 ffrt::wait();
73 ffrt::submit([] { in __anonf988f8560702()
77 ffrt::wait();
86 ffrt::set_trace_tag("TASK A");
87 ffrt::clear_trace_tag();
92 ffrt::task_attr tmpTask;
113 auto it = ffrt::qos_interval_create(16, static_cast<int>(ffrt::qos_user_interactive));
140 ffrt::submit(
146 ffrt::submit(
152 ffrt::submit(
[all …]
H A Dut_condition.cpp54 ffrt::submit(
61 ffrt::submit(
68 ffrt::wait();
77 ffrt::submit(
83 ffrt::submit(
90 ffrt::submit(
98 ffrt::wait();
107 ffrt::submit(
115 ffrt::submit(
123 ffrt::wait();
[all …]
H A Dut_execute_unit.cpp32 using namespace ffrt;
57 ffrt::submit([&]() { x += 1; }); in __anon316266890102()
58 ffrt::submit([&]() { x += 2; }, {}, {}, ffrt::task_attr().delay(1)); in __anon316266890402()
60 auto h2 = ffrt::submit_h([&]() { x += 4; }, {}, {}, ffrt::task_attr().delay(5)); in __anon316266890602()
61 int cancel_ret = ffrt::skip(h2);
63 ffrt::wait();
72 auto h2 = ffrt::submit_h([&]() { x += 2; }, {&x}, {&x}, ffrt::task_attr().delay(1)); in __anon316266890c02()
75 ffrt::wait();
78 cancel_ret = ffrt::skip(h1);
80 ffrt::task_handle h3;
[all …]
H A Dut_ffrt_io.cpp58 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos; in TearDown()
82 ffrt::wait();
105 ffrt::wait();
201 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
214 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
242 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
266 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
300 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
330 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
359 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos;
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/core/
H A Dtask.cpp41 namespace ffrt { namespace
275 return ffrt::SimpleAllocator<ffrt::QueueTask>::AllocMem()->func_storage;
399 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
407 for (auto qos = ffrt::QoS::Min(); qos < ffrt::QoS::Max(); ++qos) {
422 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
423 … if (((qos != ffrt::qos_default) && (_qos() == ffrt::qos_default)) || (qos <= ffrt::qos_inherit)) {
476 ffrt::QoS _qos = ffrt::GetFuncQosMap()(qos);
531 ffrt::QueueTask* task = reinterpret_cast<ffrt::QueueTask*>(curTask);
542 ffrt::CPUEUTask *task = static_cast<ffrt::CPUEUTask*>(handle);
569 ffrt::FuncManager* func_mg = ffrt::FuncManager::Instance();
[all …]
H A Dtask_io.cpp31 namespace ffrt { namespace
53 task->status = ffrt::ExecTaskStatus::ET_PENDING; in ExecuteIOTask()
75 pthread_once(&ffrt::once, ffrt::InitIOTaskExecutor);
77 …ffrt::task_attr_private *p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr…
78 ffrt::QoS qos = (p == nullptr ? ffrt::QoS() : ffrt::QoS(p->qos_));
82 ffrt::IOTaskExecutor* task = new (std::nothrow) ffrt::IOTaskExecutor(qos);
88 task->status = ffrt::ExecTaskStatus::ET_READY;
112 ffrt::IOTaskExecutor* wakedTask = static_cast<ffrt::IOTaskExecutor*>(task);
113 wakedTask->status = ffrt::ExecTaskStatus::ET_READY;
123 if (ffrt::ExecuteCtx::Cur()->localFifo != nullptr &&
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/sync/
H A Dpoller_api.cpp21 static bool QosConvert(ffrt_qos_t qos, ffrt::QoS& mappedQos) in QosConvert()
23 if (ffrt::GetFuncQosMap() == nullptr) { in QosConvert()
27 mappedQos = ffrt::GetFuncQosMap()(qos); in QosConvert()
28 if (mappedQos == ffrt::qos_inherit) { in QosConvert()
29 mappedQos = ffrt::ExecuteCtx::Cur()->qos(); in QosConvert()
37 ffrt::QoS ffrtQos;
58 ffrt::QoS ffrtQos;
68 ffrt::QoS pollerQos;
73 ffrt::FFRTFacade::GetPPInstance().GetPoller(pollerQos).WakeUp();
79 ffrt::QoS pollerQos;
[all …]
H A Dtimer_api.cpp22 static bool QosConvert(ffrt_qos_t qos, ffrt::QoS& mappedQos) in QosConvert()
24 if (ffrt::GetFuncQosMap() == nullptr) { in QosConvert()
28 mappedQos = ffrt::GetFuncQosMap()(qos); in QosConvert()
29 if (mappedQos == ffrt::qos_inherit) { in QosConvert()
30 mappedQos = ffrt::ExecuteCtx::Cur()->qos(); in QosConvert()
38 ffrt::QoS pollerQos;
50 ffrt::FFRTFacade::GetEUInstance().NotifyLocalTaskAdded(pollerQos);
58 ffrt::QoS pollerQos;
63 return ffrt::FFRTFacade::GetPPInstance().GetPoller(pollerQos).UnregisterTimer(handle);
69 ffrt::QoS pollerQos;
[all …]
H A Dcondition_variable.cpp23 namespace ffrt { namespace
37 static_assert(sizeof(ffrt::condition_variable_private) <= ffrt_cond_storage_size,
40 new (cond) ffrt::condition_variable_private();
51 auto p = reinterpret_cast<ffrt::condition_variable_private *>(cond);
63 auto p = reinterpret_cast<ffrt::condition_variable_private *>(cond);
75 auto pc = reinterpret_cast<ffrt::condition_variable_private *>(cond);
76 auto pm = reinterpret_cast<ffrt::mutexPrivate *>(mutex);
88 auto pc = reinterpret_cast<ffrt::condition_variable_private *>(cond);
89 auto pm = reinterpret_cast<ffrt::mutexPrivate *>(mutex);
93 auto tp = ffrt::TimePoint {
[all …]
/ohos5.0/foundation/barrierfree/accessibility/services/aams/src/
H A Daccessibility_settings.cpp92 if (wait != ffrt::future_status::ready) { in SetShortKeyState()
144 if (wait != ffrt::future_status::ready) { in SetMouseAutoClick()
181 if (wait != ffrt::future_status::ready) { in SetShortkeyTarget()
217 if (wait != ffrt::future_status::ready) { in SetShortkeyMultiTarget()
342 if (wait != ffrt::future_status::ready) { in SetDaltonizationColorFilter()
377 if (wait != ffrt::future_status::ready) { in SetContentTimeout()
418 if (wait != ffrt::future_status::ready) { in SetBrightnessDiscount()
455 if (wait != ffrt::future_status::ready) { in SetAudioBalance()
493 if (wait != ffrt::future_status::ready) { in SetClickResponseTime()
531 if (wait != ffrt::future_status::ready) { in SetIgnoreRepeatClickState()
[all …]
H A Daccessible_ability_channel.cpp69 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in SearchElementInfoByAccessibilityId()
101 if (wait != ffrt::future_status::ready) { in SearchElementInfoByAccessibilityId()
129 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in SearchElementInfosByText()
178 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in FindFocusedElementInfo()
230 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in FocusMoveSearch()
348 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in ExecuteAction()
404 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in GetWindow()
466 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in GetWindows()
549 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in GetCursorPosition()
595 …std::shared_ptr<ffrt::promise<RetError>> syncPromise = std::make_shared<ffrt::promise<RetError>>(); in SendSimulateGesture()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/benchmarks/fib/
H A Dfib.cpp19 using namespace ffrt;
41 ffrt::submit([&]() { FibFFRTChildWait(x - 1, y1); }, {}, {}); in FibFFRTChildWait()
42 ffrt::submit([&]() { FibFFRTChildWait(x - 2, y2); }, {}, {}); in FibFFRTChildWait()
43 ffrt::wait(); in FibFFRTChildWait()
58 ffrt::wait({&y1, &y2}); in FibFFRTDataWait()
78 ffrt::wait({&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()
118 ffrt::wait({&output}); in FibNoWait()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/examples/
H A Dsubmit.cpp21 ffrt::submit([&]() { x = 2; }, {}, {&x}); in ffrt_submit_example1()
22 ffrt::submit([&]() { x = x * 3; }, {&x}, {}); in ffrt_submit_example1()
23 ffrt::wait(); 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()
32 ffrt::task_attr().name("mul3")); // default to CPU in ffrt_submit_example2()
33 ffrt::wait(); in ffrt_submit_example2()
41 ffrt::task_handle h = ffrt::submit_h([&]() { x = 2; }, {}, {}); in ffrt_submit_example3()
42 ffrt::wait({h}); in ffrt_submit_example3()
/ohos5.0/foundation/resourceschedule/ffrt/docs/
H A Duser_guide.md123 * API上，二者仅在命令空间上有差异，可平滑替换(ffrt::mutex可在非ffrt task中调用，效果与普通的锁一致)
129 namespace ffrt {
195 #include "ffrt.h"
321 namespace ffrt {
418 namespace ffrt {
464 ffrt::task_attr().qos(ffrt::qos_background));
483 namespace ffrt {
819 ffrt::queue q("test_queue", ffrt::queue_attr().qos(ffrt::qos_utility));
847 …当前FFRT仅支持ffrt::mutex / ffrt::shared_mutex / ffrt::recursive_mutex / ffrt::condition_variable，用法和st…
853 * 不允许再串行任务中调用ffrt::submit和ffrt::wait，其行为是未定义的
[all …]
/ohos5.0/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/
H A Dslide_recognizer.cpp32 static ffrt::recursive_mutex stateMutex;
88 ffrt::skip(listFlingEndTask_); in HandleSlideOFFEvent()
91 ffrt::skip(listFlingTimeOutTask_); in HandleSlideOFFEvent()
103 ffrt::skip(listFlingEndTask_); in HandleSlideDetecting()
106 ffrt::skip(listFlingTimeOutTask_); in HandleSlideDetecting()
135 ffrt::skip(listFlingEndTask_); in HandleListFlingStart()
137 listFlingEndTask_ = ffrt::submit_h([payload]() { in HandleListFlingStart()
141 ffrt::skip(listFlingTimeOutTask_); in HandleListFlingStart()
143 listFlingTimeOutTask_ = ffrt::submit_h([payload]() { in HandleListFlingStart()
165 ffrt::skip(listFlingEndTask_); in HandleSendFrameEvent()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/benchmarks/face_story/
H A Dface_story.cpp39 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()
47 ffrt::wait(); // 同步下采样结果 in FaceStory()
55 ffrt::submit( 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 …]
/ohos5.0/foundation/ai/intelligent_voice_framework/utils/
H A Dthread_wrapper.cpp37 …thread_ = std::make_unique<ffrt::thread>(name.c_str(), Convert2FfrtQos(qos), &ThreadWrapper::RunIn… in Start()
74 ffrt::qos ThreadWrapper::Convert2FfrtQos(TaskQoS taskqos) in Convert2FfrtQos()
78 return ffrt::qos_inherit; in Convert2FfrtQos()
80 return ffrt::qos_background; in Convert2FfrtQos()
82 return ffrt::qos_utility; in Convert2FfrtQos()
84 return ffrt::qos_default; in Convert2FfrtQos()
86 return ffrt::qos_user_initiated; in Convert2FfrtQos()
88 return ffrt::qos_deadline_request; in Convert2FfrtQos()
90 return ffrt::qos_user_interactive; in Convert2FfrtQos()
95 return ffrt::qos_inherit; in Convert2FfrtQos()
/ohos5.0/foundation/communication/wifi/wifi/utils/src/
H A Dwifi_event_handler.cpp109 std::lock_guard<ffrt::mutex> lock(eventQurueMutex); in WifiEventHandlerImpl()
119 ffrt::queue_attr().callback(timeOutFunc)); in WifiEventHandlerImpl()
128 std::lock_guard<ffrt::mutex> lock(eventQurueMutex); in ~WifiEventHandlerImpl()
145 std::lock_guard<ffrt::mutex> lock(eventQurueMutex); 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()
201 std::shared_ptr<ffrt::queue> eventQueue = nullptr;
202 mutable ffrt::mutex eventQurueMutex;
203 std::map<std::string, ffrt::task_handle> taskMap_;
315 ffrt::future f = ffrt::async(callback); in PostSyncTimeOutTask()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dco_routine.cpp47 using namespace ffrt;
91 bool IsTaskLocalEnable(ffrt::CPUEUTask* task) in IsTaskLocalEnable()
118 void SwitchTsdAddrToTask(ffrt::CPUEUTask* task) in SwitchTsdAddrToTask()
125 void SwitchTsdToTask(ffrt::CPUEUTask* task) in SwitchTsdToTask()
139 bool SwitchTsdAddrToThread(ffrt::CPUEUTask* task) in SwitchTsdAddrToThread()
168 void SwitchTsdToThread(ffrt::CPUEUTask* task) in SwitchTsdToThread()
184 void TaskTsdRunDtors(ffrt::CPUEUTask* task) in TaskTsdRunDtors()
192 void TaskTsdDeconstruct(ffrt::CPUEUTask* task) in TaskTsdDeconstruct()
227 ffrt::CPUEUTask* task = co->task; in CoStartEntry()
302 ffrt::CoRoutineFreeMem(co); in CoMemFree()
[all …]
/ohos5.0/base/powermgr/power_manager/test/apitest/inner_api/ffrt/src/
H A Dffrt_utils_test.cpp35 ffrt::wait(); // wait async task finish
63 ffrt::this_task::sleep_for(std::chrono::milliseconds(1)); in __anone73078890302()
78 ffrt::this_task::sleep_for(std::chrono::milliseconds(10));
81 ffrt::this_task::sleep_for(std::chrono::milliseconds(50));
84 ffrt::this_task::sleep_for(std::chrono::milliseconds(80));
103 ffrt::this_task::sleep_for(std::chrono::milliseconds(5));
106 ffrt::this_task::sleep_for(std::chrono::milliseconds(7));
125 ffrt::this_task::sleep_for(std::chrono::milliseconds(5));
131 ffrt::this_task::sleep_for(std::chrono::milliseconds(10));
210 ffrt::this_task::sleep_for(std::chrono::milliseconds(50));
[all …]
/ohos5.0/foundation/resourceschedule/device_usage_statistics/interfaces/innerkits/src/
H A Dbundle_active_client.cpp67 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in ReportEvent()
77 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in IsBundleIdle()
87 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in IsBundleUsePeriod()
98 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in QueryBundleStatsInfoByInterval()
109 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in QueryBundleEvents()
121 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in SetAppGroup()
132 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in QueryBundleStatsInfos()
143 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in QueryCurrentBundleEvents()
153 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in QueryAppGroup()
168 std::lock_guard<ffrt::recursive_mutex> lock(mutex_); in QueryModuleUsageRecords()
[all …]
/ohos5.0/base/telephony/call_manager/services/call/src/
H A Dcall_request_handler.cpp53 ffrt::submit([=]() { callRequestProcessPtr_->AnswerRequest(callId, videoState); }); in AnswerCall()
63 ffrt::submit([=]() { in RejectCall()
76 ffrt::submit([=]() { callRequestProcessPtr_->HangUpRequest(callId); }); in HangUpCall()
86 ffrt::submit([=]() { callRequestProcessPtr_->HoldRequest(callId); }); in HoldCall()
96 ffrt::submit([=]() { callRequestProcessPtr_->UnHoldRequest(callId); }); in UnHoldCall()
106 ffrt::submit([=]() { callRequestProcessPtr_->SwitchRequest(callId); }); in SwitchCall()
116 ffrt::submit([=]() { in StartRtt()
129 ffrt::submit([=]() { callRequestProcessPtr_->StopRttRequest(callId); }); in StopRtt()
139 ffrt::submit([=]() { in JoinConference()
152 ffrt::submit([=]() { callRequestProcessPtr_->CombineConferenceRequest(mainCallId); }); in CombineConference()
[all …]

12345678910>>...65