Lines Matching refs:ffrt
107 ffrt::mutex lock;
126 ffrt::recursive_mutex lock;
145 ffrt::mutex lock;
146 ffrt::submit([&]() {
147 ffrt::this_task::sleep_for(10ms);
150 ffrt::submit([&]() {
153 ffrt::submit([&]() {
157 ffrt::submit([&]() {
160 ffrt::wait();
163 }, {}, {}, ffrt::task_attr().name("t2"));
165 ffrt::submit([&]() {
168 ffrt::submit([&]() {
171 ffrt::submit([&]() {
175 ffrt::submit([&]() {
178 ffrt::wait();
181 }, {}, {}, ffrt::task_attr().name("t1"));
182 ffrt::wait();
194 ffrt::shared_mutex lock;
196 ffrt::submit([&]() {
199 ffrt::this_task::sleep_for(10ms);
203 }, {}, {}, ffrt::task_attr().name("t1"));
205 ffrt::submit([&]() {
211 }, {}, {}, ffrt::task_attr().name("t2"));
213 ffrt::wait();
224 ffrt::submit([&]() {
227 ffrt::CPUEUTask* ctx = ffrt::ExecuteCtx::Cur()->task;
228 bool result = ffrt::LegacyMode(ctx);
230 ffrt::submit([&]() {
232 ffrt::CPUEUTask* ctx = ffrt::ExecuteCtx::Cur()->task;
233 bool result = ffrt::LegacyMode(ctx);
239 ctx = ffrt::ExecuteCtx::Cur()->task;
243 ffrt::wait();
246 ctx = ffrt::ExecuteCtx::Cur()->task;
250 ffrt::wait();
258 ffrt::mutex mtx;
259 ffrt::task_attr taskAttr;
260 ffrt::task_handle taskHandle;
261 ffrt::condition_variable cv;
262 ffrt::thread t;
266 ffrt::mutex* mtxAddr = &m.mtx;
270 ffrt::task_attr* attrAddr = &m.taskAttr;
274 ffrt::task_handle* handleAddr = &m.taskHandle;
278 ffrt::condition_variable* cvAddr = &m.cv;
282 ffrt::thread* tAddr = &m.t;
291 ffrt::submit([&]() {}, {}, {});
292 ffrt::wait();
297 ffrt::mutex lock;
301 ffrt::submit(
318 ffrt::wait();
325 ffrt::submit([&]() {}, {}, {});
326 ffrt::wait();
331 ffrt::mutex* lock = new ffrt::mutex;
334 ffrt::submit(
351 ffrt::wait();
364 ffrt::submit([&]() {}, {}, {});
365 ffrt::wait();
370 ffrt::recursive_mutex lock;
374 ffrt::submit(
391 ffrt::wait();
403 ffrt::submit([&]() {}, {}, {});
404 ffrt::wait();
409 ffrt::recursive_mutex* lock = new ffrt::recursive_mutex;
412 ffrt::submit(
429 ffrt::wait();
436 ffrt::condition_variable cond;
438 ffrt::mutex lock_;
440 ffrt::submit(
447 ffrt::submit(
454 ffrt::wait();
459 ffrt::condition_variable cond;
461 ffrt::mutex lock_;
463 ffrt::submit(
469 ffrt::submit(
475 ffrt::submit(
482 ffrt::submit(
489 ffrt::wait();
494 ffrt::condition_variable cond;
496 ffrt::mutex lock_;
498 ffrt::submit(
505 ffrt::submit(
512 ffrt::submit(
519 ffrt::wait();
525 ffrt::mutex mtx;
526 ffrt::condition_variable cv;
529 ffrt::thread th {[&] {
533 ffrt::this_task::sleep_for(1us);
547 ffrt::thread th1 {[&] {
558 ffrt::this_task::sleep_for(1us);
565 static void NotifyOneTest(ffrt::mutex& mtx, ffrt::condition_variable& cv)
570 ffrt::submit(
581 ffrt::submit(
591 ffrt::wait();
596 static void WaitUntilTimeoutTest(ffrt::mutex& mtx, ffrt::condition_variable& cv)
602 ffrt::submit(
606 static_cast<int>(ffrt::cv_status::timeout));
614 ffrt::submit(
616 ffrt::this_task::sleep_for(30ms + eps);
621 ffrt::wait();
626 static void WaitUtilFlagTest_1(ffrt::mutex& mtx, ffrt::condition_variable& cv)
634 ffrt::submit(
644 ffrt::submit(
646 ffrt::this_task::sleep_for(30ms + eps);
651 ffrt::wait();
656 static void WaitUtilFlagTest_2(ffrt::mutex& mtx, ffrt::condition_variable& cv)
661 ffrt::submit(
671 ffrt::submit(
679 ffrt::wait();
684 static void WaitForTest_1(ffrt::mutex& mtx, ffrt::condition_variable& cv)
689 ffrt::submit(
692 EXPECT_EQ(static_cast<int>(cv.wait_for(lk, 30ms)), static_cast<int>(ffrt::cv_status::timeout));
700 ffrt::submit(
702 ffrt::this_task::sleep_for(30ms + eps);
707 ffrt::wait();
712 static void WaitForTest_2(ffrt::mutex& mtx, ffrt::condition_variable& cv)
715 ffrt::submit(
718 ffrt::submit(
724 EXPECT_EQ(static_cast<int>(cv.wait_for(lk, 30ms)), static_cast<int>(ffrt::cv_status::no_timeout));
731 ffrt::wait();
736 static void WaitForTest_3(ffrt::mutex& mtx, ffrt::condition_variable& cv)
743 ffrt::submit(
753 ffrt::submit(
755 ffrt::this_task::sleep_for(30ms + eps);
760 ffrt::wait();
765 static void WaitForTest_4(ffrt::mutex& mtx, ffrt::condition_variable& cv)
770 ffrt::submit(
780 ffrt::submit(
788 ffrt::wait();
795 ffrt::mutex mtx;
796 ffrt::condition_variable cv;
808 static void LockTest(ffrt::shared_mutex& smtx)
814 ffrt::submit(
830 ffrt::wait();
834 static void TryLockTest(ffrt::shared_mutex& smtx)
838 ffrt::submit(
841 ffrt::this_task::sleep_for(20ms);
846 ffrt::this_task::sleep_for(2ms);
853 ffrt::wait();
862 static void LockSharedTest(ffrt::shared_mutex& smtx)
867 ffrt::submit(
870 ffrt::this_task::sleep_for(20ms);
875 ffrt::this_task::sleep_for(2ms);
885 ffrt::wait();
892 static void TryLockSharedTest(ffrt::shared_mutex& smtx)
897 ffrt::submit(
900 ffrt::this_task::sleep_for(20ms);
905 ffrt::this_task::sleep_for(2ms);
913 ffrt::wait();
922 ffrt::submit(
925 ffrt::this_task::sleep_for(20ms);
930 ffrt::this_task::sleep_for(2ms);
938 ffrt::wait();
950 ffrt::shared_mutex smtx;
973 std::thread th2 {ThreadFunc2, "hello", "ffrt"};
986 ffrt::thread th0 {[&value, &ThreadFunc1, &ThreadFunc2] {
987 ffrt::thread th1 {ThreadFunc1, 10, 20};
988 ffrt::thread th2 {ThreadFunc2, "hello", "ffrt"};
1072 FFRT_LOGW("ffrt version");
1078 ffrt::thread t2(f1, n + 1);
1081 ffrt::thread t1; // t1 is not a thread
1082 ffrt::thread t2(f1, n + 1); // pass by value
1083 ffrt::thread t3(f2, std::ref(n)); // pass by reference
1084 ffrt::thread t4(std::move(t3)); // t4 is now running f2(). t3 is no longer a thread
1085 ffrt::thread t5(&foo::bar, &f); // t5 runs foo::bar() on object f
1086 ffrt::thread t6(b); // t6 runs baz::operator() on a copy of object b
1109 ffrt::thread(static_cast<int>(ffrt::qos_user_initiated), task).join();
1120 ffrt::thread(name.c_str(), static_cast<int>(ffrt::qos_user_initiated), task).join();
1139 ffrt::thread t(F{}, std::ref(a), std::cref(a), std::ref(a));
1153 ffrt::thread t(func, A{});
1159 ffrt::packaged_task<int()> task([] { return 7; });
1160 ffrt::future<int> f1 = task.get_future();
1161 ffrt::thread t(std::move(task));
1163 ffrt::future<int> f2 = ffrt::async([] { return 8; });
1165 ffrt::promise<int> p;
1166 ffrt::future<int> f3 = p.get_future();
1167 ffrt::thread([&p] { p.set_value(9); }).detach();