| /frameworks/base/apct-tests/perftests/core/src/android/text/ |
| D | StaticLayoutMultithreadPerfTest.java | 57 Thread[] threads = new Thread[numOfThreads]; in startBackgroundThread() local
60 threads[i] = new Thread(new Runnable() { in startBackgroundThread()
78 threads[i].start(); in startBackgroundThread()
86 return threads; in startBackgroundThread()
89 private void finishThreads(Thread[] threads) { in finishThreads() argument
91 for (Thread thread : threads) { in finishThreads()
105 Thread[] threads = startBackgroundThread(numOfTotalThreads - 1); in runRandomTest() local
116 finishThreads(threads); in runRandomTest()
|
| /frameworks/native/services/powermanager/tests/ |
| D | PowerHalControllerTest.cpp | 224 std::vector<std::thread> threads; in TEST_F() local
226 threads.push_back(std::thread([&]() { in TEST_F()
231 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
252 std::vector<std::thread> threads; in TEST_F() local
254 threads.push_back(std::thread([&]() { in TEST_F()
258 threads.push_back(std::thread([&]() { in TEST_F()
262 threads.push_back(std::thread([&]() { in TEST_F()
266 threads.push_back(std::thread([&]() { in TEST_F()
271 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| D | PowerHalWrapperAidlTest.cpp | 164 std::vector<std::thread> threads; in TEST_F() local
166 threads.push_back(std::thread([&]() { in TEST_F()
171 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
242 std::vector<std::thread> threads; in TEST_F() local
244 threads.push_back(std::thread([&]() { in TEST_F()
249 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| /frameworks/base/startop/apps/test/src/ |
| D | CPUIntensiveBenchmarks.java | 51 WorkerThread[] threads = new WorkerThread[threadCount]; in doSomeWork() local
54 threads[i] = new WorkerThread(i); in doSomeWork()
58 threads[i].start(); in doSomeWork()
63 threads[i].join(); in doSomeWork()
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/locksettings/ |
| D | LockSettingsStorageTests.java | 154 List<Thread> threads = new ArrayList<>(); in testKeyValue_ReadWriteConcurrency() local
157 threads.add(new Thread("testKeyValue_ReadWriteConcurrency_" + i) { in testKeyValue_ReadWriteConcurrency()
177 threads.get(i).start(); in testKeyValue_ReadWriteConcurrency()
181 joinAll(threads, 10000); in testKeyValue_ReadWriteConcurrency()
194 final List<Thread> threads = new ArrayList<>(); in testKeyValue_ReadRemoveConcurrency() local
198 threads.add(new Thread("testKeyValue_ReadRemoveConcurrency_" + threadId) { in testKeyValue_ReadRemoveConcurrency()
227 threads.get(threadId).start(); in testKeyValue_ReadRemoveConcurrency()
229 joinAll(threads, 60000); in testKeyValue_ReadRemoveConcurrency()
236 List<Thread> threads = new ArrayList<>(); in testKeyValue_CacheStarvedWriter() local
239 threads.add(new Thread() { in testKeyValue_CacheStarvedWriter()
[all …]
|
| /frameworks/minikin/tests/stresstest/ |
| D | MultithreadTest.cpp | 92 std::vector<std::thread> threads; in TEST() local
96 threads.reserve(NUM_THREADS); in TEST()
98 threads.emplace_back(&thread_main, i); in TEST()
104 for (auto& thread : threads) { in TEST()
|
| /frameworks/libs/binary_translation/tests/ndk_program_tests/ |
| D | atomics_test.cc | 53 std::thread threads[16]; in TEST() local
58 threads[i] = std::thread(LockContentionWorkLoad, data, 10); in TEST()
61 threads[i].join(); in TEST()
|
| /frameworks/base/apct-tests/perftests/core/src/android/os/ |
| D | ParcelObtainPerfTest.java | 49 final ObtainThread[] threads = new ObtainThread[numThreads]; in timeContention() local
53 threads[i] = thread; in timeContention()
56 threads[i].join(); in timeContention()
|
| /frameworks/libs/binary_translation/base/ |
| D | mmap_pool_test.cc | 91 std::thread threads[kNumThreads]; in TEST_F() local
94 threads[i] = std::thread([]() { in TEST_F()
105 for (auto& thread : threads) { in TEST_F()
|
| D | forever_alloc_test.cc | 88 pthread_t threads[kNumThreads]; in TEST() local
91 int res = pthread_create(&threads[i], nullptr, StressFunc, reinterpret_cast<void*>(i)); in TEST()
96 int res = pthread_join(threads[i], nullptr); in TEST()
|
| D | lock_free_stack_test.cc | 131 pthread_t threads[kNumThreads]; in TEST() local
134 int res = pthread_create(&threads[i], nullptr, StressFunc, reinterpret_cast<void*>(i)); in TEST()
139 int res = pthread_join(threads[i], nullptr); in TEST()
|
| /frameworks/base/libs/hwui/tests/unit/ |
| D | CommonPoolTests.cpp | 42 std::set<pid_t> threads; in TEST() local
51 threads.insert(f.get()); in TEST()
53 EXPECT_EQ(threads.size(), CommonPool::THREAD_COUNT); in TEST()
54 EXPECT_EQ(0, threads.count(gettid())); in TEST()
|
| /frameworks/native/services/surfaceflinger/tests/ |
| D | Stress_test.cpp | 45 std::vector<std::thread> threads; in TEST() local
47 threads.push_back(std::thread(do_stress)); in TEST()
49 for (auto& thread : threads) { in TEST()
|
| /frameworks/libs/binary_translation/runtime_primitives/ |
| D | table_of_tables_test.cc | 50 std::thread threads[64]; in TEST() local
54 threads[i] = std::thread( in TEST()
71 for (auto& thread : threads) { in TEST()
|
| D | signal_queue_test.cc | 154 std::array<std::thread, kStressThreads> threads; in TEST() local
157 threads[i] = std::thread(StressEnqueueFunc, &q); in TEST()
175 threads[i].join(); in TEST()
|
| /frameworks/base/media/jni/soundpool/ |
| D | SoundDecoder.cpp | 32 SoundDecoder::SoundDecoder(SoundManager* soundManager, size_t threads, int32_t threadPriority) in SoundDecoder() argument
35 ALOGV("%s(%p, %zu)", __func__, soundManager, threads); in SoundDecoder()
38 std::min(threads, (size_t)std::thread::hardware_concurrency()), in SoundDecoder()
|
| D | StreamManager.h | 124 std::list<std::unique_ptr<JavaThread>> threads; in quit() local
129 threads = std::move(mThreads); in quit()
133 for (auto &thread : threads) { in quit()
394 StreamManager(int32_t streams, size_t threads, const audio_attributes_t& attributes,
|
| /frameworks/native/libs/binder/include_rpc_unstable/ |
| D | binder_rpc_unstable.hpp | 85 void ARpcServer_setMaxThreads(ARpcServer* server, size_t threads);
142 void ARpcSession_setMaxIncomingThreads(ARpcSession* session, size_t threads);
|
| /frameworks/wilhelm/tests/sandbox/ |
| D | multithread.c | 37 pthread_t threads[MAX_THREAD]; variable
155 ok = pthread_create(&threads[i], (const pthread_attr_t *) NULL, thread_start, in main()
185 ok = pthread_join(threads[i], NULL); in main()
|
| /frameworks/native/libs/binder/tests/ |
| D | binderHostDeviceTest.cpp | 169 std::vector<std::thread> threads; in TEST_F() local
170 for (size_t i = 0; i < 10; ++i) threads.emplace_back(threadFn); in TEST_F()
171 for (auto& thread : threads) thread.join(); in TEST_F()
|
| /frameworks/native/services/vibratorservice/test/ |
| D | VibratorManagerHalWrapperAidlTest.cpp | 172 std::vector<std::thread> threads; in TEST_F() local
174 threads.push_back(std::thread([&]() { in TEST_F()
180 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
208 std::vector<std::thread> threads; in TEST_F() local
210 threads.push_back(std::thread([&]() { in TEST_F()
216 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| /frameworks/base/tests/CoreTests/android/core/ |
| D | TestWebServer.java | 42 Vector threads = new Vector(); field in TestWebServer
264 synchronized (threads) { in run()
265 if (threads.isEmpty()) { in run()
271 w = (Worker) threads.elementAt(0); in run()
272 threads.removeElementAt(0); in run()
407 Vector pool = threads; in run()
|
| /frameworks/native/libs/vr/libpdx_uds/ |
| D | client_channel_tests.cpp | 151 std::vector<std::thread> threads; in TEST_F() local
155 threads.emplace_back(worker, client_, data); in TEST_F()
159 for (auto& thread : threads) in TEST_F()
|
| /frameworks/av/media/libnbaio/ |
| D | README.txt | 13 no mutexes, so safe to use between SCHED_NORMAL and SCHED_FIFO threads
29 no mutexes, so safe to use between SCHED_NORMAL and SCHED_FIFO threads
|
| /frameworks/native/libs/binder/ |
| D | libbinder_rpc_unstable.cpp | 170 void ARpcServer_setMaxThreads(ARpcServer* handle, size_t threads) { in ARpcServer_setMaxThreads() argument
171 handleToStrongPointer<RpcServer>(handle)->setMaxThreads(threads); in ARpcServer_setMaxThreads()
269 void ARpcSession_setMaxIncomingThreads(ARpcSession* handle, size_t threads) { in ARpcSession_setMaxIncomingThreads() argument
271 session->setMaxIncomingThreads(threads); in ARpcSession_setMaxIncomingThreads()
|