| /external/mockito/src/test/java/org/mockitousage/bugs/ |
| ShouldNotDeadlockAnswerExecutionTest.java | 25 ExecutorService threads = Executors.newCachedThreadPool(); local
32 // execute verySlowMethod twice in separate threads
34 threads.execute(new ServiceRunner(service));
35 threads.execute(new ServiceRunner(service));
37 // waiting for threads to finish
39 threads.shutdown();
41 if (!threads.awaitTermination(1000, TimeUnit.MILLISECONDS)) {
42 // threads were timed-out
51 ExecutorService threads = Executors.newCachedThreadPool(); local
59 // execute verySlowMethod twice in separate threads
[all...] |
| /development/tools/bugreport/src/com/android/bugreport/stacks/ |
| ProcessSnapshot.java | 28 public ArrayList<ThreadSnapshot> threads = new ArrayList<ThreadSnapshot>(); field in class:ProcessSnapshot
43 final int N = that.threads.size();
45 this.threads.add(that.threads.get(i).clone());
58 * Compares the threads based on their tid.
68 for (ThreadSnapshot thread: this.threads) {
80 for (ThreadSnapshot thread: this.threads) {
91 for (ThreadSnapshot thread: this.threads) {
|
| /external/ltp/lib/newlib_tests/ |
| test09.c | 23 #define THREADS 64
42 pthread_t threads[THREADS]; local
44 for (i = 0; i < THREADS; i++)
45 pthread_create(threads+i, NULL, worker, (void *)i);
47 for (i = 0; i < THREADS; i++) {
49 pthread_join(threads[i], NULL);
52 if (atomic == THREADS * ITERATIONS)
|
| /external/mockito/src/test/java/org/mockitoutil/ |
| ConcurrentTesting.java | 29 List<Thread> threads = new LinkedList<Thread>(); local
33 threads.add(t);
36 for (Thread t : threads) {
|
| /external/ltp/testcases/kernel/sched/pthreads/ |
| pth_str01.h | 26 pthread_t *threads; /* dynamic array of thread */ member in struct:child_info
|
| /frameworks/base/core/jni/ |
| android_hardware_display_DisplayViewport.h | 23 #include <utils/threads.h>
|
| /system/libhwbinder/include/hwbinder/ |
| Static.h | 20 #include <utils/threads.h>
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/EventModifiers/ |
| ThreadOnlyModifierDebuggee.java | 84 logWriter.println("Create threads");
85 Thread[] threads = new Thread[10]; local
86 for (int i = 0; i < threads.length; ++i) {
87 threads[i] = new Thread(new TestThread(obj));
88 threads[i].setName("TestThread#" + i);
92 THREAD_ONLY = threads[threads.length - 1];
101 // Run all threads.
102 for (int i = 0; i < threads.length; ++i) {
103 runThread(threads[i])
[all...] |
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_atfork/ |
| 1-2.c | 91 pthread_t threads[3]; variable
98 threads[0] = pthread_self();
103 threads[1] = pthread_self();
108 threads[2] = pthread_self();
139 if (!pthread_equal(ch, threads[0])) {
144 if (!pthread_equal(pthread_self(), threads[2])) {
153 if (!pthread_equal(ch, threads[0])) {
158 if (!pthread_equal(pthread_self(), threads[1])) {
|
| /external/tensorflow/tensorflow/core/util/ |
| work_sharder_test.cc | 31 thread::ThreadPool* threads) {
36 Shard(num_workers, threads, total, cost_per_unit,
55 thread::ThreadPool threads(Env::Default(), "test", 16);
59 RunSharding(workers, total, cost_per_unit, &threads);
66 thread::ThreadPool threads(Env::Default(), "test", 3);
71 Shard(workers, &threads, total_elements, cost_per_unit,
80 thread::ThreadPool threads(Env::Default(), "test", 16);
85 Shard(arg - 1, &threads, total, 1, work);
|
| /art/test/911-get-stack-trace/src/art/ |
| ThreadListTraces.java | 22 System.out.println("### Other select threads (suspended) ###");
30 Thread threads[] = new Thread[N]; local
41 threads[i] = t;
63 threads[i].join();
67 public static void printList(Thread[] threads, int max) {
68 PrintThread.printAll(getThreadListStackTraces(threads, max));
71 // Similar to getAllStackTraces, but restricted to the given threads.
72 public static native Object[][] getThreadListStackTraces(Thread threads[], int max);
|
| /external/linux-kselftest/tools/testing/selftests/powerpc/math/ |
| fpu_preempt.c | 12 * no way to be sure preemption happened so this test just uses many threads
32 * worker threads
61 int i, rc, threads; local
64 threads = sysconf(_SC_NPROCESSORS_ONLN) * THREAD_FACTOR;
65 tids = malloc((threads) * sizeof(pthread_t));
69 threads_starting = threads;
70 for (i = 0; i < threads; i++) {
92 for (i = 0; i < threads; i++) {
|
| vmx_preempt.c | 12 * no way to be sure preemption happened so this test just uses many threads
32 * worker threads
61 int i, rc, threads; local
64 threads = sysconf(_SC_NPROCESSORS_ONLN) * THREAD_FACTOR;
65 tids = malloc(threads * sizeof(pthread_t));
69 threads_starting = threads;
70 for (i = 0; i < threads; i++) {
92 for (i = 0; i < threads; i++) {
|
| /external/valgrind/helgrind/tests/ |
| tls_threads.c | 18 /* ptr_to_badly_shared_local allows to have multiple threads seeing
59 pthread_t threads[NLEVEL2]; local
69 pthread_create(&threads[curthread++], NULL, level2, NULL);
73 pthread_join(threads[i], NULL);
81 pthread_t threads[NLEVEL1]; local
88 pthread_create(&threads[curthread++], NULL, level1, NULL);
94 pthread_join(threads[i], NULL);
|
| /system/extras/memory_replay/ |
| main.cpp | 34 #include "Threads.h"
72 Threads threads(&pointers, max_threads);
74 printf("Maximum threads available: %zu\n", threads.max_threads());
103 Thread* thread = threads.FindThread(tid);
105 thread = threads.CreateThread(tid);
119 // Make sure that any other threads doing allocations are complete
122 threads.WaitForAllToQuiesce();
130 threads.Finish(thread)
[all...] |
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/translit/ |
| ThreadTest.java | 28 private ArrayList<Worker> threads = new ArrayList<Worker>(); field in class:ThreadTest
40 threads.add(thread);
44 for (Worker thread: threads) {
51 errln("Threads gave differing results.");
83 ArrayList<Thread> threads = new ArrayList<Thread>(); local
85 threads.add(new Thread() {
92 for (Thread th:threads) {
95 for (Thread th:threads) {
|
| /external/icu/icu4j/main/tests/translit/src/com/ibm/icu/dev/test/translit/ |
| ThreadTest.java | 25 private ArrayList<Worker> threads = new ArrayList<Worker>(); field in class:ThreadTest
37 threads.add(thread);
41 for (Worker thread: threads) {
48 errln("Threads gave differing results.");
80 ArrayList<Thread> threads = new ArrayList<Thread>(); local
82 threads.add(new Thread() {
89 for (Thread th:threads) {
92 for (Thread th:threads) {
|
| /external/tensorflow/tensorflow/python/training/ |
| coordinator_test.py | 100 threads = [
105 for t in threads:
107 coord.join(threads)
108 for t in threads:
113 threads = [
118 for t in threads:
122 for t in threads:
127 threads = [
132 for t in threads:
135 # threads[1] is not registered we must pass it in
[all...] |
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/collator/ |
| CollationThreadTest.java | 229 private void runThreads(Thread[] threads, Control control) {
230 for (int i = 0; i < threads.length; ++i) {
231 threads[i].start();
244 for (int i = 0; i < threads.length; ++i) {
245 threads[i].join();
262 Thread[] threads = new Thread[10]; local
263 for (int i = 0; i < threads.length; ++i) {
274 threads[i] = new Thread(test);
277 runThreads(threads, control);
287 Thread[] threads = new Thread[10] local
[all...] |
| /external/icu/icu4j/main/tests/collate/src/com/ibm/icu/dev/test/collator/ |
| CollationThreadTest.java | 226 private void runThreads(Thread[] threads, Control control) {
227 for (int i = 0; i < threads.length; ++i) {
228 threads[i].start();
241 for (int i = 0; i < threads.length; ++i) {
242 threads[i].join();
259 Thread[] threads = new Thread[10]; local
260 for (int i = 0; i < threads.length; ++i) {
271 threads[i] = new Thread(test);
274 runThreads(threads, control);
284 Thread[] threads = new Thread[10] local
[all...] |
| /external/compiler-rt/lib/tsan/tests/unit/ |
| tsan_mutex_test.cc | 99 pthread_t threads[kThreads]; local
101 pthread_create(&threads[i], 0, write_mutex_thread<Mutex>, &data);
103 pthread_join(threads[i], 0);
109 pthread_t threads[kThreads]; local
111 pthread_create(&threads[i], 0, read_mutex_thread<Mutex>, &data);
113 pthread_join(threads[i], 0);
119 pthread_t threads[kThreads]; local
121 pthread_create(&threads[i], 0, write_mutex_thread<SpinMutex>, &data);
123 pthread_join(threads[i], 0);
|
| /external/libvpx/libvpx/test/ |
| stress.sh | 80 local readonly threads="$4"
94 "${YUV}" "-t ${threads} --limit=150 --test-decode=fatal --passes=1" \
104 "${YUV}" "-t ${threads} --limit=150 --test-decode=fatal --passes=2" \
114 "${YUV}" "-t ${threads} --limit=150 --test-decode=fatal " \
127 eval "${decoder}" "-t ${threads}" "${webm}" "--noblit" ${devnull} &
157 for threads in 4 8 100; do
158 vp9_stress "$threads" "--row-mt=0"
163 for threads in 4 8 100; do
164 vp9_stress "$threads" "--row-mt=1"
|
| /art/test/145-alloc-tracking-stress/src/ |
| Main.java | 44 final Thread[] threads = new Thread[numberOfThreads]; local
45 for (int t = 0; t < threads.length; t++) {
46 threads[t] = new Thread(new Main(t));
47 threads[t].start();
49 for (Thread t : threads) {
|
| /art/test/597-deopt-invoke-stub/src/ |
| Main.java | 35 final Thread[] threads = new Thread[numberOfThreads]; local
36 for (int t = 0; t < threads.length; t++) {
37 threads[t] = new Thread(new Main(t));
38 threads[t].start();
40 for (Thread t : threads) {
|
| /art/test/597-deopt-new-string/src/ |
| Main.java | 34 final Thread[] threads = new Thread[numberOfThreads]; local
35 for (int t = 0; t < threads.length; t++) {
36 threads[t] = new Thread(new Main(t));
37 threads[t].start();
39 for (Thread t : threads) {
61 // This thread keeps doing deoptimization of all threads.
63 // StringFactory.newEmptyString() in one of the other threads.
|
