/aosp14/frameworks/base/apct-tests/perftests/core/src/android/text/ |
H A 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()
|
/aosp14/system/core/debuggerd/libdebuggerd/ |
H A D | tombstone.cpp | 75 std::map<pid_t, ThreadInfo> threads; in engrave_tombstone_ucontext() local 76 threads[target_tid] = ThreadInfo { in engrave_tombstone_ucontext() 86 const ThreadInfo& thread = threads[pid]; in engrave_tombstone_ucontext() 87 if (!iterate_tids(pid, [&threads, &thread, &target_tid](pid_t tid) { in engrave_tombstone_ucontext() 91 threads[tid] = ThreadInfo{ in engrave_tombstone_ucontext() 120 engrave_tombstone(unique_fd(dup(tombstone_fd)), unique_fd(dup(proto_fd)), &unwinder, threads, in engrave_tombstone_ucontext() 126 const std::map<pid_t, ThreadInfo>& threads, pid_t target_thread, in engrave_tombstone() argument 131 engrave_tombstone_proto(&tombstone, unwinder, threads, target_thread, process_info, open_files); in engrave_tombstone()
|
H A D | tombstone_proto_to_text.cpp | 522 const auto& threads = tombstone.threads(); in tombstone_proto_to_text() local 523 auto main_thread_it = threads.find(tombstone.tid()); in tombstone_proto_to_text() 524 if (main_thread_it == threads.end()) { in tombstone_proto_to_text() 537 for (const auto& [tid, _] : threads) { in tombstone_proto_to_text() 545 print_thread(callback, tombstone, threads.find(tid)->second); in tombstone_proto_to_text()
|
H A D | tombstone_proto.cpp | 463 auto& threads = *tombstone->mutable_threads(); in dump_thread() local 464 threads[thread_info.tid] = thread; in dump_thread() 620 const std::map<pid_t, ThreadInfo>& threads, pid_t target_thread, in engrave_tombstone_proto() argument 629 const ThreadInfo& main_thread = threads.at(target_thread); in engrave_tombstone_proto() 684 for (const auto& [tid, thread_info] : threads) { in engrave_tombstone_proto() 697 const ThreadInfo& thread = threads.at(main_thread.pid); in engrave_tombstone_proto()
|
/aosp14/frameworks/base/startop/apps/test/src/ |
H A 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()
|
/aosp14/frameworks/base/services/tests/servicestests/src/com/android/server/locksettings/ |
H A D | LockSettingsStorageTests.java | 154 List<Thread> threads = new ArrayList<>(); in testKeyValue_ReadWriteConcurrency() local 177 threads.get(i).start(); in testKeyValue_ReadWriteConcurrency() 181 joinAll(threads, 10000); in testKeyValue_ReadWriteConcurrency() 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() 254 threads.get(i).start(); in testKeyValue_CacheStarvedWriter() 257 for (int i = 0; i < threads.size(); i++) { in testKeyValue_CacheStarvedWriter() 259 threads.get(i).join(); in testKeyValue_CacheStarvedWriter() [all …]
|
/aosp14/system/core/init/ |
H A D | ueventd_test.cpp | 55 std::vector<std::thread> threads; in WriteFromMultipleThreads() local 57 threads.emplace_back(std::thread(make_thread_function(file, parameter))); in WriteFromMultipleThreads() 60 for (auto& thread : threads) { in WriteFromMultipleThreads() 186 std::vector<std::thread> threads; in TEST() local 187 std::generate_n(back_inserter(threads), num_threads, in TEST() 192 for (auto& thread : threads) { in TEST()
|
/aosp14/frameworks/base/apct-tests/perftests/core/src/android/os/ |
H A 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()
|
/aosp14/system/core/libutils/ |
H A D | ProcessCallStack_fuzz.cpp | 36 std::vector<std::thread> threads = std::vector<std::thread>(); in spawnThreads() local 47 threads.push_back(std::move(th)); in spawnThreads() 68 for (auto& thread : threads) { in spawnThreads()
|
H A D | RefBase_fuzz.cpp | 171 std::vector<std::thread> threads = std::vector<std::thread>(); in spawnThreads() local 180 threads.push_back(std::move(tmpThread)); in spawnThreads() 183 for (auto& th : threads) { in spawnThreads()
|
/aosp14/frameworks/base/libs/hwui/tests/unit/ |
H A 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()
|
/aosp14/frameworks/base/media/jni/soundpool/ |
H A 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()
|
H A 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,
|
H A D | SoundDecoder.h | 31 SoundDecoder(SoundManager* soundManager, size_t threads);
|
H A D | StreamManager.cpp | 109 int32_t streams, size_t threads, const audio_attributes_t& attributes, in StreamManager() argument 119 ALOGV("%s(%d, %zu, ...)", __func__, streams, threads); 129 std::min(threads, (size_t)std::thread::hardware_concurrency())),
|
/aosp14/frameworks/base/tests/CoreTests/android/core/ |
H A 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()
|
/aosp14/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/ |
H A D | snapuserd_verify.cpp | 189 std::vector<std::future<bool>> threads; in VerifyPartition() local 194 threads.emplace_back(std::async(std::launch::async, &UpdateVerify::VerifyBlocks, this, in VerifyPartition() 205 for (auto& t : threads) { in VerifyPartition()
|
H A D | snapuserd_core.cpp | 309 std::vector<std::future<bool>> threads; in Start() local 321 threads.emplace_back( in Start() 334 for (auto& t : threads) { in Start()
|
/aosp14/system/core/debuggerd/client/ |
H A D | debuggerd_client_test.cpp | 60 std::vector<std::thread> threads; in TEST() local 62 threads.emplace_back([]() { in TEST()
|
/aosp14/frameworks/base/media/jni/soundpool/tests/ |
H A 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()
|
/aosp14/frameworks/base/core/tests/coretests/src/android/graphics/ |
H A D | TypefaceTest.java | 178 final Thread[] threads = new Thread[threadCount]; in testMultithreadCacheStressTest() local 180 threads[i] = new Thread(threadedCreater); in testMultithreadCacheStressTest() 184 threads[i].start(); in testMultithreadCacheStressTest() 189 threads[i].join(); in testMultithreadCacheStressTest()
|
/aosp14/frameworks/base/tests/JankBench/app/src/main/jni/ |
H A 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()
|
/aosp14/frameworks/base/libs/WindowManager/Shell/src/com/android/wm/shell/docs/ |
H A D | threading.md | 22 We currently have multiple threads in use in the Shell library depending on the configuration by 47 for example, the Executors and Handlers for the various threads that are used. You can request 48 an executor of the necessary type by using the appropriate annotation for each of the threads (ie.
|
/aosp14/system/core/debuggerd/libdebuggerd/include/libdebuggerd/ |
H A D | tombstone.h | 63 const std::map<pid_t, ThreadInfo>& threads, pid_t target_thread,
|
/aosp14/system/core/libsync/tests/ |
H A D | sync_test.cpp | 557 vector<thread> threads; in TEST_P() local 587 threads.push_back(thread{threadMain, i}); in TEST_P() 616 for_each(begin(threads), end(threads), [](thread& thread) { thread.join(); }); in TEST_P()
|