| /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/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…
69 The module is responsible for translation between runtime threads and Inspector session IDs.
77 In the multi-thread version, the two main kinds of threads are considered:
79 - Application threads, these are the execution threads of the debuggable application.
81 …he server thread, while the debugger events are processed by application threads. This fact is use…
91 - 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()
165 os << "ARK THREADS (" << threadsCount_ << "):\n"; in EnumerateThreadsForDump()
273 * Tries to stop all daemon threads in case there are no active basic threads
279 * Deregister all suspended threads including daemon threads.
292 …// * CREATED - wait until threads finish initializing which requires communication with ThreadMana… in CanDeregister()
294 // * TERMINATING - threads which requires communication with Runtime; in CanDeregister()
295 // * 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/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/libpandabase/taskmanager/utils/ |
| D | sp_sc_lock_free_queue.h | 53 // Atomic with release order reason: other threads should see correct value in SPSCLockFreeQueue()
55 // Atomic with release order reason: other threads should see correct value in SPSCLockFreeQueue()
69 // Atomic with release order reason: other threads should see correct value in Push()
72 // Atomic with release order reason: other threads should see correct value in Push()
78 // Atomic with release order reason: other threads should see correct value in Push()
99 // Atomic with release order reason: other threads should see correct value in Pop()
107 // Atomic with release order reason: other threads should see correct value in Pop()
|
| D | sp_mc_lock_free_queue.h | 70 // Atomic with acq_rel order reason: other threads should see correct value in PopUserScope()
75 // Atomic with acq_rel order reason: other threads should see correct value in ~PopUserScope()
123 * threads will use Pop method until method execution ends
189 // Atomic with acq_rel order reason: other threads should be correct value in TryMovePopIndex()
204 // Atomic with acq_rel order reason: other threads should be correct value in CompareAndSetNextHead()
233 // Atomic with release order reason: other threads should see correct value in SPMCLockFreeQueue()
235 // Atomic with release order reason: other threads should see correct value in SPMCLockFreeQueue()
254 // Atomic with acq_rel order reason: other threads should be correct value in RegisterConsumer()
297 // Atomic with release order reason: other threads should see correct value in Push()
299 // Atomic with release order reason: other threads should see correct value in Push()
[all …]
|
| /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/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/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()
|
| D | gc.h | 294 … // Atomic with acquire order reason: data race with another threads which can update the variable in GetLastGCCause()
301 // order where threads observe all modifications in the same order in IsGCRunning()
649 /// Set GC Threads on best and middle cores before GC
652 /// Set GC Threads on best and middle cores after concurrent phase
655 /// Set GC Threads on saved or weak cores before concurrent phase
658 /// Restore GC Threads after GC on saved cores
674 /// Reset GC Threads on saved or weak cores
678 …Check whether run GC after waiting for mutator threads. Tasks for GC can pass from several mutator…
680 … GC wait for idle state for running, so need to check whether run such GC after waiting for threads
683 * @param counter_before_waiting value of gc counter before waiting for mutator threads
[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/static_core/docs/diagrams/ |
| D | mm-components.plantuml | 21 [Daemon threads]
24 [ReferenceProcessor] ..> [Daemon threads]
|
| /arkcompiler/runtime_core/docs/diagrams/ |
| D | mm-components.pucomponent | 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/verification/verifier/ |
| D | verifier.cpp | 258 std::vector<std::thread *> threads; in RunVerifier() local
261 threads.push_back(worker); in RunVerifier()
264 for (auto *thr : threads) { in RunVerifier()
292 uint32_t threads = cliOptions.GetThreads(); in RunThreads() local
293 if (threads == 0) { in RunThreads()
294 threads = std::thread::hardware_concurrency(); in RunThreads()
296 if (threads == 0) { in RunThreads()
297 threads = 1; in RunThreads()
298 } else if (threads > MAX_THREADS) { in RunThreads()
299 threads = MAX_THREADS; in RunThreads()
[all …]
|
| /arkcompiler/toolchain/tooling/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/coroutines/ |
| D | stackful_coroutine_manager.h | 29 …* In this implementation coroutines are user-level threads ("fibers") with manually allocated stac…
126 * @brief create the arbitrary number of worker threads
127 * @param how_many total number of worker threads, including MAIN
157 // worker threads-related members
|
| /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()
|
| /arkcompiler/runtime_core/static_core/libpandabase/mem/ringbuf/ |
| D | lock_free_ring_buffer.h | 38 // Atomic with release order reason: threads should see correct initialization in LockFreeBuffer()
40 // Atomic with release order reason: threads should see correct initialization in LockFreeBuffer()
94 // Atomic with release order reason: let others threads to see the latest value in TryPop()
|
| /arkcompiler/runtime_core/static_core/runtime/tests/intrusive-tests/ |
| D | README.md | 5 …ce to catch such bugs by controlling the order of synchronization events between different threads.
6 …cial comments in a source code introducing control points where different threads are synchronized.
96 …od, rarely finds the described data race, because one of two conflicting threads often finishes be…
|