Home
last modified time | relevance | path

Searched refs:threads (Results 1 - 25 of 36) sorted by relevance

12

/foundation/resourceschedule/ffrt/src/eu/
H A Dcpuworker_manager.cpp67 auto result = groupCtl[workerQos].threads.emplace(worker, std::move(uniqueWorker)); in IncWorker()
89 return groupCtl[qos()].threads.size(); in GetWorkerCount()
110 if (GetStealingWorkers(thread->GetQos()) > groupCtl[thread->GetQos()].threads.size() / 2) { in StealTaskBatch()
117 groupCtl[thread->GetQos()].threads.begin(); in StealTaskBatch()
118 while (iter != groupCtl[thread->GetQos()].threads.end()) { in StealTaskBatch()
176 auto worker = std::move(groupCtl[qos].threads[thread]); in WorkerRetired()
177 int ret = groupCtl[qos].threads.erase(thread); in WorkerRetired()
H A Dworker_manager.cpp24 for (auto& thread : tgwrap.threads) { in JoinRtg()
50 for (auto& thread : tgwrap.threads) { in JoinTG()
74 for (auto& thread : groupCtl[qos].threads) { in LeaveTG()
H A Dworker_manager.h38 std::unordered_map<WorkerThread*, std::unique_ptr<WorkerThread>> threads; member
H A Dscpuworker_manager.cpp61 if (groupCtl[qos].threads.empty()) { in ~SCPUWorkerManager()
68 FFRT_LOGE("erase qos[%d] threads failed", qos); in ~SCPUWorkerManager()
81 bool isEmpty = groupCtl[qos].threads.empty(); in AddDelayedTask()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_rtg.cpp164 std::vector<std::thread> threads; in HWTEST_F() local
185 threads.emplace_back(std::thread(f)); in HWTEST_F()
213 for (auto& thread : threads) { in HWTEST_F()
232 std::vector<std::thread> threads; in HWTEST_F() local
253 threads.emplace_back(std::thread(f)); in HWTEST_F()
298 for (auto& thread : threads) { in HWTEST_F()
/foundation/graphic/graphic_3d/lume/LumeEngine/src/threading/
H A Ddispatcher_impl.cpp27 DispatcherImpl::DispatcherImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in DispatcherImpl() argument
H A Dsequential_impl.cpp27 SequentialImpl::SequentialImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in SequentialImpl() argument
H A Dparallel_impl.cpp27 ParallelImpl::ParallelImpl(const IThreadPool::Ptr& threads) : queue_(threads) {} in ParallelImpl() argument
H A Dtask_queue_factory.cpp145 auto threads = array_view<ThreadContext>(threads_.get(), threadCount_); in ThreadPool() local
146 for (ThreadContext& context : threads) { in ThreadPool()
313 // Ask all the threads to stop and not process any more tasks. in Stop()
314 auto threads = array_view(threads_.get(), threadCount_); in Stop() local
317 for (auto& context : threads) { in Stop()
324 // Trigger all waiting threads. in Stop()
327 // Wait for all threads to finish. in Stop()
328 auto threads = array_view(threads_.get(), threadCount_); in Stop() local
329 for (auto& context : threads) { in Stop()
H A Ddispatcher_impl.h30 explicit DispatcherImpl(const IThreadPool::Ptr& threads);
H A Dsequential_impl.h30 explicit SequentialImpl(const IThreadPool::Ptr& threads);
H A Dparallel_impl.h30 explicit ParallelImpl(const IThreadPool::Ptr& threads);
/foundation/resourceschedule/frame_aware_sched/test/unittest/phone/
H A Drtg_interface_test.cpp398 vector<int> threads; in HWTEST_F() local
407 threads.push_back(pid[i]); in HWTEST_F()
411 ret = AddThreadsToRtg(threads, grpId); in HWTEST_F()
419 * @tc.desc: Verify rtg multiple add function with out of limit threads.
426 vector<int> threads; in HWTEST_F() local
435 threads.push_back(pid[i]); in HWTEST_F()
439 ret = AddThreadsToRtg(threads, grpId); in HWTEST_F()
/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dbackground_task_executor.cpp55 LOGI("Create ace bg threads pool."); in BackgroundTaskExecutor()
57 // Start other threads in the first created thread. in BackgroundTaskExecutor()
68 std::list<std::thread> threads; in ~BackgroundTaskExecutor() local
74 threads = std::move(threads_); in ~BackgroundTaskExecutor()
77 for (auto& threadInPool : threads) { in ~BackgroundTaskExecutor()
166 // Start new threads. in StartNewThreads()
/foundation/multimedia/audio_framework/frameworks/native/audioutils/test/unittest/
H A Daudio_utils_unit_test.cpp1357 static void ThreadsJoin(std::thread (&threads)[THREAD_NUM])
1359 for (auto& t : threads) {
1376 * @tc.desc: Multiple threads put until blocking runs, one thread gets, all threads finish running normally
1380 std::thread threads[THREAD_NUM]; in HWTEST() local
1386 threads[i] = std::thread(PutHandleThreadData, std::ref(demoDatas[i]), i); in HWTEST()
1389 // 1. queue is full and some threads is blocked in HWTEST()
1405 // queue is full and some threads is blocked and is not joined in HWTEST()
1407 ThreadsJoin(threads); in HWTEST()
1428 * @tc.desc: Multi-threaded put() on the empty queue. When n threads ar
1434 std::thread threads[THREAD_NUM]; HWTEST() local
1500 std::thread threads[THREAD_NUM]; HWTEST() local
1548 std::thread threads[THREAD_NUM]; HWTEST() local
1597 std::thread threads[THREAD_NUM]; HWTEST() local
1653 std::thread threads[THREAD_NUM]; HWTEST() local
1703 std::thread threads[THREAD_NUM]; HWTEST() local
[all...]
/foundation/resourceschedule/ffrt/src/util/
H A Dworker_monitor.cpp131 if (!workerGroup[i].threads.empty()) { in SubmitMemReleaseTask()
164 if (!workerGroup[i].threads.empty()) { in CheckWorkerStatus()
180 CoWorkerInfo coWorkerInfo(i, workerGroup[i].threads.size(), executionNum, sleepingWorkerNum); in CheckWorkerStatus()
181 for (auto& thread : workerGroup[i].threads) { in CheckWorkerStatus()
/foundation/graphic/graphic_surface/surface/src/
H A Dbuffer_utils.cpp342 // Obtain the number of parallelizable threads. in CloneBuffer()
357 // Vector to store threads in CloneBuffer()
358 std::vector<std::thread> threads; in CloneBuffer() local
362 // Create threads and copy blocks of memory in CloneBuffer()
367 threads.emplace_back(copy_block, current_dest, current_src, length_to_copy); in CloneBuffer()
374 threads.emplace_back(copy_block, current_dest, current_src, last_block_size); in CloneBuffer()
377 // Wait for all threads to finish in CloneBuffer()
378 for (auto& th : threads) { in CloneBuffer()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_nb_autolaunch_test.cpp604 vector<thread> threads; in HWTEST_F() local
607 threads.push_back(thread([&]() { in HWTEST_F()
615 threads.push_back(thread([&]() { in HWTEST_F()
621 threads.push_back(thread([&]() { in HWTEST_F()
634 for (auto &th : threads) { in HWTEST_F()
H A Ddistributeddb_nb_enable_sync_by_closed_db_test.cpp593 vector<thread> threads; in HWTEST_F() local
596 threads.push_back(thread([&]() { in HWTEST_F()
604 threads.push_back(thread([&]() { in HWTEST_F()
610 threads.push_back(thread([&]() { in HWTEST_F()
623 for (auto &th : threads) { in HWTEST_F()
H A Ddistributeddb_nb_cursor_testcase.cpp1728 std::vector<std::thread> threads; in ResultSetDb025() local
1730 threads.push_back(std::thread(CursorOperThread, std::ref(delegate))); in ResultSetDb025()
1732 for (auto& th : threads) { in ResultSetDb025()
1961 std::vector<std::thread> threads; in ResultSetDb026() local
1962 threads.push_back(std::thread(CursorRandOperThread1, std::ref(resultSetAll))); in ResultSetDb026()
1963 threads.push_back(std::thread(CursorRandOperThread2, std::ref(resultSetAll))); in ResultSetDb026()
1964 threads.push_back(std::thread(CursorRandOperThread3, std::ref(resultSetAll))); in ResultSetDb026()
1965 threads.push_back(std::thread(CursorRandOperThread4, std::ref(resultSetAll))); in ResultSetDb026()
1967 for (auto& th : threads) { in ResultSetDb026()
/foundation/communication/ipc/ipc/native/c/ipc/src/liteos_a/
H A Dserializer_inner.c15 #include <threads.h>
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_import_and_export_rd_test.cpp1206 * @tc.steps: step3. Multi threads to occupy write handles. in HWTEST_F()
1209 vector<thread> threads; in HWTEST_F() local
1210 threads.emplace_back(thread([&]() { in HWTEST_F()
1213 threads.emplace_back(&KvStoreNbDelegate::Import, g_kvNbDelegatePtr, singleExportFileName, passwd); in HWTEST_F()
1214 threads.emplace_back(thread([&i]() { in HWTEST_F()
1218 for (auto &th: threads) { in HWTEST_F()
/foundation/communication/ipc/ipc/test/moduletest/native/common/
H A Dipc_core_module_test.cpp727 * @tc.desc: Test obtaining the same proxy by multiple threads concurrently.
732 std::vector<std::unique_ptr<std::thread>> threads; in HWTEST_F() local
734 auto& res = threads.emplace_back(std::make_unique<std::thread>(&IPCNativeFrameworkTest::RegisterThread)); in HWTEST_F()
738 for (auto &thread : threads) { in HWTEST_F()
/foundation/arkui/ace_engine/test/unittest/core/pipeline/
H A Dpipeline_context_test_ng.cpp1465 std::vector<std::thread> threads; in HWTEST_F() local
1467 threads.emplace_back(std::thread([]() { context_->GetOrCreateSharedImageManager(); })); in HWTEST_F()
1469 for (auto&& thread : threads) { in HWTEST_F()
1473 threads.clear(); in HWTEST_F()
1478 threads.emplace_back(std::thread([]() { context_->GetThemeManager(); })); in HWTEST_F()
1481 for (auto&& thread : threads) { in HWTEST_F()
/foundation/resourceschedule/ffrt/src/dfx/bbox/
H A Dbbox.cpp98 for (auto& thread : workerGroup[i].threads) { in SaveWorkerStatus()
426 for (auto& thread : workerGroup[i].threads) { in SaveWorkerStatusInfo()

Completed in 21 milliseconds

12