Home
last modified time | relevance | path

Searched refs:threads (Results 1 – 25 of 44) sorted by relevance

12

/frameworks/opt/gamesdk/third_party/protobuf-3.0.0/objectivec/Tests/
DGPBConcurrencyTests.m68 - (void)startThreads:(NSArray *)threads {
69 for (NSThread *thread in threads) {
74 - (void)joinThreads:(NSArray *)threads {
75 for (NSThread *thread in threads) {
91 NSArray *threads =
94 [self startThreads:threads];
95 [self joinThreads:threads];
111 NSArray *threads =
114 [self startThreads:threads];
115 [self joinThreads:threads];
[all …]
/frameworks/base/apct-tests/perftests/core/src/android/text/
DStaticLayoutMultithreadPerfTest.java57 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/opt/gamesdk/third_party/protobuf-3.0.0/src/google/protobuf/stubs/
Donce_unittest.cc211 scoped_ptr<TestThread> threads[4]; in TEST_F() local
214 threads[i].reset(RunInitOnceInNewThread()); in TEST_F()
217 threads[i]->Join(); in TEST_F()
228 scoped_ptr<TestThread> threads[8]; in TEST_F() local
233 threads[i].reset(RunInitOnceInNewThread()); in TEST_F()
236 threads[i].reset(RunInitRecursiveOnceInNewThread()); in TEST_F()
248 threads[i]->Join(); in TEST_F()
/frameworks/ml/nn/runtime/test/
DTestOpenmpSettings.cpp67 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) { in TEST_F()
DTestGenerated.cpp200 std::vector<std::thread> threads; in executeMultithreadedOwnCompilation() local
202 threads.push_back(std::thread([&]() { executeOnce(model, isIgnored, examples, ""); })); in executeMultithreadedOwnCompilation()
204 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedOwnCompilation()
213 std::vector<std::thread> threads; in executeMultithreadedSharedCompilation() local
215 threads.push_back(std::thread( in executeMultithreadedSharedCompilation()
218 std::for_each(threads.begin(), threads.end(), [](std::thread& t) { t.join(); }); in executeMultithreadedSharedCompilation()
/frameworks/minikin/tests/stresstest/
DMultithreadTest.cpp90 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/native/services/surfaceflinger/tests/
DStress_test.cpp41 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/libs/hwui/tests/unit/
DCommonPoolTests.cpp42 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/
DLockSettingsStorageTests.java126 List<Thread> threads = new ArrayList<>(); in testKeyValue_Concurrency() local
129 threads.add(new Thread("testKeyValue_Concurrency_" + i) { in testKeyValue_Concurrency()
151 threads.get(i).start(); in testKeyValue_Concurrency()
157 joinAll(threads, 10000); in testKeyValue_Concurrency()
165 List<Thread> threads = new ArrayList<>(); in testKeyValue_CacheStarvedWriter() local
168 threads.add(new Thread() { in testKeyValue_CacheStarvedWriter()
183 threads.get(i).start(); in testKeyValue_CacheStarvedWriter()
186 for (int i = 0; i < threads.size(); i++) { in testKeyValue_CacheStarvedWriter()
188 threads.get(i).join(); in testKeyValue_CacheStarvedWriter()
515 private static void joinAll(List<Thread> threads, long timeoutMillis) { in joinAll() argument
[all …]
/frameworks/base/core/tests/coretests/src/android/graphics/
DTypefaceTest.java155 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/opt/gamesdk/third_party/protobuf-3.0.0/m4/
Dacx_pthread.m413 dnl @summary figure out how to build C programs using POSIX threads
15 dnl This macro figures out how to build C programs using POSIX threads.
16 dnl It sets the PTHREAD_LIBS output variable to the threads library and
31 dnl If you are only building threads programs, you may wish to use
42 dnl ACTION-IF-FOUND is a list of shell commands to run if a threads
74 # etcetera environment variables, and if threads linking works using
92 # We must check for the threads library under a number of different
108 # none: in case threads are in libc; should be tried before -Kthread and
110 # -Kthread: Sequent (threads in libc, but -Kthread needed for pthread.h)
111 # -kthread: FreeBSD kernel threads (preferred to -pthread since SMP-able)
[all …]
/frameworks/base/tests/WindowManagerStressTest/src/test/windowmanagerstresstest/
DMainActivity.java101 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/
Dmultithread.c37 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/vr/libpdx_uds/
Dclient_channel_tests.cpp151 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/base/tests/CoreTests/android/core/
DTestWebServer.java42 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/av/media/libnbaio/
DREADME.txt13 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/
DrsCpuIntrinsicHistogram.cpp101 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/
DBench.cpp125 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/
Drs_atomic.spec20 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/av/media/libaaudio/src/fifo/
DREADME.md1 Simple atomic FIFO for passing data between threads or processes.
/frameworks/native/libs/vr/libpdx_default_transport/
Dpdx_benchmarks.cpp173 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/native/cmds/surfacereplayer/replayer/
DREADME.md53 - -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/
Drs_atomic.rsh22 * 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/opt/gamesdk/third_party/protobuf-3.0.0/java/util/src/test/java/com/google/protobuf/util/
DTimeUtilTest.java130 final List<Thread> threads = new ArrayList<Thread>(); in testTimestampConcurrentParsing() local
137 threads.add(thread); in testTimestampConcurrentParsing()
141 for (Thread thread : threads) { in testTimestampConcurrentParsing()
/frameworks/av/services/audioflinger/
DAudioFlinger.h570 audio_session_t sessionId, const T& threads) { in findIoHandleBySessionId_l() argument
573 for (size_t i = 0; i < threads.size(); i++) { in findIoHandleBySessionId_l()
574 const uint32_t sessionType = threads.valueAt(i)->hasAudioSession(sessionId); in findIoHandleBySessionId_l()
576 io = threads.keyAt(i); in findIoHandleBySessionId_l()

12