| /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/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/ml/nn/runtime/test/ |
| D | TestOpenmpSettings.cpp | 67 std::vector<std::thread> threads; in TEST_F() local
72 threads.push_back(std::thread([sleepFor]() { in TEST_F()
89 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in TEST_F()
|
| D | TestGenerated.cpp | 282 std::vector<std::thread> threads; in executeMultithreadedOwnCompilation() local
284 threads.push_back(std::thread([&]() { executeOnce(model, testModel); })); in executeMultithreadedOwnCompilation()
286 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedOwnCompilation()
296 std::vector<std::thread> threads; in executeMultithreadedSharedCompilation() local
298 threads.push_back( in executeMultithreadedSharedCompilation()
301 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedSharedCompilation()
|
| /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/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 | 121 std::list<std::unique_ptr<JavaThread>> threads; in quit() local
126 threads = std::move(mThreads); in quit()
130 for (auto &thread : threads) { in quit()
389 StreamManager(int32_t streams, size_t threads, const audio_attributes_t* attributes);
|
| D | SoundDecoder.h | 31 SoundDecoder(SoundManager* soundManager, size_t threads);
|
| D | StreamManager.cpp | 101 int32_t streams, size_t threads, const audio_attributes_t* attributes) in StreamManager() argument
105 ALOGV("%s(%d, %zu, ...)", __func__, streams, threads); in StreamManager()
114 std::min(threads, (size_t)std::thread::hardware_concurrency()), in StreamManager()
|
| /frameworks/base/core/tests/coretests/src/android/graphics/ |
| D | TypefaceTest.java | 155 final Thread[] threads = new Thread[threadCount]; in testMultithreadCacheStressTest() local
157 threads[i] = new Thread(threadedCreater); in testMultithreadCacheStressTest()
161 threads[i].start(); in testMultithreadCacheStressTest()
166 threads[i].join(); in testMultithreadCacheStressTest()
|
| /frameworks/base/cmds/statsd/tests/utils/ |
| D | MultiConditionTrigger_test.cpp | 52 vector<thread> threads; in TEST() local
57 threads.emplace_back([&done, &conditionName, &trigger, i] { in TEST()
75 threads[i].join(); in TEST()
|
| /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/native/services/surfaceflinger/tests/unittests/ |
| D | VSyncDispatchRealtimeTest.cpp | 166 std::array<std::thread, num_clients> threads{ in TEST_F() local
172 for (auto it = threads.rbegin(); it != threads.rend(); it++) { in TEST_F()
|
| /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/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()
|
| /frameworks/rs/script_api/ |
| D | rs_atomic.spec | 20 To update values shared between multiple threads, use the functions below.
28 threads even though you did not explicitely create them. The RenderScript
30 threads. Updating globals should be done with atomic functions. If possible,
|
| /frameworks/native/libs/vr/libpdx_default_transport/ |
| D | pdx_benchmarks.cpp | 173 int threads = 1; member
528 int thread_count = ProgramOptions.threads; in ServiceCommand()
586 ProgramOptions.instances * ProgramOptions.threads * ProgramOptions.count); in ClientCommand()
602 int thread_count = ProgramOptions.threads; in ClientCommand()
876 const int total_threads = ProgramOptions.threads * ProgramOptions.instances; in ClientCommand()
1047 ProgramOptions.threads = std::stoi(optarg); in main()
1048 if (ProgramOptions.threads < 1) { in main()
1049 std::cerr << "Invalid threads argument: " << ProgramOptions.threads in main()
|
| /frameworks/av/media/libaaudio/src/fifo/ |
| D | README.md | 1 Simple atomic FIFO for passing data between threads or processes.
|