| /art/runtime/ |
| D | barrier_test.cc | 59 static int32_t num_threads; member in art::BarrierTest
62 int32_t BarrierTest::num_threads = 4; member in art::BarrierTest
68 ThreadPool::Create("Barrier test thread pool", num_threads)); in TEST_F()
69 Barrier barrier(num_threads + 1); // One extra Wait() in main thread. in TEST_F()
73 for (int32_t i = 0; i < num_threads; ++i) { in TEST_F()
77 while (count1.load(std::memory_order_relaxed) != num_threads) { in TEST_F()
87 EXPECT_EQ(count1.load(std::memory_order_relaxed), num_threads); in TEST_F()
88 EXPECT_EQ(count2.load(std::memory_order_relaxed), num_threads); in TEST_F()
120 ThreadPool::Create("Barrier test thread pool", num_threads)); in TEST_F()
123 const int32_t num_tasks = num_threads * 4; in TEST_F()
|
| D | thread_pool_test.cc | 56 static int32_t num_threads; member in art::ThreadPoolTest
59 int32_t ThreadPoolTest::num_threads = 4; member in art::ThreadPoolTest
65 ThreadPool::Create("Thread pool test thread pool", num_threads)); in TEST_F()
67 static const int32_t num_tasks = num_threads * 4; in TEST_F()
81 ThreadPool::Create("Thread pool test thread pool", num_threads)); in TEST_F()
83 static const int32_t num_tasks = num_threads * 4; in TEST_F()
107 ThreadPool::Create("Thread pool test thread pool", num_threads)); in TEST_F()
110 static const int32_t num_tasks = num_threads * 100; in TEST_F()
158 ThreadPool::Create("Thread pool test thread pool", num_threads)); in TEST_F()
|
| D | thread_pool.h | 187 size_t num_threads,
222 size_t num_threads,
225 ThreadPool* pool = new ThreadPool(name, num_threads, create_peers, worker_stack_size);
243 size_t num_threads, in ThreadPool() argument
246 : AbstractThreadPool(name, num_threads, create_peers, worker_stack_size) {} in ThreadPool()
|
| D | thread_pool.cc | 194 size_t num_threads, in AbstractThreadPool() argument
207 max_active_workers_(num_threads), in AbstractThreadPool()
|
| /art/test/1986-structural-redefine-multi-thread-stack-scope/src/ |
| D | Main.java | 85 final int num_threads = 10; in main() local
86 Object[] results = new Object[num_threads]; in main()
87 Thread[] threads = new Thread[num_threads]; in main()
88 CountDownLatch start_latch = new CountDownLatch(num_threads); in main()
90 for (int i = 0; i < num_threads; i++) { in main()
|
| /art/test/1995-final-virtual-structural-multithread/src/art/ |
| D | Test1995.java | 149 public static MyThread[] startThreads(int num_threads) throws Exception { in startThreads() argument
150 CountDownLatch cdl = new CountDownLatch(num_threads); in startThreads()
151 MyThread[] res = new MyThread[num_threads]; in startThreads()
152 for (int i = 0; i < num_threads; i++) { in startThreads()
|
| /art/test/2001-virtual-structural-multithread/src-art/art/ |
| D | Test2001.java | 208 public static MyThread[] startThreads(int num_threads) throws Exception { in startThreads() argument
209 CountDownLatch cdl = new CountDownLatch(num_threads); in startThreads()
210 MyThread[] res = new MyThread[num_threads]; in startThreads()
211 for (int i = 0; i < num_threads; i++) { in startThreads()
|
| /art/test/2005-pause-all-redefine-multithreaded/src/art/ |
| D | Test2005.java | 147 public static MyThread[] startThreads(int num_threads) throws Exception { in startThreads() argument
148 CountDownLatch cdl = new CountDownLatch(num_threads); in startThreads()
149 MyThread[] res = new MyThread[num_threads]; in startThreads()
150 for (int i = 0; i < num_threads; i++) { in startThreads()
|
| /art/runtime/jit/ |
| D | jit.h | 117 size_t num_threads,
119 JitThreadPool* pool = new JitThreadPool(name, num_threads, worker_stack_size);
153 size_t num_threads, in JitThreadPool() argument
156 : AbstractThreadPool(name, num_threads, /* create_peers= */ true, worker_stack_size) {} in JitThreadPool()
|
| /art/runtime/gc/ |
| D | heap.cc | 1135 void Heap::CreateThreadPool(size_t num_threads) { in CreateThreadPool() argument
1136 if (num_threads == 0) { in CreateThreadPool()
1137 num_threads = std::max(parallel_gc_threads_, conc_gc_threads_); in CreateThreadPool()
1139 if (num_threads != 0) { in CreateThreadPool()
1140 thread_pool_.reset(ThreadPool::Create("Heap thread pool", num_threads)); in CreateThreadPool()
|
| D | heap.h | 788 void CreateThreadPool(size_t num_threads = 0);
|
| /art/runtime/gc/collector/ |
| D | mark_compact.cc | 1158 size_t num_threads = pool->GetThreadCount(); in PrepareForCompaction() local
1159 thread_pool_counter_ = num_threads; in PrepareForCompaction()
1160 for (size_t i = 0; i < num_threads; i++) { in PrepareForCompaction()
1163 CHECK_EQ(pool->GetTaskCount(thread_running_gc_), num_threads); in PrepareForCompaction()
|