/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/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 | 291 std::vector<std::thread> threads; in executeMultithreadedOwnCompilation() local 293 threads.push_back(std::thread([&]() { executeOnce(model, testModel); })); in executeMultithreadedOwnCompilation() 295 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedOwnCompilation() 305 std::vector<std::thread> threads; in executeMultithreadedSharedCompilation() local 307 threads.push_back( in executeMultithreadedSharedCompilation() 310 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/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/base/services/tests/servicestests/src/com/android/server/locksettings/ |
D | LockSettingsStorageTests.java | 142 List<Thread> threads = new ArrayList<>(); in testKeyValue_Concurrency() local 145 threads.add(new Thread("testKeyValue_Concurrency_" + i) { in testKeyValue_Concurrency() 167 threads.get(i).start(); in testKeyValue_Concurrency() 173 joinAll(threads, 10000); in testKeyValue_Concurrency() 182 List<Thread> threads = new ArrayList<>(); in testKeyValue_CacheStarvedWriter() local 185 threads.add(new Thread() { in testKeyValue_CacheStarvedWriter() 200 threads.get(i).start(); in testKeyValue_CacheStarvedWriter() 203 for (int i = 0; i < threads.size(); i++) { in testKeyValue_CacheStarvedWriter() 205 threads.get(i).join(); in testKeyValue_CacheStarvedWriter() 559 private static void joinAll(List<Thread> threads, long timeoutMillis) { in joinAll() argument [all …]
|
/frameworks/native/services/surfaceflinger/tests/ |
D | Stress_test.cpp | 41 std::vector<std::thread> threads; in TEST() local 43 threads.push_back(std::thread(do_stress)); in TEST() 45 for (auto& thread : threads) { in TEST()
|
/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/tests/WindowManagerStressTest/src/test/windowmanagerstresstest/ |
D | MainActivity.java | 101 ArrayList<Thread> threads = new ArrayList<>(); in slamWm() local 115 threads.add(t); in slamWm() 119 for (Thread t : threads) { in slamWm()
|
/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/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()
|
D | rsCpuIntrinsicBlur.cpp | 465 uint32_t threads = mCtx->getThreadCount(); in ~RsdCpuScriptIntrinsicBlur() local 467 for (size_t i = 0; i < threads; i++) { in ~RsdCpuScriptIntrinsicBlur()
|
/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.
|
/frameworks/native/cmds/surfacereplayer/replayer/ |
D | README.md | 53 - -t [Number of Threads] uses specified number of threads to queue up actions (default is 3) 99 - numThreads - Number of worker threads the replayer will use. 133 - The synchronization mechanism to signal threads within the Replayer (Event.cpp) 226 and worker threads. Every time an increment is dispatched, an Event object is also created. 250 **BufferUpdates** that act on the same surface, both threads will try to lock a buffer and fill it,
|
/frameworks/rs/script_api/include/ |
D | rs_atomic.rsh | 22 * To update values shared between multiple threads, use the functions below. 30 * threads even though you did not explicitely create them. The RenderScript 32 * threads. Updating globals should be done with atomic functions. If possible,
|
/frameworks/av/services/audioflinger/ |
D | AudioFlinger.h | 599 audio_session_t sessionId, const T& threads) { in findIoHandleBySessionId_l() argument 602 for (size_t i = 0; i < threads.size(); i++) { in findIoHandleBySessionId_l() 603 const uint32_t sessionType = threads.valueAt(i)->hasAudioSession(sessionId); in findIoHandleBySessionId_l() 605 io = threads.keyAt(i); in findIoHandleBySessionId_l()
|
/frameworks/native/libs/vr/libbufferhubqueue/benchmarks/ |
D | buffer_transport_benchmark.cpp | 444 surfaces_.resize(state.threads); in SetUp() 445 for (int i = 0; i < state.threads; i++) { in SetUp()
|
/frameworks/native/libs/gui/tests/ |
D | CpuConsumer_test.cpp | 727 std::vector<std::thread> threads; in TEST_P() local 729 threads.push_back(std::thread(lockAndUnlock)); in TEST_P() 733 for (auto& thread : threads) { in TEST_P()
|
/frameworks/compile/mclinker/include/mcld/Config/ |
D | Config.h.in | 31 /* Define if you have POSIX threads libraries and header files. */
|