| /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 | 135 std::vector<std::thread> threads; in TEST_F() local
137 threads.push_back(std::thread([&]() { in TEST_F()
142 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
199 std::vector<std::thread> threads; in TEST_F() local
201 threads.push_back(std::thread([&]() { in TEST_F()
206 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/minikin/tests/stresstest/ |
| D | MultithreadTest.cpp | 90 std::vector<std::thread> threads; in TEST() local
94 threads.reserve(NUM_THREADS); in TEST()
96 threads.emplace_back(&thread_main, i); in TEST()
102 for (auto& thread : threads) { 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/native/services/vibratorservice/test/ |
| D | VibratorCallbackSchedulerTest.cpp | 106 std::vector<std::thread> threads; in TEST_F() local
108 threads.push_back(std::thread( in TEST_F()
111 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| 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()
|
| D | VibratorManagerHalControllerTest.cpp | 206 std::vector<std::thread> threads; in TEST_F() local
208 threads.push_back(std::thread([&]() { ASSERT_TRUE(mController->ping().isOk()); })); in TEST_F()
210 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| D | VibratorHalControllerTest.cpp | 185 std::vector<std::thread> threads; in TEST_F() local
187 threads.push_back(std::thread([&]() { in TEST_F()
192 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/locksettings/ |
| D | LockSettingsStorageTests.java | 147 List<Thread> threads = new ArrayList<>(); in testKeyValue_Concurrency() local
150 threads.add(new Thread("testKeyValue_Concurrency_" + i) { in testKeyValue_Concurrency()
170 threads.get(i).start(); in testKeyValue_Concurrency()
174 joinAll(threads, 10000); in testKeyValue_Concurrency()
183 List<Thread> threads = new ArrayList<>(); in testKeyValue_CacheStarvedWriter() local
186 threads.add(new Thread() { in testKeyValue_CacheStarvedWriter()
201 threads.get(i).start(); in testKeyValue_CacheStarvedWriter()
204 for (int i = 0; i < threads.size(); i++) { in testKeyValue_CacheStarvedWriter()
206 threads.get(i).join(); in testKeyValue_CacheStarvedWriter()
523 private static void joinAll(List<Thread> threads, long timeoutMillis) { in joinAll() argument
[all …]
|
| /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/base/media/jni/soundpool/ |
| D | SoundDecoder.cpp | 32 SoundDecoder::SoundDecoder(SoundManager* soundManager, size_t threads) 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 | 122 std::list<std::unique_ptr<JavaThread>> threads; in quit() local
127 threads = std::move(mThreads); in quit()
131 for (auto &thread : threads) { in quit()
390 StreamManager(int32_t streams, size_t threads, const audio_attributes_t* attributes,
|
| D | SoundDecoder.h | 31 SoundDecoder(SoundManager* soundManager, 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/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/base/core/tests/coretests/src/android/graphics/ |
| D | TypefaceTest.java | 177 final Thread[] threads = new Thread[threadCount]; in testMultithreadCacheStressTest() local
179 threads[i] = new Thread(threadedCreater); in testMultithreadCacheStressTest()
183 threads[i].start(); in testMultithreadCacheStressTest()
188 threads[i].join(); in testMultithreadCacheStressTest()
|
| /frameworks/base/media/jni/soundpool/tests/ |
| D | soundpool_stress.cpp | 289 std::vector<std::future<void>> threads(threadCount); in main() local
290 printf("testing %zu threads\n", threads.size()); in main()
291 for (auto &thread : threads) { in main()
|
| /frameworks/native/services/surfaceflinger/tests/unittests/ |
| D | VSyncDispatchRealtimeTest.cpp | 177 std::array<std::thread, num_clients> threads{ in TEST_F() local
183 for (auto it = threads.rbegin(); it != threads.rend(); it++) { in TEST_F()
|
| /frameworks/rs/cpu_ref/ |
| D | rsCpuIntrinsicHistogram.cpp | 101 const uint32_t threads = mCtx->getThreadCount(); in preLaunch() local
139 memset(mSums, 0, 256 * sizeof(int32_t) * threads * vSize); in preLaunch()
150 uint32_t threads = mCtx->getThreadCount(); in postLaunch() local
157 for (uint32_t t=1; t < threads; t++) { in postLaunch()
|
| /frameworks/base/tests/JankBench/app/src/main/jni/ |
| D | Bench.cpp | 125 int threads = useMT ? 1 : 0; in runPowerManagementTest() local
128 threads = options & 0x1f; in runPowerManagementTest()
133 mWorkers.launchWork(testWork, this, threads); in runPowerManagementTest()
|