| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/bsddb/test/ |
| test_lock.py | 56 threads = []
57 threads.append(Thread(target = self.theThread,
59 threads.append(Thread(target = self.theThread,
61 threads.append(Thread(target = self.theThread,
63 threads.append(Thread(target = self.theThread,
65 threads.append(Thread(target = self.theThread,
67 threads.append(Thread(target = self.theThread,
69 threads.append(Thread(target = self.theThread,
71 threads.append(Thread(target = self.theThread,
73 threads.append(Thread(target = self.theThread
[all...] |
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| test_dummy_threading.py | 44 self.threads = []
49 self.threads.append(t)
54 for t in self.threads:
|
| test_threadedtempfile.py | 3 in each of NUM_THREADS threads, recording the number of successes and
49 threads = []
54 threads.append(t)
61 for t in threads:
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/bsddb/test/ |
| test_lock.py | 56 threads = []
57 threads.append(Thread(target = self.theThread,
59 threads.append(Thread(target = self.theThread,
61 threads.append(Thread(target = self.theThread,
63 threads.append(Thread(target = self.theThread,
65 threads.append(Thread(target = self.theThread,
67 threads.append(Thread(target = self.theThread,
69 threads.append(Thread(target = self.theThread,
71 threads.append(Thread(target = self.theThread,
73 threads.append(Thread(target = self.theThread
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_dummy_threading.py | 44 self.threads = []
49 self.threads.append(t)
54 for t in self.threads:
|
| test_threadedtempfile.py | 3 in each of NUM_THREADS threads, recording the number of successes and
49 threads = []
54 threads.append(t)
61 for t in threads:
|
| /external/chromium-trace/catapult/telemetry/telemetry/timeline/ |
| inspector_importer_unittest.py | 140 threads = process.threads
141 self.assertEquals(2, len(threads))
142 renderer_thread = threads[0]
146 second_thread = threads['2']
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| MoreExecutorsDirectExecutorBenchmark.java | 66 Set<Thread> threads = new HashSet<Thread>(); field in class:MoreExecutorsDirectExecutorBenchmark
80 threads.add(thread);
85 for (Thread thread : threads) {
88 threads.clear();
106 for (Thread thread : threads) {
|
| /external/libvpx/libvpx/test/ |
| invalid_file_test.cc | 29 int threads; member in struct:__anon17048::DecodeParam
34 return os << "threads: " << dp.threads << " file: " << dp.filename;
67 if (input.threads > 1) {
90 cfg.threads = input.threads;
|
| /libcore/ojluni/src/main/java/java/lang/ |
| ThreadGroup.java | 34 * A thread group represents a set of threads. In addition, a thread
73 Thread threads[]; field in class:ThreadGroup
178 * Returns the maximum priority of this thread group. Threads that are
238 * Sets the maximum priority of the group. Threads in the thread
331 * Returns an estimate of the number of active threads in this thread
336 * threads may change dynamically while this method traverses internal
338 * system threads. This method is intended primarily for debugging
341 * @return an estimate of the number of active threads in this thread
383 * an array into which to put the list of threads
385 * @return the number of threads put into the arra
[all...] |
| /external/protobuf/src/google/protobuf/stubs/ |
| once_unittest.cc | 209 scoped_ptr<TestThread> threads[4]; local
212 threads[i].reset(RunInitOnceInNewThread());
215 threads[i]->Join();
226 scoped_ptr<TestThread> threads[8]; local
231 threads[i].reset(RunInitOnceInNewThread());
234 threads[i].reset(RunInitRecursiveOnceInNewThread());
246 threads[i]->Join();
|
| /external/skia/src/core/ |
| SkTaskGroup.cpp | 58 if (!gGlobal) { // If we have no threads, the work must already be done.
80 // We threads gotta stick together. We're always making forward progress.
99 explicit ThreadPool(int threads) {
100 if (threads == -1) {
101 threads = sk_num_cores();
103 for (int i = 0; i < threads; i++) {
181 // We make do, but this means some worker threads may wake spuriously.
194 SkTaskGroup::Enabler::Enabler(int threads) {
196 if (threads != 0) {
197 ThreadPool::gGlobal = new ThreadPool(threads);
[all...] |
| /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([&, i, threads, this]() {
62 if (tids_.size() == threads) {
78 cv_start_.wait(lk, [&]{ return tids_.size() == threads; });
144 const unsigned int threads = GetParam() - 1; local
146 StartThreads(threads, [](){});
212 const unsigned int threads = GetParam() local
[all...] |
| /external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/s3/ |
| test_pool.py | 74 # Create 30 threads that each create an object in S3. The number
78 threads = [
82 for t in threads:
85 # Create 30 threads to read the contents of the new objects. This
89 threads = [
93 for t in threads:
111 time.sleep(0) # yield to other threads
163 I was expecting that it would fail because two threads would be
220 # Start some threads to read it and check that they are reading
222 threads =
[all...] |
| /external/opencv3/3rdparty/openexr/IlmThread/ |
| IlmThreadPool.cpp | 91 Semaphore taskSemaphore; // threads wait on this for ready tasks
98 Mutex threadMutex; // mutual exclusion for threads list
99 list<WorkerThread*> threads; // the list of all threads member in struct:IlmThread::ThreadPool::Data
102 bool stopping; // flag indicating whether to stop threads
233 // Signal enough times to allow all threads to stop.
235 // Wait until all threads have started their run functions.
236 // If we do not wait before we destroy the threads then it's
237 // possible that the threads have not yet called their run
251 // Join all the threads
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ThreadReference/ |
| ThreadGroupTest.java | 50 * debuggee threads by VirtualMachine.AllThreads command and looks for tested thread.
61 logWriter.println("get all threads");
63 int threads = reply.getNextValueAsInt(); local
64 logWriter.println("exercise threads = " + threads);
70 for (int i = 0; i < threads; i++) {
|
| /external/libcxxabi/test/ |
| test_exception_storage.pass.cpp | 44 pthread_t threads [ NUMTHREADS ]; variable
64 // Make the threads, let them run, and wait for them to finish
66 pthread_create( threads + i, NULL, thread_code, (void *) (thread_globals + i));
68 pthread_join ( threads [ i ], NULL );
|
| /ndk/sources/cxx-stl/llvm-libc++abi/libcxxabi/test/ |
| test_exception_storage.pass.cpp | 44 pthread_t threads [ NUMTHREADS ]; variable
64 // Make the threads, let them run, and wait for them to finish
66 pthread_create( threads + i, NULL, thread_code, (void *) (thread_globals + i));
68 pthread_join ( threads [ i ], NULL );
|
| /prebuilts/misc/windows/sdl2/test/ |
| testlock.c | 27 static SDL_Thread *threads[6]; variable
61 SDL_WaitThread(threads[i], NULL);
84 /* If this sleep isn't done, then threads may starve */
121 if ((threads[i] = SDL_CreateThread(Run, name, NULL)) == NULL)
|
| testsem.c | 82 SDL_Thread *threads[NUM_THREADS]; local
105 SDL_Log("Running %d threads, semaphore value = %d\n", NUM_THREADS,
107 /* Create all the threads */
111 threads[i] = SDL_CreateThread(ThreadFunc, name, (void *) i);
117 /* Wait for all threads to finish */
118 SDL_Log("Waiting for threads to finish\n");
121 SDL_WaitThread(threads[i], NULL);
123 SDL_Log("Finished waiting for threads\n");
|
| /art/test/051-thread/src/ |
| Main.java | 38 TestCapacityThread[] threads = new TestCapacityThread[512]; local
40 threads[i] = new TestCapacityThread();
43 for (TestCapacityThread thread : threads) {
46 for (TestCapacityThread thread : threads) {
|
| /cts/suite/audio_quality/test/ |
| AudioPlaybackLocalTest.cpp | 19 #include <utils/threads.h>
|
| AudioRecordingLocalTest.cpp | 19 #include <utils/threads.h>
|
| /development/ndk/platforms/android-3/include/linux/ |
| kernel_stat.h | 17 #include <linux/threads.h>
|
| /device/asus/fugu/libaudio/ |
| AudioHotplugThread.h | 21 #include <utils/threads.h>
|
