Home
last modified time | relevance | path

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

/arkcompiler/runtime_core/static_core/libpandabase/tests/
H A Dlock_holder_test.cpp60 std::array<std::thread, TEST_THREADS> threads; in TEST_F() local
63 threads[i] = std::thread(LockMutexesAndIncrement<Mutex>, std::ref(var), std::ref(lock)); in TEST_F()
67 threads[i].join(); in TEST_F()
77 std::array<std::thread, TEST_THREADS> threads; in TEST_F() local
83 threads[0U] = in TEST_F()
85 threads[1U] = in TEST_F()
89 threads[j].join(); in TEST_F()
99 threads[0U] = std::thread(LockMutexesAndIncrement<Mutex, RecursiveMutex>, std::ref(var), std::ref(lock0), in TEST_F()
101 threads[1U] = std::thread(LockMutexesAndIncrement<RecursiveMutex, Mutex>, std::ref(var), in TEST_F()
105 threads[ in TEST_F()
116 std::array<std::thread, TEST_THREADS> threads; TEST_F() local
148 std::array<std::thread, TEST_THREADS> threads; TEST_F() local
171 std::array<std::thread, TEST_THREADS> threads; TEST_F() local
203 std::array<std::thread, TEST_THREADS> threads; TEST_F() local
221 std::array<std::thread, TEST_THREADS> threads; TEST_F() local
[all...]
H A Dalloc_tracker_test.cpp133 std::vector<std::thread> threads; in TEST() local
135 threads.emplace_back( in TEST()
146 for (auto &thread : threads) { in TEST()
/arkcompiler/runtime_core/static_core/libpandafile/tests/
H A Dpanda_cache_test.cpp282 std::thread threads[NUMBER_OF_READERS]; in TEST() local
286 threads[i] = std::thread(MethodReaderThread, &cache); in TEST()
290 threads[i].join(); in TEST()
301 std::thread threads[NUMBER_OF_READERS]; in TEST() local
305 threads[i] = std::thread(FieldReaderThread, &cache); in TEST()
309 threads[i].join(); in TEST()
320 std::thread threads[NUMBER_OF_READERS]; in TEST() local
324 threads[i] = std::thread(ClassReaderThread, &cache); in TEST()
328 threads[i].join(); in TEST()
/arkcompiler/runtime_core/static_core/runtime/tests/
H A Dmultithreaded_intern_string_table_test.cpp198 std::array<std::thread, TEST_THREADS> threads; in TEST_F() local
213 threads[i] = std::thread(TestConcurrentInsertion, std::ref(strings), std::ref(arrayItem), this); in TEST_F()
217 threads[i].join(); in TEST_F()
223 std::array<std::thread, TEST_THREADS> threads; in TEST_F() local
225 threads[i] = std::thread(TestThreadEntry, this); in TEST_F()
228 threads[i].join(); in TEST_F()
H A Dmem_stats_test.cpp360 // order where threads observe all modifications in the same order in FillMemStatsForConcurrency()
363 // order where threads observe all modifications in the same order in FillMemStatsForConcurrency()
365 // Unlock all threads in FillMemStatsForConcurrency()
369 // consistent order where threads observe all modifications in the same order in FillMemStatsForConcurrency()
405 std::array<std::thread, NUM_THREADS> threads; in TEST_F() local
411 threads[i] = std::thread(FillMemStatsForConcurrency, std::ref(stats), std::ref(readyToStart), std::ref(cvMutex), in TEST_F()
416 threads[i].join(); in TEST_F()
/arkcompiler/runtime_core/static_core/verification/verifier/
H A Dverifier.cpp294 std::vector<std::thread *> threads; in RunVerifier() local
297 threads.push_back(worker); in RunVerifier()
300 for (auto *thr : threads) { in RunVerifier()
328 uint32_t threads = cliOptions.GetThreads(); in RunThreads() local
329 if (threads == 0) { in RunThreads()
330 threads = std::thread::hardware_concurrency(); in RunThreads()
332 if (threads == 0) { in RunThreads()
333 threads = 1; in RunThreads()
334 } else if (threads > MAX_THREADS) { in RunThreads()
335 threads in RunThreads()
[all...]
/arkcompiler/runtime_core/static_core/runtime/mem/gc/gc-hung/
H A Dgc_hung.h80 static void Check(const PandaList<MTManagedThread *> &threads, uint64_t startTime);
107 void CheckSuspend(const PandaList<MTManagedThread *> &threads, uint64_t startTime);
H A Dgc_hung.cpp174 // check threads suspend while get "Locks::mutator_lock->WriteLock()", and report to hung
175 void GcHung::CheckSuspend(const PandaList<MTManagedThread *> &threads, uint64_t startTime) in CheckSuspend() argument
179 for (const auto &thread : threads) { in CheckSuspend()
285 void GcHung::Check(const PandaList<MTManagedThread *> &threads, uint64_t startTime) in Check() argument
288 instance_->CheckSuspend(threads, startTime); in Check()
/arkcompiler/runtime_core/libpandabase/tests/
H A Dalloc_tracker_test.cpp130 std::vector<std::thread> threads; in TEST() local
132 threads.emplace_back( in TEST()
142 for (auto &thread : threads) { in TEST()
/arkcompiler/runtime_core/static_core/runtime/
H A Dlock_order_graph.cpp35 bool LockOrderGraph::CheckForTerminationLoops(const PandaList<MTManagedThread *> &threads, in CheckForTerminationLoops() argument
43 for (auto thread : threads) { in CheckForTerminationLoops()
137 // the node belongs to a loop (i.e., there is a deadlock with corresponding threads), or in CheckForTerminationLoops()
H A Dlock_order_graph.h35 static bool CheckForTerminationLoops(const PandaList<MTManagedThread *> &threads,
/arkcompiler/runtime_core/static_core/tests/tests-u-runner/tools/generate-es-checked/
H A Dmain.rb56 opts.on '--proc=PROC', Integer, 'number of ruby threads to use, defaults to max available' do |v|
99 @threads = []
103 @threads.filter! { |t| t.alive? }
108 while @threads.size >= @threads_num
117 @threads << t
121 while @threads.size != 0
/arkcompiler/ets_runtime/ecmascript/tests/
H A Djs_thread_state_test.cpp84 threads.push_back(worker_thread); in CreateNewVMInSeparateThread()
132 for (auto i: threads) { in DestroyAllVMs()
139 std::list<std::thread *> threads; member in panda::test::StateTransitioningTest
/arkcompiler/runtime_core/static_core/runtime/tests/tooling/
H A Dtest_util.h175 PandaVector<PtThread> threads; in GetUserThreadList() local
176 debugInterface->GetThreadList(&threads); in GetUserThreadList()
178 for (auto &thread : threads) { in GetUserThreadList()
/arkcompiler/ets_frontend/test262/
H A Drun_test262.py104 parser.add_argument('--threads', default=DEFAULT_THREADS, type=int,
686 def get_timeout(args, threads):
687 timeout = DEFAULT_TIMEOUT * threads
694 threads = DEFAULT_THREADS
695 if args.threads:
696 threads = args.threads
697 return threads
835 threads = get_threads(args)
836 timeout = get_timeout(args, threads)
[all...]
/arkcompiler/ets_runtime/ecmascript/compiler/
H A Dfile_generators.cpp381 // For others, run them in child threads and wait for finish. in CollectCodeInfo()
382 std::vector<std::thread> threads; in CollectCodeInfo() local
384 threads.emplace_back([&, i]() { in CollectCodeInfo()
389 for (auto& t : threads) { in CollectCodeInfo()
533 // For others, run them in child threads and wait for finish. in RunLLVMAssembler()
534 std::vector<std::thread> threads; in RunLLVMAssembler() local
537 threads.emplace_back([&, i] { in RunLLVMAssembler()
542 for (auto& t : threads) { in RunLLVMAssembler()
/arkcompiler/ets_runtime/ecmascript/dfx/hprof/
H A Dheap_profiler.cpp614 std::vector<std::thread> threads; in BinaryDump() local
617 threads.emplace_back(threadMain); in BinaryDump()
620 threads[i].join(); in BinaryDump()
/arkcompiler/ets_runtime/ecmascript/serializer/tests/
H A Dserializer_test.cpp2436 std::thread threads[maxNumDeserializers]; in HWTEST_F_L0() local
2438 threads[i] = std::thread(&JSDeserializerTest::JSSharedSetMultiThreadTest1, in HWTEST_F_L0()
2443 threads[i].join(); in HWTEST_F_L0()

Completed in 16 milliseconds