| /arkcompiler/runtime_core/static_core/libpandabase/tests/ |
| D | lock_holder_test.cpp | 60 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(… in TEST_F()
101 threads[1U] = std::thread(LockMutexesAndIncrement<RecursiveMutex, Mutex>, std::ref(var), in TEST_F()
105 threads[j].join(); in TEST_F()
[all …]
|
| /arkcompiler/runtime_core/arkplatform/hybrid/ |
| D | sts_vm_interface.h | 52 …* @brief Increment count of threads that will execute XGC. If you use this method in the scope of …
53 * new count of threads will be ignored by currect XGC, but will be used in next one.
57 …* @brief Decrement count of threads that will execute XGC. If you use this method in the scope of …
58 * new count of threads will be ignored by currect XGC, but will be used in next one.
62 …* @brief Method waits for all threads to start XGC. The count of threads can be changed using meth…
69 * @brief Method waits for all threads would call WaitForConcurrentMark.
71 …* @returns true if all threads called this methods. It can return false if VM should try continue …
75 /// @brief Method waits for all threads would call RemarkStartBarrier
78 * @brief Method waits for all threads would call WaitForRemark.
80 …* @returns true if all threads called this methods. It can return false if VM should try continue …
[all …]
|
| /arkcompiler/runtime_core/static_core/docs/ |
| D | task_manager.md | 3 …ware(cores)/OS(threads) resources we introduce TaskManager. The main goal of TaskManager is to use…
35 For managing worker threads we should provide machinery for:
38 3. Change priority of worker threads `ThreadManager`
39 4. Distribute worker threads from `ThreadPool` between static and dynamic VM instances to optimize …
46 1. Creation of thread pool with `N` worker threads
47 1. Getting available `WorkerThread` from the pool of available worker threads
48 1. Returning `WorkerThread` back to the pool of available worker threads
54 1. Distribute threads from pool between consumers in accordance with different policies
55 1. Provide machinery for changing priority of the threads managed by current Thread Manager
|
| D | inspector.md | 15 … encapsulates a `ThreadState` and processes logic of thread suspensions. Threads have the followin…
77 The module is responsible for translation between runtime threads and Inspector session IDs.
85 In the multi-thread version, the two main kinds of threads are considered:
87 - Application threads, these are the execution threads of the debuggable application.
89 …he server thread, while the debugger events are processed by application threads. This fact is use…
99 - and application threads could not process events due to the aforementioned write-lock.
|
| /arkcompiler/runtime_core/static_core/runtime/tooling/sampler/ |
| D | lock_free_queue.cpp | 25 // Atomic with acquire order reason: to sync with push in other threads in Push()
28 // Atomic with acquire order reason: to sync with push in other threads in Push()
30 // Atomic with acquire order reason: to sync with push in other threads in Push()
52 // Atomic with acquire order reason: to sync with push in other threads in Pop()
54 // Atomic with acquire order reason: to sync with push in other threads in Pop()
56 // Atomic with acquire order reason: to sync with push in other threads in Pop()
58 // Atomic with acquire order reason: to sync with push in other threads in Pop()
85 // Atomic with acquire order reason: to sync with push in other threads in FindValue()
87 // Atomic with acquire order reason: to sync with push in other threads in FindValue()
|
| /arkcompiler/runtime_core/static_core/runtime/ |
| D | thread_manager.h | 32 // This interval is required for waiting for threads to stop.
41 VM_THREAD = 4, // Includes VM threads
86 // Some uninitialized threads may not have attached flag, in SatisfyTheMask()
88 // Newly created threads are using flag suspend new count. in SatisfyTheMask()
166 os << "ARK THREADS (" << threadsCount_ << "):\n"; in EnumerateThreadsForDump()
272 * Tries to stop all daemon threads in case there are no active basic threads
278 * Deregister all suspended threads including daemon threads.
291 …// * CREATED - wait until threads finish initializing which requires communication with ThreadMana… in CanDeregister()
293 // * TERMINATING - threads which requires communication with Runtime; in CanDeregister()
294 // * FINISHED threads should be deleted itself; in CanDeregister()
[all …]
|
| D | mt_thread_manager.cpp | 88 // Only threads in IS_TERMINATED_LOOP status can be deregistered. in DeregisterSuspendedThreads()
107 // All threads except current are blocked (have BLOCKED or NATIVE status) in DeregisterSuspendedThreads()
108 LOG(DEBUG, RUNTIME) << "Potential termination loop with daemon threads is detected"; in DeregisterSuspendedThreads()
129 LOG(DEBUG, RUNTIME) << "Termination loop with daemon threads was not confirmed"; in StopThreadsOnTerminationLoops()
153 // First wait for non-daemon threads to finish in WaitForDeregistration()
158 // Then stop daemon threads in WaitForDeregistration()
161 // Finally wait until all threads are suspended in WaitForDeregistration()
164 // There are threads, which are not completely registered in WaitForDeregistration()
165 // We can not destroy other threads, as they may use shared data (waiting mutexes) in WaitForDeregistration()
196 // Suspend any future new threads in StopDaemonThreads()
[all …]
|
| D | thread_pool.h | 54 // Atomic with release order reason: threads should see correct initialization in SetTid()
124 LOG(DEBUG, RUNTIME) << "Scale thread pool for " << newNThreads << " new threads"; in Scale()
126 … LOG(ERROR, RUNTIME) << "Incorrect number of threads " << newNThreads << " for thread pool"; in Scale()
130 // Need to add new threads. in Scale()
139 // Need to remove threads. in Scale()
151 // Same number of threads - do nothing. in Scale()
|
| /arkcompiler/runtime_core/static_core/plugins/ets/doc/concurrency/ |
| D | 04_concurrency_runtime.rst | 18 Worker threads and coroutines
21 …`coroutines` in |LANG| we use pool of worker threads for running them. So we have M:N concurrency …
31 …nsible for fair scheduling of coroutines on the general Coroutine Worker threads. Also it guarante…
|
| /arkcompiler/ets_frontend/test262/ |
| D | mix_compile.py | 59 '--file-threads', str(self.file_threads),
60 '--function-threads', str(self.function_threads),
73 '--file-threads', str(self.file_threads),
74 '--abc-class-threads', str(self.abc_class_threads),
75 '--function-threads', str(self.function_threads),
|
| /arkcompiler/runtime_core/static_core/tools/sampler/ |
| D | README.md | 27 …Signals can be ignored if threads are suspended to wait for cpu time(major part of ignored signals…
33 | --csv-tid-separation | single-csv-single-tid | Doesn't distinguish threads…
34 | | single-csv-multi-tid (by default) | Distinguish threads by thre…
35 | | multi-csv | Distinguish threads by crea…
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/ |
| D | generational-gc-base.h | 95 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountFreedYoung()
109 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeFreedYoung()
123 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountMovedYoung()
137 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeMovedYoung()
161 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountMovedTenured()
175 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeMovedTenured()
189 // Atomic with relaxed order reason: memory accesses from different threads in RecordCountFreedTenured()
203 // Atomic with relaxed order reason: memory accesses from different threads in RecordSizeFreedTenured()
|
| /arkcompiler/runtime_core/static_core/libpandafile/tests/ |
| D | panda_cache_test.cpp | 282 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/libpandabase/taskmanager/utils/ |
| D | sp_mc_lock_free_queue.h | 74 // Atomic with acq_rel order reason: other threads should see correct value in PopUserScope()
79 // Atomic with acq_rel order reason: other threads should see correct value in ~PopUserScope()
127 * threads will use Pop method until method execution ends
193 // Atomic with acq_rel order reason: other threads should be correct value in TryMovePopIndex()
208 // Atomic with acq_rel order reason: other threads should be correct value in CompareAndSetNextHead()
237 // Atomic with release order reason: other threads should see correct value in SPMCLockFreeQueue()
239 // Atomic with release order reason: other threads should see correct value in SPMCLockFreeQueue()
258 // Atomic with acq_rel order reason: other threads should be correct value in RegisterConsumer()
301 // Atomic with release order reason: other threads should see correct value in Push()
303 // Atomic with release order reason: other threads should see correct value in Push()
[all …]
|
| /arkcompiler/runtime_core/static_core/runtime/mem/ |
| D | rendezvous.h | 30 * Meeting point for all managed threads.
41 // Wait until all threads release Mutator lock and acquires it for write;
43 // Ends safepoint (wakes up waiting threads, releases Mutator lock);
|
| D | rendezvous.cpp | 29 // Suspend all threads in SafepointBegin()
41 // Resume all threads in SafepointEnd()
|
| /arkcompiler/runtime_core/docs/diagrams/ |
| D | mm-components.pucomponent | 21 [Daemon threads]
24 [ReferenceProcessor] ..> [Daemon threads]
|
| /arkcompiler/runtime_core/static_core/docs/diagrams/ |
| D | mm-components.plantuml | 21 [Daemon threads]
24 [ReferenceProcessor] ..> [Daemon threads]
|
| /arkcompiler/runtime_core/static_core/runtime/tests/ |
| D | multithreaded_intern_string_table_test.cpp | 198 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()
|
| /arkcompiler/runtime_core/static_core/plugins/ets/tests/ani/tests/vm_ops/ |
| D | detach_thread_test.cpp | 32 std::array<std::thread, NUM_THREADS> threads; in DoTest() local
34 threads[i] = std::thread(func); in DoTest()
37 for (auto &t : threads) { in DoTest()
|
| /arkcompiler/toolchain/tooling/dynamic/client/ark_multi/ |
| D | ReadMe.md | 5 Can start a specified number of threads, each thread starts the virtual machine and executes the te…
9 ark_multi [number of threads] [execution file, internal record of abc that needs to be run, one per…
|
| /arkcompiler/runtime_core/static_core/runtime/tooling/sampler/docs/ |
| D | sampler.md | 23 …threads denoted as `SamplerThread` and `ListenerThread`. The first one is responsible for setting …
|
| /arkcompiler/runtime_core/static_core/verification/verifier/ |
| D | verifier.cpp | 294 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 = MAX_THREADS; in RunThreads()
[all …]
|
| /arkcompiler/ets_runtime/common_components/common_runtime/tests/ |
| D | base_runtime_test.cpp | 74 std::vector<std::thread> threads; in HWTEST_F_L0() local
77 threads.emplace_back([&instances, i]() { in HWTEST_F_L0()
82 for (auto& t : threads) { in HWTEST_F_L0()
|
| /arkcompiler/runtime_core/libpandabase/mem/ringbuf/ |
| D | lock_free_ring_buffer.h | 39 // Atomic with release order reason: threads should see correct initialization in LockFreeBuffer()
41 // Atomic with release order reason: threads should see correct initialization in LockFreeBuffer()
95 // Atomic with release order reason: let others threads to see the latest value in TryPop()
|