| /external/protobuf/src/google/protobuf/stubs/ |
| once_unittest.cc | 211 scoped_ptr<TestThread> threads[4]; local
214 threads[i].reset(RunInitOnceInNewThread());
217 threads[i]->Join();
228 scoped_ptr<TestThread> threads[8]; local
233 threads[i].reset(RunInitOnceInNewThread());
236 threads[i].reset(RunInitRecursiveOnceInNewThread());
248 threads[i]->Join();
|
| /external/python/cpython2/Python/ |
| thread_beos.h | 149 int32 threads; local
154 threads = atomic_add( &thread_count, 0 );
156 if( threads == 0 ) {
157 /* No threads around, so exit main(). */
|
| /external/skia/tools/flags/ |
| SkCommonFlags.h | 32 DECLARE_int32(threads); variable
|
| /frameworks/base/apct-tests/perftests/core/src/android/text/ |
| StaticLayoutMultithreadPerfTest.java | 58 Thread[] threads = new Thread[numOfThreads]; local
61 threads[i] = new Thread(new Runnable() {
79 threads[i].start();
87 return threads;
90 private void finishThreads(Thread[] threads) {
92 for (Thread thread : threads) {
106 Thread[] threads = startBackgroundThread(numOfTotalThreads - 1); local
117 finishThreads(threads);
|
| /frameworks/base/tests/WindowManagerStressTest/src/test/windowmanagerstresstest/ |
| MainActivity.java | 99 ArrayList<Thread> threads = new ArrayList<>(); local
113 threads.add(t);
117 for (Thread t : threads) {
|
| /frameworks/rs/cpu_ref/ |
| rsCpuIntrinsicHistogram.cpp | 101 const uint32_t threads = mCtx->getThreadCount(); local
139 memset(mSums, 0, 256 * sizeof(int32_t) * threads * vSize);
150 uint32_t threads = mCtx->getThreadCount(); local
157 for (uint32_t t=1; t < threads; t++) {
|
| /frameworks/wilhelm/tests/sandbox/ |
| multithread.c | 17 // Multiple threads create and destroy objects
37 pthread_t threads[MAX_THREAD]; variable
128 // create threads
155 ok = pthread_create(&threads[i], (const pthread_attr_t *) NULL, thread_start,
171 // signal threads that they should exit
183 // now wait for the threads to actually exit
185 ok = pthread_join(threads[i], NULL);
|
| /libcore/luni/src/test/java/tests/support/ |
| ThreadPool.java | 79 Thread[] threads = new Thread[activeCount()]; local
80 int count = enumerate(threads);
83 threads[i].join();
|
| /system/core/libmemunreachable/tests/ |
| ThreadCapture_test.cpp | 54 void StartThreads(unsigned int threads, Function&& func) {
55 threads_.reserve(threads);
56 tids_.reserve(threads);
57 for (unsigned int i = 0; i < threads; i++) {
58 threads_.emplace_back([&, threads, this]() {
62 if (tids_.size() == threads) {
78 cv_start_.wait(lk, [&] { return tids_.size() == threads; });
142 const unsigned int threads = GetParam() - 1; local
144 StartThreads(threads, []() {});
208 const unsigned int threads = GetParam() local
[all...] |
| /system/core/libunwindstack/tests/ |
| UnwindTest.cpp | 314 // Verify that using the same map while unwinding multiple threads at the
323 std::vector<std::thread*> threads; local
340 threads.push_back(thread);
343 for (auto thread : threads) {
|
| /system/extras/iotop/ |
| taskstats.h | 44 int threads() const { return threads_; } function in class:TaskStatistics
|
| /system/extras/verity/fec/ |
| image.cpp | 354 int threads = ctx->threads; local
356 if (threads < IMAGE_MIN_THREADS) {
357 threads = sysconf(_SC_NPROCESSORS_ONLN);
359 if (threads < IMAGE_MIN_THREADS) {
360 threads = IMAGE_MIN_THREADS;
366 if ((uint64_t)threads > ctx->rounds) {
367 threads = (int)ctx->rounds;
369 if (threads > IMAGE_MAX_THREADS) {
370 threads = IMAGE_MAX_THREADS
[all...] |
| image.h | 53 int threads; member in struct:image
|
| /toolchain/binutils/binutils-2.27/gold/ |
| workqueue.cc | 128 bool threads = options.threads(); local
130 threads = false;
132 if (!threads)
260 // Kick all the threads to make them exit.
443 // them to the run queue and signal any other threads. This must be
490 // function is called by all threads.
499 // Set the number of threads to use for the workqueue, if we are using
500 // threads.
503 Workqueue::set_thread_count(int threads)
[all...] |
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/rbbi/ |
| RBBITest.java | 410 List<Thread> threads = new ArrayList<Thread>(); local
412 threads.add(new Thread(new WorkerThread()));
414 for (Thread thread: threads) {
417 for (Thread thread: threads) {
425 // JUnit wont see failures from within the worker threads, so
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/locksettings/ |
| LockSettingsStorageTests.java | 120 List<Thread> threads = new ArrayList<>(); local
123 threads.add(new Thread() {
145 threads.get(i).start();
151 for (int i = 0; i < threads.size(); i++) {
153 threads.get(i).join();
164 List<Thread> threads = new ArrayList<>(); local
167 threads.add(new Thread() {
182 threads.get(i).start();
185 for (int i = 0; i < threads.size(); i++) {
187 threads.get(i).join()
[all...] |
| /art/test/051-thread/src/ |
| Main.java | 43 TestCapacityThread[] threads = new TestCapacityThread[128]; local
44 for (int i = 0; i < threads.length; i++) {
45 threads[i] = new TestCapacityThread();
48 for (TestCapacityThread thread : threads) {
51 for (TestCapacityThread thread : threads) {
168 Thread threads[] = new Thread[10]; local
170 current.getThreadGroup().enumerate(threads);
172 for (Thread t : threads) {
178 throw new RuntimeException("Did not find main thread: " + Arrays.toString(threads));
|
| /art/test/626-const-class-linking/src/ |
| Main.java | 123 final Thread[] threads = new Thread[4]; local
124 final Object[] results = new Object[threads.length];
126 final RacyLoader racy_loader = new RacyLoader(system_loader, threads.length);
130 for (int i = 0; i != threads.length; ++i) {
145 threads[i] = t;
147 for (Thread t : threads) {
157 final Thread[] threads = new Thread[4]; local
158 final Object[] results = new Object[threads.length];
160 final RacyLoader racy_loader = new RacyLoader(system_loader, threads.length);
166 for (int i = 0; i != threads.length; ++i)
194 final Thread[] threads = new Thread[4]; local
229 final Thread[] threads = new Thread[4]; local
[all...] |
| /art/test/923-monitors/src/art/ |
| Test923.java | 103 List<Thread> threads = new ArrayList<Thread>(); local
106 threads.add(t);
110 // Wait till all threads have been started.
113 // Hopefully enough time for all the threads to progress into wait.
138 for (Thread t : threads) {
179 // 5) N-1 threads wake up, run, and die.
|
| /art/test/ti-agent/ |
| jni_binder.cc | 196 // Look at the context classloaders of all threads.
198 jthread* threads; local
199 CheckJvmtiError(jvmti_env, jvmti_env->GetAllThreads(&thread_count, &threads));
200 JvmtiUniquePtr threads_uptr = MakeJvmtiUniquePtr(jvmti_env, threads);
207 CheckJvmtiError(jvmti_env, jvmti_env->GetThreadInfo(threads[t], &info));
218 env->DeleteLocalRef(threads[t]);
|
| /cts/hostsidetests/os/src/android/os/cts/ |
| ProcfsHostTests.java | 105 * app easily has 10+ threads including those from Android runtime).
108 * threads may be idling for a while so it is hard to test whether they are being updated within a
116 assertTrue("/proc/" + mTestAppPid + "/task/ includes < 2 threads", tids.length >= 2);
215 String[] threads = lsOutput.split("\\s+"); local
216 int[] tids = new int[threads.length];
217 for (int i = 0; i < threads.length; i++) {
218 tids[i] = Integer.parseInt(threads[i]);
|
| /external/compiler-rt/lib/asan/tests/ |
| asan_interface_test.cc | 122 pthread_t threads[kManyThreadsNumThreads]; local
125 PTHREAD_CREATE(&threads[i], 0,
129 PTHREAD_JOIN(threads[i], 0);
|
| /external/compiler-rt/lib/sanitizer_common/tests/ |
| sanitizer_thread_registry_test.cc | 71 // Create a bunch of threads.
81 // Finish, create and start more threads.
108 // Detach and finish and join remaining threads.
204 pthread_t threads[kNumShards]; local
209 PTHREAD_CREATE(&threads[i], 0, RunThread, &args[i]);
212 PTHREAD_JOIN(threads[i], 0);
215 // of "threads" in thread_registry.
|
| /external/compiler-rt/lib/tsan/rtl/ |
| tsan_report.h | 111 Vector<ReportThread*> threads; member in class:__tsan::ReportDesc
|
| /external/deqp/framework/delibs/decpp/ |
| deBlockBuffer.cpp | 309 vector<Thread*> threads; local
314 threads.push_back(new Consumer(&buffer, rnd.getUint32()));
316 threads.push_back(new Producer(&buffer, rnd.getUint32()));
319 // Start threads.
320 for (vector<Thread*>::iterator i = threads.begin(); i != threads.end(); i++)
329 // Wait for threads to finish.
330 for (vector<Thread*>::iterator i = threads.begin(); i != threads.end(); i++)
336 // Delete threads
[all...] |
