| /prebuilts/gdb/darwin-x86/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/gdb/linux-x86/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/gdb/linux-x86/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/ndk/r16/sources/cxx-stl/llvm-libc++abi/test/ |
| test_exception_storage.pass.cpp | 45 std::__libcpp_thread_t threads [ NUMTHREADS ]; variable
52 // Make the threads, let them run, and wait for them to finish
54 std::__libcpp_thread_create ( threads + i, thread_code, (void *) (thread_globals + i));
56 std::__libcpp_thread_join ( &threads [ i ] );
|
| /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/eigen/Eigen/src/Core/products/ |
| Parallelizer.h | 47 /** Must be call first when calling Eigen from multiple threads */
56 /** \returns the max number of threads reserved for Eigen
65 /** Sets the max number of threads reserved for Eigen
102 // - the max number of threads we can create is greater than 1
106 // compute the maximal number of threads from the size of the product:
111 // compute the maximal number of threads from the total amount of work:
117 // compute the number of threads we are going to use
118 Index threads = std::min<Index>(nbThreads(), pb_max_threads);
123 if((!Condition) || (threads==1) || (omp_get_num_threads()>1))
127 func.initParallelSession(threads);
[all...] |
| /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/libchrome/base/threading/ |
| thread_local_storage_unittest.cc | 100 // threads that set the TLS, while the destructor cleans it up.
101 // After the threads finish, verify that the value is cleaned up.
105 DelegateSimpleThread* threads[kNumThreads]; local
109 // Spawn the threads.
113 threads[index] = new DelegateSimpleThread(thread_delegates[index],
115 threads[index]->Start();
118 // Wait for the threads to finish.
120 threads[index]->Join();
121 delete threads[index];
127 tls_slot.Free(); // Stop doing callbacks to cleanup threads
[all...] |
| /external/libvpx/libvpx/test/ |
| invalid_file_test.cc | 29 int threads; member in struct:__anon26027::DecodeParam
34 return os << "threads: " << dp.threads << " file: " << dp.filename;
65 if (input.threads > 1) {
88 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/google-benchmark/test/ |
| benchmark_test.cc | 80 BENCHMARK(BM_CalculatePi)->Threads(8);
158 int thread_size = size / state.threads;
169 // do not overlap between threads.
225 assert(st.threads == 1 || st.threads == 2 || st.threads == 3);
228 assert(st.threads == 1 || st.threads == 3 || st.threads == 4);
231 assert(st.threads == 5 || st.threads == 8 || st.threads == 11 |
[all...] |
| /external/libcxx/utils/google-benchmark/test/ |
| benchmark_test.cc | 80 BENCHMARK(BM_CalculatePi)->Threads(8);
158 int thread_size = size / state.threads;
169 // do not overlap between threads.
225 assert(st.threads == 1 || st.threads == 2 || st.threads == 3);
228 assert(st.threads == 1 || st.threads == 3 || st.threads == 4);
231 assert(st.threads == 5 || st.threads == 8 || st.threads == 11 |
[all...] |
| /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/clang/test/OpenMP/ |
| ordered_messages.cpp | 30 #pragma omp ordered threads threads // expected-error {{directive '#pragma omp ordered' cannot contain more than one 'threads' clause}}
44 #pragma omp ordered threads // expected-error {{'ordered' directive with 'threads' clause cannot be closely nested inside ordered region with specified parameter}}
62 #pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd region}}
76 #pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd region}}
90 #pragma omp ordered threads // expected-error {{OpenMP constructs may not be nested inside a simd region}}
118 #pragma omp ordered depend(source) threads // expected-error {{'depend' clauses cannot be mixed with 'threads' clause}
[all...] |
| /external/tensorflow/tensorflow/python/training/ |
| coordinator.py | 15 """Coordinator to help multiple threads stop when requested."""
35 """A coordinator for threads.
38 set of threads.
45 # Start a number of threads, passing the coordinator to each of them.
48 # Wait for all the threads to terminate.
49 coord.join(threads)
52 Any of the threads can call `coord.request_stop()` to ask for all the threads
86 # Start a number of threads, passing the coordinator to each of them.
89 # Wait for all the threads to terminate
[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([&, 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/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...] |
| /art/test/925-threadgroups/src/art/ |
| Test925.java | 70 Thread[] threads = (Thread[])data[0]; local
73 List<Thread> threadList = new ArrayList<>(Arrays.asList(threads));
101 Thread[] threads = (Thread[])data[0]; local
102 if (threads.length == expectedChildCount) {
109 Thread[] threads = (Thread[])data[0]; local
110 System.out.println(Arrays.toString(threads));
128 // Returns an array where element 0 is an array of threads and element 1 is an array of groups.
|
